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

fix wrong blocking status

Browse Source
This commit is contained in:
nroskill
2023-07-07 06:12:31 +00:00
committed by ob-robot
parent 8907d57293
commit 0692a9954d
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/observer/omt/ob_tenant.cpp
View File

@ -388,6 +388,7 @@ void ObResourceGroup::check_worker_count()
workers_.remove(wnode); workers_.remove(wnode);
destroy_worker(w); destroy_worker(w);
} else if (w->has_req_flag() } else if (w->has_req_flag()
&& 0 != w->blocking_ts()
&& now - w->blocking_ts() >= threshold && now - w->blocking_ts() >= threshold
&& enable_dynamic_worker) { && enable_dynamic_worker) {
++token; ++token;
@ -1385,6 +1386,7 @@ void ObTenant::check_worker_count()
workers_.remove(wnode); workers_.remove(wnode);
destroy_worker(w); destroy_worker(w);
} else if (w->has_req_flag() } else if (w->has_req_flag()
&& 0 != w->blocking_ts()
&& now - w->blocking_ts() >= threshold && now - w->blocking_ts() >= threshold
&& w->is_default_worker() && w->is_default_worker()
&& enable_dynamic_worker) { && enable_dynamic_worker) {