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

fix the problem when ObAsyncRpcProxy send rpc failed and do not add response count and result

Browse Source
This commit is contained in:
obdev
2023-01-28 16:19:00 +08:00
committed by ob-robot
parent ad4cf1e9c1
commit df011a89d6
1 changed files with 2 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/share/rpc/ob_async_rpc_proxy.h
View File

@ -262,14 +262,10 @@ int ObAsyncRpcProxy<PC, RpcArg, RpcResult, Func>::call(
RPC_LOG(WARN, "call rpc func failed", K(server), K(timeout), RPC_LOG(WARN, "call rpc func failed", K(server), K(timeout),
K(cluster_id), K(tenant_id), K(arg), KR(ret)); K(cluster_id), K(tenant_id), K(arg), KR(ret));
} }
if (OB_FAIL(ret)) {
cb_list_.remove_last();
}
} }
if (OB_FAIL(ret)) { if (OB_FAIL(ret)) {
// free memory // if send rpc failed, just call on_timeout to fill the result and add response count
cb->~ObAsyncCB(); cb->on_timeout();
allocator_.free(mem);
} }
} }