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))) {