braft Performance optimization

Author: wuxianrong

src/praft/CMakeLists.txt

@@ -21,6 +21,11 @@ add_dependencies(binlog_pb protobuf)
 # Collect all source files (excluding binlog.proto which is in binlog_pb)
 aux_source_directory(./src DIR_SRCS)
 
+# Add batch_manager source files explicitly
+set(DIR_SRCS ${DIR_SRCS} 
+    ${CMAKE_CURRENT_SOURCE_DIR}/batch_manager.cc
+)
+
 # Create static library (WITHOUT binlog protobuf sources, link binlog_pb instead)
 add_library(praft STATIC ${DIR_SRCS})
 

src/praft/include/praft/praft.h

@@ -21,6 +21,7 @@
 #include "pstd/include/pstd_mutex.h"
 #include "pstd/include/pstd_status.h"
 #include "rocksdb/status.h"
+#include "batch_manager.h"
 
 class PikaServer;
 
@@ -237,6 +238,9 @@ class RaftManager {
   mutable std::shared_mutex nodes_mutex_;
   std::unordered_map<std::string, std::shared_ptr<PikaRaftNode>> raft_nodes_;
 
+  // Batch managers for each database (for request batching optimization)
+  std::unordered_map<std::string, std::unique_ptr<BatchManager>> batch_managers_;
+  
   // Storage reference for applying binlog
   storage::Storage* storage_ = nullptr;