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

Fix ls rpc table core

Browse Source
This commit is contained in:
tino247 2023-07-17 06:12:15 +00:00 committed by ob-robot
parent dc60d1a54c
commit ab007e8868
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/share/ls/ob_rpc_ls_table.cpp
View File

@ -298,6 +298,15 @@ int ObRpcLSTable::do_detect_master_rs_ls_(
if (OB_TMP_FAIL(proxy.wait_all(return_ret_array))) { // ignore ret
LOG_WARN("wait batch result failed", KR(tmp_ret), KR(ret));
ret = OB_SUCC(ret) ? tmp_ret : ret;
} else if (proxy.get_dests().count() != proxy.get_args().count()
|| return_ret_array.count() != proxy.get_args().count()
|| return_ret_array.count() != proxy.get_results().count()) {
ret = OB_STATE_NOT_MATCH;
LOG_WARN("args/dest/return_ret_array/results count not match, need retry",
KR(ret), "args_cnt", proxy.get_args().count(),
"dests_cnt", proxy.get_dests().count(),
"return_cnt", return_ret_array.count(),
"result_cnt", proxy.get_results().count());
}
bool leader_exist = false;
for (int64_t i = 0; OB_SUCC(ret) && i < return_ret_array.count(); i++) {