kapitan/IXWebSocket
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

(ixbots) display sent/receive message, per seconds as accumulated

Browse Source
This commit is contained in:
Benjamin Sergeant
2020-04-17 09:56:09 -07:00
parent 0b6fd989f5
commit 9d79596629
4 changed files with 18 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
ixbots/ixbots/IXCobraBot.cpp
View File

@ -34,16 +34,25 @@ namespace ix
Json::FastWriter jsonWriter;
std::atomic<uint64_t> sentCount(0);
std::atomic<uint64_t> receivedCount(0);
std::atomic<uint64_t> sentCountTotal(0);
std::atomic<uint64_t> receivedCountTotal(0);
std::atomic<bool> stop(false);
std::atomic<bool> throttled(false);
std::atomic<bool> fatalCobraError(false);
QueueManager queueManager(maxQueueSize);
auto timer = [&sentCount, &receivedCount, &stop] {
auto timer = [&sentCount, &receivedCount, &sentCountTotal, &receivedCountTotal, &stop] {
while (!stop)
{
spdlog::info("messages received {} sent {}", receivedCount, sentCount);
spdlog::info("messages received {} {} sent {} {}",
receivedCount, receivedCountTotal, sentCount, sentCountTotal);
receivedCountTotal += receivedCount;
sentCountTotal += sentCount;
receivedCount = 0;
sentCount = 0;
auto duration = std::chrono::seconds(1);
std::this_thread::sleep_for(duration);