X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=senf%2FPPI%2FQueueingSocketSink.cc;h=d01ee8b90b3ae1cd884a362963bd146fd051a428;hb=73c33f663ff0f65e4656ea5a5f6f07a43a2e1722;hp=4267bb886c5a8b31bf59f983ab7e5baa0b2da954;hpb=fc1569e67cfda71bc8c406617a5e0b05f28f1b47;p=senf.git diff --git a/senf/PPI/QueueingSocketSink.cc b/senf/PPI/QueueingSocketSink.cc index 4267bb8..d01ee8b 100644 --- a/senf/PPI/QueueingSocketSink.cc +++ b/senf/PPI/QueueingSocketSink.cc @@ -83,7 +83,7 @@ prefix_ senf::ppi::FIFOQueueingAlgorithm::FIFOQueueingAlgorithm() prefix_ senf::Packet senf::ppi::FIFOQueueingAlgorithm::v_dequeue() { if (queue_.size() > 0) { - Packet const & p = queue_.front(); + Packet p (queue_.front()); queue_.pop(); return p; } @@ -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;