add queue length status.

lichao

2021-03-31 4353f73ea0c30c776a3957dc674d750e51519ca3

 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