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

[CP] fix autoinc not refresh location cache for some error code

Browse Source
This commit is contained in:
Hongqin-Li
2023-10-20 12:43:56 +00:00
committed by ob-robot
parent 1d37a07e69
commit 5f5a283570
2 changed files with 13 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
src/share/ob_tablet_autoincrement_service.cpp
View File

@ -159,13 +159,16 @@ int ObTabletAutoincMgr::fetch_new_range(const ObTabletAutoincParam &param,
} else { } else {
finish = true; finish = true;
} }
if (OB_FAIL(ret) && is_retryable(ret)) { if (OB_FAIL(ret)) {
const bool need_refresh_leader = OB_NOT_MASTER == ret || OB_LS_NOT_EXIST == ret || OB_TABLET_NOT_EXIST == ret; const bool force_refresh_leader = OB_NOT_MASTER == ret || OB_LS_NOT_EXIST == ret || OB_TABLET_NOT_EXIST == ret || OB_TENANT_NOT_IN_SERVER == ret;
ob_usleep<common::ObWaitEventIds::STORAGE_AUTOINC_FETCH_RETRY_SLEEP>(RETRY_INTERVAL); if (is_retryable(ret)) {
res.reset(); ob_usleep<common::ObWaitEventIds::STORAGE_AUTOINC_FETCH_RETRY_SLEEP>(RETRY_INTERVAL);
if (OB_FAIL(THIS_WORKER.check_status())) { // overwrite ret res.reset();
LOG_WARN("failed to check status", K(ret)); if (OB_FAIL(THIS_WORKER.check_status())) { // overwrite ret
} else if (need_refresh_leader) { LOG_WARN("failed to check status", K(ret));
}
}
if (OB_SUCC(ret) && force_refresh_leader) {
if (OB_FAIL(location_service->get(param.tenant_id_, tablet_id, INT64_MAX/*expire_renew_time*/, is_cache_hit, arg.ls_id_))) { if (OB_FAIL(location_service->get(param.tenant_id_, tablet_id, INT64_MAX/*expire_renew_time*/, is_cache_hit, arg.ls_id_))) {
LOG_WARN("fail to get log stream id", K(ret), K(ret), K(tablet_id)); LOG_WARN("fail to get log stream id", K(ret), K(ret), K(tablet_id));
} else if (OB_FAIL(location_service->get_leader(GCONF.cluster_id, } else if (OB_FAIL(location_service->get_leader(GCONF.cluster_id,
@ -175,6 +178,8 @@ int ObTabletAutoincMgr::fetch_new_range(const ObTabletAutoincParam &param,
leader_addr))) { leader_addr))) {
LOG_WARN("force get leader failed", K(ret), K(ret), K(arg.ls_id_)); LOG_WARN("force get leader failed", K(ret), K(ret), K(arg.ls_id_));
} }
} else {
(void)location_service->renew_tablet_location(param.tenant_id_, tablet_id, ret, true/*is_nonblock*/);
} }
} }
} }

2
src/share/ob_tablet_autoincrement_service.h
View File

@ -80,7 +80,7 @@ private:
} }
bool is_retryable(int ret) bool is_retryable(int ret)
{ {
return OB_NOT_MASTER == ret || OB_NOT_INIT == ret || OB_TIMEOUT == ret || OB_EAGAIN == ret || OB_LS_NOT_EXIST == ret || OB_TABLET_NOT_EXIST == ret; return OB_NOT_MASTER == ret || OB_NOT_INIT == ret || OB_TIMEOUT == ret || OB_EAGAIN == ret || OB_LS_NOT_EXIST == ret || OB_TABLET_NOT_EXIST == ret || OB_TENANT_NOT_IN_SERVER == ret;
} }
private: private:
static const int64_t PREFETCH_THRESHOLD = 4; static const int64_t PREFETCH_THRESHOLD = 4;