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

[CP] modify default archive concurrency

Browse Source
This commit is contained in:
taoshuning 2023-09-20 15:05:08 +00:00 committed by ob-robot
parent 8b4f1665de
commit bbf364a30f
1 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/logservice/archiveservice/ob_archive_scheduler.cpp
View File

@ -94,10 +94,17 @@ int ObArchiveScheduler::modify_thread_count_()
omt::ObTenantConfigGuard tenant_config(TENANT_CONF(tenant_id_));
const int64_t log_archive_concurrency =
tenant_config.is_valid() ? tenant_config->log_archive_concurrency : 0L;
// if parameter log_archive_concurrency is default zero, set archive_concurrency = max_cpu / 4
// if parameter log_archive_concurrency is default zero, set archive_concurrency based on max_cpu,
// otherwise set archive_concurrency = log_archive_concurrency
if (0 == log_archive_concurrency) {
archive_concurrency = MTL_CPU_COUNT() / 4;
const int64_t max_cpu = MTL_CPU_COUNT();
if (max_cpu <= 8) {
archive_concurrency = max_cpu;
} else if (max_cpu <= 32) {
archive_concurrency = std::max(max_cpu / 2, 8L);
} else {
archive_concurrency = std::max(max_cpu / 4, 16L);
}
} else {
archive_concurrency = log_archive_concurrency;
}