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

[CP] fix: trigger create L0 worker when L1-L9 queue has request

Browse Source
This commit is contained in:
obdev 2024-11-26 07:45:11 +00:00 committed by ob-robot
parent 8a67280deb
commit d210ef0f00
1 changed files with 8 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -485,31 +485,26 @@ void ObResourceGroup::check_worker_count()
}
}
int64_t target_min = 0;
int64_t token = 0;
bool is_group_critical = share::ObCgSet::instance().is_group_critical(group_id_);
bool is_group_critical = share::ObCgSet::instance().is_group_critical(group_id_) || is_resource_manager_group(group_id_);
if (is_group_critical) {
target_min = min_worker_cnt();
token = 1 + blocking_cnt;
token = std::min(token, max_worker_cnt());
token = std::max(token, target_min);
token = std::max(token, min_worker_cnt());
} else {
if (req_queue_.size() > 0) {
target_min = std::min(req_queue_.size() + workers_.get_size(), min_worker_cnt());
}
if (blocking_cnt == 0 && req_queue_.size() == 0) {
int64_t queue_size = req_queue_.size() + multi_level_queue_.get_total_size();
if (queue_size == 0) {
token = 0;
} else {
token = 1 + blocking_cnt;
token = max(1 + blocking_cnt, min(workers_.get_size() + queue_size, min_worker_cnt()));
token = std::min(token, max_worker_cnt());
}
}
int64_t succ_num = 0L;
int64_t shrink_ts =
(!is_group_critical && workers_.get_size() == 1 && token == 0) ? SLEEP_INTERVAL : SHRINK_INTERVAL;
if (OB_UNLIKELY(workers_.get_size() < target_min)) {
const int64_t diff = target_min - workers_.get_size();
int64_t shrink_ts = (token == 0 && workers_.get_size() == 1) ? SLEEP_INTERVAL : SHRINK_INTERVAL;
int64_t diff = token < min_worker_cnt() ? token - workers_.get_size() : min_worker_cnt() - workers_.get_size();
if (OB_UNLIKELY(diff > 0)) {
token_change_ts_ = now;
ATOMIC_STORE(&shrink_, false);
acquire_more_worker(diff, succ_num, /* force */ true);