Add sp_drain() function.

[libserialport.git] / serialport.c

diff --git a/serialport.c b/serialport.c
index 92156b476471cdf73f3a3efefe05bba69aff6795..6104f241a17cb34db7638ef00ac9cebaff4529ce 100644 (file)
--- a/serialport.c
+++ b/serialport.c
@@ -535,6 +535,23 @@ enum sp_return sp_flush(struct sp_port *port, enum sp_buffer buffers)
        return SP_OK;
 }
 
+enum sp_return sp_drain(struct sp_port *port)
+{
+       CHECK_PORT();
+
+#ifdef _WIN32
+       /* Returns non-zero upon success, 0 upon failure. */
+       if (FlushFileBuffers(port->hdl) == 0)
+               return SP_ERR_FAIL;
+#else
+       /* Returns 0 upon success, -1 upon failure. */
+       if (tcdrain(port->fd) < 0)
+               return SP_ERR_FAIL;
+#endif
+
+       return SP_OK;
+}
+
 enum sp_return sp_write(struct sp_port *port, const void *buf, size_t count)
 {
        CHECK_PORT();