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

fix async rpc callbcack hasn't been executed when cb.cloned failed

Browse Source
This commit is contained in:
liucc1997
2023-05-26 08:16:49 +00:00
committed by ob-robot
parent 379dbe0109
commit fa8e909ea6
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
deps/oblib/src/rpc/obrpc/ob_poc_rpc_proxy.cpp vendored
View File

@ -80,20 +80,25 @@ ObAsyncRespCallback* ObAsyncRespCallback::create(ObRpcMemPool& pool, UAsyncCB* u
UAsyncCB* cb = NULL; UAsyncCB* cb = NULL;
ObAsyncRespCallback* pcb = NULL; ObAsyncRespCallback* pcb = NULL;
if (NULL == (pcb = (ObAsyncRespCallback*)pool.alloc(sizeof(ObAsyncRespCallback)))) { if (NULL == (pcb = (ObAsyncRespCallback*)pool.alloc(sizeof(ObAsyncRespCallback)))) {
ret = OB_ALLOCATE_MEMORY_FAILED;
RPC_LOG(WARN, "alloc resp callback fail", K(ret)); RPC_LOG(WARN, "alloc resp callback fail", K(ret));
} else { } else {
if (NULL != ucb) { if (NULL != ucb) {
if (NULL == (cb = ucb->clone(sp_alloc))) { if (NULL == (cb = ucb->clone(sp_alloc))) {
ret = OB_ALLOCATE_MEMORY_FAILED;
pcb = NULL;
RPC_LOG(WARN, "ucb.clone fail", K(ret)); RPC_LOG(WARN, "ucb.clone fail", K(ret));
} else { } else {
cb->low_level_cb_ = pcb; cb->low_level_cb_ = pcb;
if (cb != ucb) { if (cb != ucb) {
cb->set_cloned(true); cb->set_cloned(true);
} }
}
}
new(pcb)ObAsyncRespCallback(pool, cb); new(pcb)ObAsyncRespCallback(pool, cb);
} }
} else {
new(pcb)ObAsyncRespCallback(pool, NULL);
}
}
return pcb; return pcb;
} }