diff --git a/src/fne/network/DiagNetwork.cpp b/src/fne/network/DiagNetwork.cpp index 68b65f62..8e27f0a3 100644 --- a/src/fne/network/DiagNetwork.cpp +++ b/src/fne/network/DiagNetwork.cpp @@ -305,21 +305,6 @@ void* DiagNetwork::threadedNetworkRx(void* arg) // validate peer (simple validation really) if (connection->connected() && connection->address() == ip) { - UInt8Array __rawPayload = std::make_unique(req->length - 11U); - uint8_t* rawPayload = __rawPayload.get(); - ::memset(rawPayload, 0x00U, req->length - 11U); - ::memcpy(rawPayload, req->buffer + 11U, req->length - 11U); - std::string payload(rawPayload, rawPayload + (req->length - 11U)); - - influxdb::QueryBuilder() - .meas("peer_status") - .tag("peerId", std::to_string(peerId)) - .field("identity", connection->identity()) - .field("status", payload) - .timestamp(std::chrono::duration_cast(std::chrono::system_clock::now().time_since_epoch()).count()) - .request(network->m_influxServer); - - // repeat traffic to the connected peers if (network->m_peers.size() > 0U) { uint32_t i = 0U; for (auto peer : network->m_peers) { diff --git a/src/host/Host.cpp b/src/host/Host.cpp index f70f9559..e3ffe48b 100644 --- a/src/host/Host.cpp +++ b/src/host/Host.cpp @@ -1973,7 +1973,7 @@ void* Host::threadSiteData(void* arg) ::pthread_setname_np(th->thread, threadName.c_str()); #endif // _GNU_SOURCE - Timer networkPeerStatusNotify(1000U, 5U); + Timer networkPeerStatusNotify(1000U, 2U); networkPeerStatusNotify.start(); StopWatch stopWatch; diff --git a/src/sysview/NodeStatusWnd.h b/src/sysview/NodeStatusWnd.h index 184df7fb..ba7028ae 100644 --- a/src/sysview/NodeStatusWnd.h +++ b/src/sysview/NodeStatusWnd.h @@ -400,7 +400,8 @@ public: void update() { const auto& rootWidget = getRootWidget(); - for (auto entry : getNetwork()->peerStatus) { + std::map peerStatus(getNetwork()->peerStatus.begin(), getNetwork()->peerStatus.end()); + for (auto entry : peerStatus) { auto it = std::find_if(m_nodes.begin(), m_nodes.end(), [&](NodeStatusWidget* wdgt) { if (wdgt->peerId == entry.first && wdgt->uniqueId == (int32_t)entry.first) return true; @@ -826,7 +827,7 @@ private: killed = wnd->m_killed; } - Thread::sleep(1000U); + Thread::sleep(250U); } else { break; }