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

[master] check session killed in obmp_init_db

Browse Source
This commit is contained in:
chinaxing
2023-04-03 23:44:34 +00:00
committed by ob-robot
parent bbd5bd36b7
commit c8173884d0
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/observer/mysql/obmp_init_db.cpp
View File

@ -83,7 +83,10 @@ int ObMPInitDB::process()
int64_t retry_times = 0; int64_t retry_times = 0;
THIS_WORKER.set_timeout_ts(get_receive_timestamp() + query_timeout); THIS_WORKER.set_timeout_ts(get_receive_timestamp() + query_timeout);
ObNameCaseMode mode = OB_NAME_CASE_INVALID; ObNameCaseMode mode = OB_NAME_CASE_INVALID;
if (OB_FAIL(gctx_.schema_service_->get_tenant_received_broadcast_version(effective_tenant_id, global_version))) { if (OB_UNLIKELY(session->is_zombie())) {
ret = OB_ERR_SESSION_INTERRUPTED;
LOG_WARN("session has been killed", K(ret), KPC(session));
} else if (OB_FAIL(gctx_.schema_service_->get_tenant_received_broadcast_version(effective_tenant_id, global_version))) {
LOG_WARN("fail to get global_version", K(ret), K(effective_tenant_id)); LOG_WARN("fail to get global_version", K(ret), K(effective_tenant_id));
} else if (OB_FAIL(gctx_.schema_service_->get_tenant_refreshed_schema_version(effective_tenant_id, local_version))) { } else if (OB_FAIL(gctx_.schema_service_->get_tenant_refreshed_schema_version(effective_tenant_id, local_version))) {
LOG_WARN("fail to get local_version", K(ret), K(effective_tenant_id)); LOG_WARN("fail to get local_version", K(ret), K(effective_tenant_id));