From 25e4a2425bb3e7ae296cf611aadc629676b36eae Mon Sep 17 00:00:00 2001
From: hnwyllmm <hnwyllmm@126.com>
Date: Thu, 14 Apr 2022 11:20:23 +0800
Subject: [PATCH] udpate omti.worker_pool while updating cpu_count config.

---
 src/observer/ob_server_reload_config.cpp | 1 +
 src/observer/omt/ob_multi_tenant.cpp     | 5 +++++
 src/observer/omt/ob_multi_tenant.h       | 1 +
 3 files changed, 7 insertions(+)

diff --git a/src/observer/ob_server_reload_config.cpp b/src/observer/ob_server_reload_config.cpp
index e7f3b84acb..14ff71a2ee 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(common::get_cpu_count());
     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 48619f5029..3cd0ff28a1 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 a0620387b8..6428415226 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();