//#include "QueueingSocketSink.ih"
// Custom includes
+#include <senf/Utils/Console/Variables.hh>
#define prefix_
-///////////////////////////////cc.p////////////////////////////////////////
+//-/////////////////////////////////////////////////////////////////////////////////////////////////
SENF_PPI_REGISTER_QALGORITHM( "FIFOQueueingAlgorithm", senf::ppi::FIFOQueueingAlgorithm);
-///////////////////////////////////////////////////////////////////////////
+//-/////////////////////////////////////////////////////////////////////////////////////////////////
// senf::ppi::QueueingAlgorithm
prefix_ senf::ppi::QueueingAlgorithm::QueueingAlgorithm()
return dir_;
}
-/////////////////////////////////////////////////////////////////////////////
+//-/////////////////////////////////////////////////////////////////////////////////////////////////
// senf::ppi::QueueingAlgorithmRegistry
prefix_ void senf::ppi::QueueingAlgorithmRegistry::dump(std::ostream & os)
throw Exception("QueueingAlgorithm not registered: ") << key;
}
-///////////////////////////////////////////////////////////////////////////
+//-/////////////////////////////////////////////////////////////////////////////////////////////////
// senf::ppi::FIFOQueueingAlgorithm
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;
}
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;
return new FIFOQueueingAlgorithm();
}
-///////////////////////////////cc.e////////////////////////////////////////
+//-/////////////////////////////////////////////////////////////////////////////////////////////////
#undef prefix_