sven/libicsneo
1
0
Fork 0
mirror of https://github.com/intrepidcs/libicsneo.git synced 2026-08-05 01:18:36 +02:00
Code Issues Projects Releases Wiki Activity

Servd: Add pushRx error

Browse Source
This commit is contained in:
Kyle Schwarz
2026-07-29 17:44:58 -04:00
parent 9b01e488da
commit afedd4bb1f
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
platform/servd.cpp
+5 -1
View File
@@ -243,6 +243,7 @@ bool Servd::enableCommunication(bool enable, bool& sendMsg) {
} }
void Servd::read() { void Servd::read() {
EventManager::GetInstance().downgradeErrorsOnCurrentThread();
std::vector<uint8_t> buf(2 * 1024 * 1024); std::vector<uint8_t> buf(2 * 1024 * 1024);
while(!isDisconnected() && !isClosing()) { while(!isDisconnected() && !isClosing()) {
bool hasData; bool hasData;
@@ -260,11 +261,14 @@ void Servd::read() {
setIsDisconnected(true); setIsDisconnected(true);
return; return;
} }
pushRx(buf.data(), bufSize); if(!pushRx(buf.data(), bufSize)) {
EventManager::GetInstance().add(APIEvent::Type::FailedToRead, APIEvent::Severity::Error);
}
} }
} }
void Servd::write() { void Servd::write() {
EventManager::GetInstance().downgradeErrorsOnCurrentThread();
WriteOperation writeOp; WriteOperation writeOp;
while(!isDisconnected() && !isClosing()) { while(!isDisconnected() && !isClosing()) {
if(!writeQueue.wait_dequeue_timed(writeOp, std::chrono::milliseconds(100))) { if(!writeQueue.wait_dequeue_timed(writeOp, std::chrono::milliseconds(100))) {