hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 2 Packages Projects Releases Wiki Activity

fix memleak when px submit

Browse Source
This commit is contained in:
ly0
2022-02-28 20:17:37 +08:00
committed by LINxiansheng
parent c160d95033
commit c7b59a9dde
1 changed files with 3 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
deps/oblib/src/lib/coro/co_base_sched.cpp vendored
View File

@ -81,7 +81,7 @@ void CoBaseSched::run()
if (OB_SUCC(create_routine(curr->func_))) {
has_new_routine = true;
the_tasks.remove(curr);
common::ob_free(curr);
OB_DELETE(Task, ObModIds::OB_CORO, curr);
} else {
break;
}
@ -263,10 +263,7 @@ void CoBaseSched::cancel_timer(CoTimer& timer)
int CoBaseSched::submit(RunFuncT&& func)
{
int ret = OB_SUCCESS;
Task* t = (Task*)common::ob_malloc(sizeof(Task), ObModIds::OB_CORO);
if (t != nullptr) {
new (t) Task(func);
}
Task* t = OB_NEW(Task, ObModIds::OB_CORO, func);
if (OB_ISNULL(t)) {
ret = OB_ALLOCATE_MEMORY_FAILED;
} else {
@ -281,10 +278,7 @@ int CoBaseSched::submit(RunFuncT&& func)
int CoBaseSched::submit(const RunFuncT& func)
{
int ret = OB_SUCCESS;
Task* t = (Task*)common::ob_malloc(sizeof(Task), ObModIds::OB_CORO);
if (t != nullptr) {
new (t) Task(func);
}
Task* t = OB_NEW(Task, ObModIds::OB_CORO, func);
if (OB_ISNULL(t)) {
ret = OB_ALLOCATE_MEMORY_FAILED;
} else {