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

fix sts cache go back problem

Browse Source
This commit is contained in:
obdev
2023-05-09 08:12:01 +00:00
committed by ob-robot
parent 988c3c5dbd
commit bbff688675
1 changed files with 10 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
src/rootserver/ob_tenant_info_loader.cpp
View File

@ -474,12 +474,17 @@ int ObAllTenantInfoCache::refresh_tenant_info(const uint64_t tenant_id,
* During the switch to standby process, some LS may be in RO state. GTS & STS may not work. * During the switch to standby process, some LS may be in RO state. GTS & STS may not work.
* This also ensures the consistency of tenant_role cache and the tenant role field in all_tenant_info * This also ensures the consistency of tenant_role cache and the tenant role field in all_tenant_info
*/ */
MTL_SET_TENANT_ROLE(new_tenant_info.get_tenant_role().value());
SpinWLockGuard guard(lock_); SpinWLockGuard guard(lock_);
(void)tenant_info_.assign(new_tenant_info); if (ora_rowscn > ora_rowscn_) {
last_sql_update_time_ = new_refresh_time_us; MTL_SET_TENANT_ROLE(new_tenant_info.get_tenant_role().value());
ora_rowscn_ = ora_rowscn; (void)tenant_info_.assign(new_tenant_info);
refreshed = true; last_sql_update_time_ = new_refresh_time_us;
ora_rowscn_ = ora_rowscn;
refreshed = true;
} else {
LOG_WARN("refresh tenant info conflict", K(new_tenant_info), K(new_refresh_time_us),
K(tenant_id), K(tenant_info_), K(last_sql_update_time_), K(ora_rowscn_), K(ora_rowscn));
}
} }
if (dump_tenant_info_interval_.reach()) { if (dump_tenant_info_interval_.reach()) {