src/pubsub.h
@@ -19,14 +19,15 @@ #define PUBSUB_4KGRA997 #include "shm_queue.h" #include <thread> #include <atomic> #include <mutex> #include <vector> #include <unordered_map> #include <set> #include <thread> #include <unordered_map> #include <vector> namespace bhome_shm { namespace bhome_shm { // publish/subcribe manager. class BusManager @@ -41,13 +42,13 @@ bool StopNoLock(); void OnMsg(MsgI &msg); public: BusManager(SharedMemory &shm); ~BusManager(); bool Start(const int nworker = 2); bool Stop(); }; } // namespace bhome_shm
