added a flush() member to ActiveBurstSocketSource

[senf.git] / senf / PPI / SocketSource.ct

diff --git a/senf/PPI/SocketSource.ct b/senf/PPI/SocketSource.ct
index 00f5564..946515b 100644 (file)
--- a/senf/PPI/SocketSource.ct
+++ b/senf/PPI/SocketSource.ct
@@ -143,6 +143,20 @@ prefix_ void senf::ppi::module::ActiveBurstSocketSource<Reader>::read()
     }
 }
 
+template <class Reader>
+prefix_ void senf::ppi::module::ActiveBurstSocketSource<Reader>::flush()
+{
+    try{
+        while( true){
+            typename Reader::PacketType p(reader_(handle_));
+            if (p.data().size() <= 0)
+                break;
+        }
+    }
+    catch(...){};
+}
+
+
 //-/////////////////////////////////////////////////////////////////////////////////////////////////
 #undef prefix_