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

fix the core of ObAsyncRpcProxy::wait when executing memory error injection

Browse Source
This commit is contained in:
obdev
2023-02-09 18:16:23 +00:00
committed by ob-robot
parent d95c76359c
commit 16428a2609
1 changed files with 7 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -414,8 +414,13 @@ int ObAsyncRpcProxy<PC, RpcArg, RpcResult, Func>::wait(
} else { } else {
const int rc = cb->get_ret_code(); const int rc = cb->get_ret_code();
if (common::OB_SUCCESS != rc) { if (common::OB_SUCCESS != rc) {
if (index <= (args_.count() -1)) {
RPC_LOG(WARN, "execute rpc failed", K(rc), "server", cb->get_dst(), "timeout", cb->get_timeout(), RPC_LOG(WARN, "execute rpc failed", K(rc), "server", cb->get_dst(), "timeout", cb->get_timeout(),
"packet code", PC, "arg", args_.at(index)); "packet code", PC, "arg", args_.at(index));
} else {
RPC_LOG(WARN, "execute rpc failed and args_ count is not correct", K(rc), "server", cb->get_dst(), "timeout", cb->get_timeout(),
"packet code", PC, K(args_.count()), K(index));
}
} }
if (NULL != return_code_array) { if (NULL != return_code_array) {
if (OB_FAIL(return_code_array->push_back(rc))) { if (OB_FAIL(return_code_array->push_back(rc))) {