fix ProcessPool

Author: usermicrodevices

CMakeLists.txt

@@ -58,6 +58,12 @@ find_package(ZLIB REQUIRED)
 # Find OpenSSL for encryption
 find_package(OpenSSL REQUIRED)
 
+# Find UUID library
+find_library(UUID_LIBRARY NAMES uuid)
+if(NOT UUID_LIBRARY)
+    message(FATAL_ERROR "libuuid not found - install libuuid-dev or equivalent")
+endif()
+
 # Add GLM include directory
 include_directories(${glm_INCLUDE_DIRS})
 
@@ -101,6 +107,7 @@ set(LOGIC_CORE_SOURCES
     src/game/GameLogic.cpp
     src/game/EntityManager.cpp
     src/game/Player.cpp
+    src/game/PlayerManager.cpp
     src/game/NPCEntity.cpp
 )
 
@@ -173,6 +180,7 @@ target_link_libraries(gameserver PRIVATE
     Python3::Python
     fmt::fmt
     spdlog::spdlog
+    ${UUID_LIBRARY}
 )
 
 # Compiler flags

include/process/ProcessPool.hpp

@@ -22,6 +22,8 @@
 #include <sys/prctl.h>
 #include <sys/socket.h>
 
+#include "logging/Logger.hpp"
+
 class ProcessPool {
 public:
     enum class ProcessRole {
@@ -45,7 +47,7 @@ class ProcessPool {
     pid_t GetMasterPid() const { return masterPid_; }
 
     // Callback for worker process
-    void SetWorkerMain(std::function<void(int workerId)> workerMain);
+    void SetWorkerMain(std::function<void(int workerId)> workerMainFunc);
 
     // Inter-process communication with message length prefix
     bool SendToWorker(int workerId, const std::string& message);
@@ -84,7 +86,7 @@ class ProcessPool {
     std::atomic<bool> shutdownRequested_{false};
 
     std::vector<pid_t> workerPids_;
-    std::function<void(int workerId)> workerMain_;
+    std::function<void(int workerId)> workerMainFunc_;
 
     // IPC mechanisms
     std::vector<int> workerPipes_;  // [read_fd, write_fd] for each worker

src/process/ProcessPool.cpp

@@ -1,5 +1,4 @@
 #include "process/ProcessPool.hpp"
-#include "logging/Logger.hpp"
 
 ProcessPool::ProcessPool(int numProcesses)
     : numProcesses_(numProcesses > 0 ? numProcesses : 1) {
@@ -90,8 +89,8 @@ void ProcessPool::MasterProcess() {
 
             Logger::Info("Worker process {} started (PID: {})", i, getpid());
 
-            if (workerMain_) {
-                workerMain_(i);
+            if (workerMainFunc_) {
+                workerMainFunc_(i);
             }
 
             // Cleanup before exit
@@ -167,8 +166,8 @@ void ProcessPool::WorkerProcess(int workerId) {
     });
     signal(SIGINT, SIG_IGN);
 
-    if (workerMain_) {
-        workerMain_(workerId);
+    if (workerMainFunc_) {
+        workerMainFunc_(workerId);
     }
 }
 
@@ -219,8 +218,8 @@ void ProcessPool::RestartWorker(int workerId) {
 
         Logger::Info("Restarted worker {} (PID: {})", workerId, getpid());
 
-        if (workerMain_) {
-            workerMain_(workerId);
+        if (workerMainFunc_) {
+            workerMainFunc_(workerId);
         }
 
         close(workerPipes_[workerId * 2]);
@@ -512,3 +511,7 @@ void ProcessPool::SetupSignalHandlers() {
     signal(SIGCHLD, SIG_IGN);  // We'll handle child processes with waitpid
     signal(SIGPIPE, SIG_IGN);  // Ignore broken pipes
 }
+
+void ProcessPool::SetWorkerMain(std::function<void(int)> workerMainFunc) {
+    workerMainFunc_ = std::move(workerMainFunc);
+}