From 4353f73ea0c30c776a3957dc674d750e51519ca3 Mon Sep 17 00:00:00 2001
From: lichao <lichao@aiotlink.com>
Date: 星期三, 31 三月 2021 15:02:19 +0800
Subject: [PATCH] add queue length status.
---
src/pubsub.cpp | 11 ++++++++++-
1 files changed, 10 insertions(+), 1 deletions(-)
diff --git a/src/pubsub.cpp b/src/pubsub.cpp
index 52285b1..eff54ab 100644
--- a/src/pubsub.cpp
+++ b/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
--
Gitblit v1.8.0