X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=senf%2FPPI%2FSocketSource.ct;fp=senf%2FPPI%2FSocketSource.ct;h=946515bf04731a74b7a5f41b5d2a61e81d48c85b;hb=0e6076544fbcaba94b6339f0074cb2adcd56d515;hp=00f556418288af24715eeb3e508eb6e20532ce68;hpb=aeb7c57c3b42e83cb0b429989f9c3ab0900a76a4;p=senf.git

diff --git a/senf/PPI/SocketSource.ct b/senf/PPI/SocketSource.ct
index 00f5564..946515b 100644
--- 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_