fix QueueingSocketSink to update the IOEvent when the handle is modified. tihgtened...

[senf.git] / senf / PPI / QueueingSocketSink.cc

diff --git a/senf/PPI/QueueingSocketSink.cc b/senf/PPI/QueueingSocketSink.cc
index 4267bb8..c21eeb8 100644 (file)
--- a/senf/PPI/QueueingSocketSink.cc
+++ b/senf/PPI/QueueingSocketSink.cc
@@ -92,7 +92,7 @@ prefix_ senf::Packet senf::ppi::FIFOQueueingAlgorithm::v_dequeue()
 
 prefix_ bool senf::ppi::FIFOQueueingAlgorithm::v_enqueue(Packet const & packet)
 {
-    if (queue_.size() == max_size_)
+    if (queue_.size() >= max_size_)
         queue_.pop();
     queue_.push( packet);
     return true;