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

modify inner sql nonblock_get_leader retry logic

Browse Source
This commit is contained in:
obdev
2023-03-14 19:43:49 +00:00
committed by ob-robot
parent b1c17ccbdf
commit 67212153f3
1 changed files with 30 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

46
src/observer/ob_inner_sql_connection.cpp
View File

@ -2127,22 +2127,36 @@ int ObInnerSQLConnection::nonblock_get_leader(
} else if (OB_FAIL(set_timeout(abs_timeout_us))) {
LOG_WARN("set timeout failed", K(ret));
} else {
const int64_t retry_interval_us = 200 * 1000;
if (OB_FAIL(GCTX.location_service_->get_leader_with_retry_until_timeout(
cluster_id,
tenant_id,
ls_id,
leader,
abs_timeout_us,
retry_interval_us))) {
LOG_WARN("get leader with retry until timeout failed", KR(ret), K(tenant_id), K(ls_id),
K(leader), K(cluster_id), K(abs_timeout_us), K(retry_interval_us));
} else if (OB_UNLIKELY(!leader.is_valid())) {
ret = OB_ERR_UNEXPECTED;
LOG_WARN("leader addr is invalid", K(ret), K(tenant_id), K(ls_id), K(leader), K(cluster_id));
} else {
LOG_DEBUG("get participants", K(tenant_id), K(ls_id), K(leader), K(cluster_id));
}
bool is_tenant_dropped = false;
int64_t tmp_abs_timeout_us = 0;
const int64_t retry_interval_us = 200 * 1000; // 200ms
do {
tmp_abs_timeout_us = ObTimeUtility::current_time() + GCONF.location_cache_refresh_sql_timeout;
if (THIS_WORKER.is_timeout()) {
ret = OB_TIMEOUT;
LOG_WARN("already timeout", K(ret), K(THIS_WORKER.get_timeout_ts()));
} else if (OB_FAIL(GSCHEMASERVICE.check_if_tenant_has_been_dropped(
tenant_id, is_tenant_dropped))) {
LOG_WARN("user tenant has been dropped", KR(ret), K(tenant_id));
} else if (is_tenant_dropped) {
ret = OB_TENANT_HAS_BEEN_DROPPED;
LOG_WARN("user tenant has been dropped", KR(ret), K(tenant_id));
} else if (OB_FAIL(GCTX.location_service_->get_leader_with_retry_until_timeout(
cluster_id,
tenant_id,
ls_id,
leader,
tmp_abs_timeout_us,
retry_interval_us))) {
LOG_WARN("get leader with retry until timeout failed", KR(ret), K(tenant_id), K(ls_id),
K(leader), K(cluster_id), K(tmp_abs_timeout_us), K(retry_interval_us));
} else if (OB_UNLIKELY(!leader.is_valid())) {
ret = OB_ERR_UNEXPECTED;
LOG_WARN("leader addr invalid", K(ret), K(cluster_id), K(tenant_id), K(ls_id), K(leader));
} else {
LOG_DEBUG("get participants", K(tenant_id), K(ls_id), K(leader), K(cluster_id));
}
} while (is_location_service_renew_error(ret));
}
get_session().set_query_start_time(old_query_start_time);
return ret;