rename GlobalHttpQueryRuntime to GolbalQueryRuntime

Author: dantengsky

src/common/base/src/runtime/global_runtime.rs

@@ -21,9 +21,9 @@ use crate::runtime::Runtime;
 
 pub struct GlobalIORuntime;
 
-pub struct GlobalHttpQueryRuntime(pub Runtime);
+pub struct GlobalQueryRuntime(pub Runtime);
 
-impl GlobalHttpQueryRuntime {
+impl GlobalQueryRuntime {
     #[inline(always)]
     pub fn runtime<'a>(self: &'a Arc<Self>) -> &'a Runtime {
         &self.0
@@ -47,18 +47,17 @@ impl GlobalIORuntime {
     }
 }
 
-impl GlobalHttpQueryRuntime {
+impl GlobalQueryRuntime {
     pub fn init(num_cpus: usize) -> Result<()> {
         let thread_num = std::cmp::max(num_cpus, num_cpus::get() / 2);
         let thread_num = std::cmp::max(2, thread_num);
 
-        let rt =
-            Runtime::with_worker_threads(thread_num, Some("http-query-ctx-worker".to_owned()))?;
-        GlobalInstance::set(Arc::new(GlobalHttpQueryRuntime(rt)));
+        let rt = Runtime::with_worker_threads(thread_num, Some("g-query-worker".to_owned()))?;
+        GlobalInstance::set(Arc::new(GlobalQueryRuntime(rt)));
         Ok(())
     }
 
-    pub fn instance() -> Arc<GlobalHttpQueryRuntime> {
+    pub fn instance() -> Arc<GlobalQueryRuntime> {
         GlobalInstance::get()
     }
 }

src/common/base/src/runtime/mod.rs

@@ -22,8 +22,8 @@ mod thread_pool;
 
 pub use catch_unwind::catch_unwind;
 pub use catch_unwind::CatchUnwindFuture;
-pub use global_runtime::GlobalHttpQueryRuntime;
 pub use global_runtime::GlobalIORuntime;
+pub use global_runtime::GlobalQueryRuntime;
 pub use runtime::execute_futures_in_parallel;
 pub use runtime::match_join_handle;
 pub use runtime::Dropper;

src/query/service/src/api/rpc/exchange/statistics_sender.rs

@@ -18,7 +18,7 @@ use std::sync::Arc;
 
 use async_channel::Receiver;
 use async_channel::Sender;
-use common_base::runtime::GlobalHttpQueryRuntime;
+use common_base::runtime::GlobalQueryRuntime;
 use common_base::runtime::TrySpawn;
 use common_catalog::table_context::TableContext;
 use common_exception::ErrorCode;
@@ -64,7 +64,7 @@ impl StatisticsSender {
         let shutdown_flag = self.shutdown_flag.clone();
         let shutdown_flag_receiver = self.shutdown_flag_receiver.clone();
 
-        let spawner = GlobalHttpQueryRuntime::instance();
+        let spawner = GlobalQueryRuntime::instance();
         spawner.runtime().spawn(async move {
             let mut recv = Box::pin(flight_exchange.recv());
             let mut notified = Box::pin(shutdown_flag_receiver.recv());

src/query/service/src/global_services.rs

@@ -13,8 +13,8 @@
 // limitations under the License.
 
 use common_base::base::GlobalInstance;
-use common_base::runtime::GlobalHttpQueryRuntime;
 use common_base::runtime::GlobalIORuntime;
+use common_base::runtime::GlobalQueryRuntime;
 use common_catalog::catalog::CatalogManager;
 use common_config::GlobalConfig;
 use common_config::InnerConfig;
@@ -48,7 +48,7 @@ impl GlobalServices {
 
         QueryLogger::init(app_name_shuffle, &config.log)?;
         GlobalIORuntime::init(config.storage.num_cpus as usize)?;
-        GlobalHttpQueryRuntime::init(config.storage.num_cpus as usize)?;
+        GlobalQueryRuntime::init(config.storage.num_cpus as usize)?;
 
         // Cluster discovery.
         ClusterDiscovery::init(config.clone()).await?;

src/query/service/src/servers/http/v1/query/http_query.rs

@@ -20,7 +20,7 @@ use std::time::Instant;
 use common_base::base::tokio;
 use common_base::base::tokio::sync::Mutex as TokioMutex;
 use common_base::base::tokio::sync::RwLock;
-use common_base::runtime::GlobalHttpQueryRuntime;
+use common_base::runtime::GlobalQueryRuntime;
 use common_base::runtime::TrySpawn;
 use common_catalog::table_context::StageAttachment;
 use common_exception::ErrorCode;
@@ -279,7 +279,7 @@ impl HttpQuery {
         let query_id_clone = id.clone();
 
         let schema = ExecuteState::get_schema(&sql, ctx.clone()).await?;
-        let http_query_runtime_instance = GlobalHttpQueryRuntime::instance();
+        let http_query_runtime_instance = GlobalQueryRuntime::instance();
         http_query_runtime_instance
             .runtime()
             .try_spawn(async move {