From afedd4bb1f03888fc6e4c3795f2711d0a5286708 Mon Sep 17 00:00:00 2001 From: Kyle Schwarz Date: Wed, 29 Jul 2026 17:44:58 -0400 Subject: [PATCH] Servd: Add pushRx error --- platform/servd.cpp | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/platform/servd.cpp b/platform/servd.cpp index 00587fe..84a93d2 100644 --- a/platform/servd.cpp +++ b/platform/servd.cpp @@ -243,6 +243,7 @@ bool Servd::enableCommunication(bool enable, bool& sendMsg) { } void Servd::read() { + EventManager::GetInstance().downgradeErrorsOnCurrentThread(); std::vector buf(2 * 1024 * 1024); while(!isDisconnected() && !isClosing()) { bool hasData; @@ -260,11 +261,14 @@ void Servd::read() { setIsDisconnected(true); return; } - pushRx(buf.data(), bufSize); + if(!pushRx(buf.data(), bufSize)) { + EventManager::GetInstance().add(APIEvent::Type::FailedToRead, APIEvent::Severity::Error); + } } } void Servd::write() { + EventManager::GetInstance().downgradeErrorsOnCurrentThread(); WriteOperation writeOp; while(!isDisconnected() && !isClosing()) { if(!writeQueue.wait_dequeue_timed(writeOp, std::chrono::milliseconds(100))) {