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

Add timeout for autoinc rpc

Browse Source
This commit is contained in:
Hongqin-Li
2023-12-07 02:42:12 +00:00
committed by ob-robot
parent 892fbee583
commit 6c2f308816
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/share/ob_tablet_autoincrement_service.cpp
View File

@ -152,7 +152,7 @@ int ObTabletAutoincMgr::fetch_new_range(const ObTabletAutoincParam &param,
false,/*force_renew*/ false,/*force_renew*/
leader_addr))) { leader_addr))) {
LOG_WARN("get leader failed", K(ret), K(arg.ls_id_)); LOG_WARN("get leader failed", K(ret), K(arg.ls_id_));
} else if (OB_FAIL(srv_rpc_proxy->to(leader_addr).fetch_tablet_autoinc_seq_cache(arg, res))) { } else if (OB_FAIL(srv_rpc_proxy->to(leader_addr).timeout(THIS_WORKER.get_timeout_remain()).fetch_tablet_autoinc_seq_cache(arg, res))) {
LOG_WARN("fail to fetch autoinc cache for tablets", K(ret), K(retry_times), K(arg)); LOG_WARN("fail to fetch autoinc cache for tablets", K(ret), K(retry_times), K(arg));
} else { } else {
finish = true; finish = true;