diff --git a/src/observer/ob_server_reload_config.cpp b/src/observer/ob_server_reload_config.cpp index 3f470e8da24185a49c6d3631aeb15b37a0f9a1ca..8f08bfc3aee711cb1f318718ab5463706b7224bc 100644 --- a/src/observer/ob_server_reload_config.cpp +++ b/src/observer/ob_server_reload_config.cpp @@ -327,6 +327,7 @@ int ObServerReloadConfig::operator()() share::ObTaskController::get().set_log_rate_limit(GCONF.syslog_io_bandwidth_limit.get_value()); if (nullptr != GCTX.omt_) { + GCTX.omt_->set_node_quota(GCONF.cpu_count.get_value()); GCTX.omt_->set_workers_per_cpu(GCONF.workers_per_cpu_quota.get_value()); } diff --git a/src/observer/omt/ob_multi_tenant.cpp b/src/observer/omt/ob_multi_tenant.cpp index 48619f5029de91599dd2e2c6a69895e849481ae0..3cd0ff28a1056bad3b23fb8591310c557f237f15 100644 --- a/src/observer/omt/ob_multi_tenant.cpp +++ b/src/observer/omt/ob_multi_tenant.cpp @@ -744,6 +744,11 @@ void ObMultiTenant::set_workers_per_cpu(int64_t v) LOG_INFO("set max workers", K(max_workers_cnt)); } +void ObMultiTenant::set_node_quota(double node_quota) +{ + node_quota_ = node_quota; +} + void ObMultiTenant::run1() { lib::set_thread_name("MultiTenant"); diff --git a/src/observer/omt/ob_multi_tenant.h b/src/observer/omt/ob_multi_tenant.h index a0620387b8db9af1295e6f2338aa532ba440c9c8..64284152262d29df274b146d34533e4478391974 100644 --- a/src/observer/omt/ob_multi_tenant.h +++ b/src/observer/omt/ob_multi_tenant.h @@ -117,6 +117,7 @@ public: inline bool has_synced() const; void set_workers_per_cpu(int64_t v); + void set_node_quota(double node_quota); protected: void run1();