add thread handling and use one-thread-per-connection as default

oceanbase · hnwyllmm · Jan 22, 2024 · Jan 10, 2024 · Jan 11, 2024 · Jan 11, 2024
commit f2fd305a47546c1b1e0848678e2d45894964a410
diff --git a/CMakeLists.txt b/CMakeLists.txt
@@ -14,6 +14,7 @@ OPTION(ENABLE_ASAN "Enable build with address sanitizer" ON)
 OPTION(ENABLE_TSAN "Build with thread sanitizer" OFF)
 OPTION(ENABLE_UBSAN "Build with undefined behavior sanitizer" OFF)
 OPTION(WITH_UNIT_TESTS "Compile miniob with unit tests" ON)
+OPTION(ENABLE_COVERAGE "Enable unittest coverage" OFF)
 OPTION(CONCURRENCY "Support concurrency operations" OFF)
 OPTION(STATIC_STDLIB "Link std library static or dynamic, such as libgcc, libstdc++, libasan" OFF)
 
@@ -127,7 +128,9 @@ ENDIF ()
 INCLUDE_DIRECTORIES(. ${PROJECT_SOURCE_DIR}/deps /usr/local/include)
 
 IF(WITH_UNIT_TESTS)
-    SET(CMAKE_COMMON_FLAGS "${CMAKE_COMMON_FLAGS} -fprofile-arcs -ftest-coverage")
+    IF (ENABLE_COVERAGE)
+        SET(CMAKE_COMMON_FLAGS "${CMAKE_COMMON_FLAGS} -fprofile-arcs -ftest-coverage")
+    ENDIF (ENABLE_COVERAGE)
     enable_testing()
 ENDIF(WITH_UNIT_TESTS)
 

diff --git a/deps/common/os/process_param.h b/deps/common/os/process_param.h
@@ -72,6 +72,15 @@ class ProcessParam
   }
   const std::string &trx_kit_name() const { return trx_kit_name_; }
 
+  void set_thread_handling_name(const char *thread_handling_name)
+  {
+    if (thread_handling_name) {
+      thread_handling_name_ = thread_handling_name;
+    }
+  }
+
+  const std::string &thread_handling_name() const { return thread_handling_name_; }
+
   void set_buffer_pool_memory_size(int bytes) { buffer_pool_memory_size_ = bytes; }
 
   int buffer_pool_memory_size() const { return buffer_pool_memory_size_; }
@@ -87,6 +96,7 @@ class ProcessParam
   std::string              unix_socket_path_;
   std::string              protocol_;
   std::string              trx_kit_name_;
+  std::string              thread_handling_name_;
   int                      buffer_pool_memory_size_ = -1;
 };
 

diff --git a/deps/common/seda/callback.cpp b/deps/common/seda/callback.cpp
diff --git a/deps/common/seda/callback.h b/deps/common/seda/callback.h
diff --git a/deps/common/seda/class_factory.h b/deps/common/seda/class_factory.h
diff --git a/deps/common/seda/event_dispatcher.cpp b/deps/common/seda/event_dispatcher.cpp
diff --git a/deps/common/seda/event_dispatcher.h b/deps/common/seda/event_dispatcher.h
diff --git a/deps/common/seda/example_stage.cpp b/deps/common/seda/example_stage.cpp
diff --git a/deps/common/seda/example_stage.h b/deps/common/seda/example_stage.h
diff --git a/deps/common/seda/init.cpp b/deps/common/seda/init.cpp
diff --git a/deps/common/seda/init.h b/deps/common/seda/init.h
diff --git a/deps/common/seda/kill_thread.cpp b/deps/common/seda/kill_thread.cpp
diff --git a/deps/common/seda/kill_thread.h b/deps/common/seda/kill_thread.h
diff --git a/deps/common/seda/metrics_report_event.cpp b/deps/common/seda/metrics_report_event.cpp
diff --git a/deps/common/seda/metrics_report_event.h b/deps/common/seda/metrics_report_event.h
diff --git a/deps/common/seda/metrics_stage.cpp b/deps/common/seda/metrics_stage.cpp
diff --git a/deps/common/seda/metrics_stage.h b/deps/common/seda/metrics_stage.h
diff --git a/deps/common/seda/seda_config.cpp b/deps/common/seda/seda_config.cpp
diff --git a/deps/common/seda/seda_config.h b/deps/common/seda/seda_config.h
diff --git a/deps/common/seda/seda_defs.h b/deps/common/seda/seda_defs.h
diff --git a/deps/common/seda/stage.cpp b/deps/common/seda/stage.cpp
diff --git a/deps/common/seda/stage.h b/deps/common/seda/stage.h
diff --git a/deps/common/seda/stage_event.cpp b/deps/common/seda/stage_event.cpp
diff --git a/deps/common/seda/stage_event.h b/deps/common/seda/stage_event.h
diff --git a/deps/common/seda/thread_pool.cpp b/deps/common/seda/thread_pool.cpp
diff --git a/deps/common/seda/thread_pool.h b/deps/common/seda/thread_pool.h