src/pubsub.cpp
@@ -34,6 +34,15 @@ bool BusManager::Start(const int nworker) { auto onRecv = [&](MsgI &imsg) { #ifndef NDEBUG static std::atomic<time_t> last(0); time_t now = 0; time(&now); if (last.exchange(now) < now) { printf("bus queue size: %ld\n", socket_.Pending()); } #endif BHMsg msg; if (!imsg.Unpack(msg)) { return; @@ -130,7 +139,7 @@ } }; return socket_.StartRaw(onRecv, std::min(nworker, kMaxWorker)); return socket_.StartRaw(onRecv, std::min((nworker > 0 ? nworker : 2), kMaxWorker)); } } // namespace bhome_shm