thooge
/
esp32-nmea2000-obp60
mirror of https://github.com/thooge/esp32-nmea2000-obp60.git
1
0
Fork 0
Code Releases Activity

add flush for gwserial

This commit is contained in:
andreas 2021-11-01 11:19:31 +01:00
parent 470dec92ad
commit a57d91c63d
2 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
lib/serial/GwSerial.cpp
View File

@ -67,7 +67,7 @@ size_t GwSerial::enqueue(const uint8_t *data, size_t len)
} }
GwBuffer::WriteStatus GwSerial::write(){ GwBuffer::WriteStatus GwSerial::write(){
if (! isInitialized()) return GwBuffer::ERROR; if (! isInitialized()) return GwBuffer::ERROR;
return buffer->fetchData(writer,false); return buffer->fetchData(writer,-1,false);
} }
void GwSerial::sendToClients(const char *buf,int sourceId){ void GwSerial::sendToClients(const char *buf,int sourceId){
if ( sourceId == id) return; if ( sourceId == id) return;
@ -93,3 +93,10 @@ bool GwSerial::readMessages(GwBufferWriter *writer){
if (! allowRead) return false; if (! allowRead) return false;
return readBuffer->fetchMessage(writer,'\n',true) == GwBuffer::OK; return readBuffer->fetchMessage(writer,'\n',true) == GwBuffer::OK;
} }
void GwSerial::flush(){
if (! isInitialized()) return;
while (buffer->fetchData(writer,-1,false) == GwBuffer::AGAIN){
vTaskDelay(1);
}
}

1
lib/serial/GwSerial.h
View File

@ -26,5 +26,6 @@ class GwSerial{
void sendToClients(const char *buf,int sourceId); void sendToClients(const char *buf,int sourceId);
void loop(bool handleRead=true); void loop(bool handleRead=true);
bool readMessages(GwBufferWriter *writer); bool readMessages(GwBufferWriter *writer);
void flush();
}; };
#endif #endif