Drop-front queue. More...

#include <DropTailQueue.h>

Inheritance diagram for inet::DropTailQueue:

Protected Member Functions
virtual void	initialize () override

virtual cMessage *	enqueue (cMessage *msg) override
	Redefined from PassiveQueueBase. More...

virtual cMessage *	dequeue () override
	Redefined from PassiveQueueBase. More...

virtual void	sendOut (cMessage *msg) override
	Redefined from PassiveQueueBase. More...

virtual bool	isEmpty () override
	Redefined from IPassiveQueue. More...

Protected Member Functions inherited from inet::PassiveQueueBase
virtual void	handleMessage (cMessage *msg) override

virtual void	finish () override

virtual void	refreshDisplay () const override

virtual void	notifyListeners ()

Protected Attributes
int	frameCapacity

cQueue	queue

cGate *	outGate

Protected Attributes inherited from inet::PassiveQueueBase
std::list< IPassiveQueueListener * >	listeners

int	packetRequested

int	numQueueReceived

int	numQueueDropped

Static Protected Attributes
static simsignal_t	queueLengthSignal = registerSignal("queueLength")

Additional Inherited Members
Public Member Functions inherited from inet::PassiveQueueBase
virtual void	requestPacket () override
	The queue should send a packet whenever this method is invoked. More...

virtual int	getNumPendingRequests () override
	Returns number of pending requests. More...

virtual void	clear () override
	Clear all queued packets and stored requests. More...

virtual cMessage *	pop () override
	Return a packet from the queue directly. More...

virtual void	addListener (IPassiveQueueListener *listener) override
	Implementation of IPassiveQueue::addListener(). More...

virtual void	removeListener (IPassiveQueueListener *listener) override
	Implementation of IPassiveQueue::removeListener(). More...

Public Member Functions inherited from inet::IPassiveQueue
virtual	~IPassiveQueue ()

Static Public Attributes inherited from inet::PassiveQueueBase
static simsignal_t	rcvdPkSignal = registerSignal("rcvdPk")
	Signal with packet when received it. More...

static simsignal_t	enqueuePkSignal = registerSignal("enqueuePk")
	Signal with packet when enqueued it. More...

static simsignal_t	dequeuePkSignal = registerSignal("dequeuePk")
	Signal with packet when sent out it. More...

static simsignal_t	dropPkByQueueSignal = registerSignal("dropPkByQueue")
	Signal with packet when dropped it. More...

static simsignal_t	queueingTimeSignal = registerSignal("queueingTime")
	Signal with value of delaying time when sent out a packet. More...

Detailed Description

Drop-front queue.

See NED for more info.

Member Function Documentation

cMessage * inet::DropTailQueue::dequeue ( )

overrideprotectedvirtual

Redefined from PassiveQueueBase.

Implements inet::PassiveQueueBase.

 {
     if (queue.isEmpty())
         return nullptr;
 
     cMessage *msg = (cMessage *)queue.pop();
 
     // statistics
     emit(queueLengthSignal, queue.getLength());
 
     return msg;
 }

cMessage * inet::DropTailQueue::enqueue ( cMessage * msg )

overrideprotectedvirtual

Redefined from PassiveQueueBase.

Implements inet::PassiveQueueBase.

 {
     if (frameCapacity && queue.getLength() >= frameCapacity) {
         EV << "Queue full, dropping packet.\n";
         return msg;
     }
     else {
         queue.insert(msg);
         emit(queueLengthSignal, queue.getLength());
         return nullptr;
     }
 }

void inet::DropTailQueue::initialize ( )

overrideprotectedvirtual

Reimplemented from inet::PassiveQueueBase.

 {
     PassiveQueueBase::initialize();
 
     queue.setName(par("queueName"));
 
     //statistics
     emit(queueLengthSignal, queue.getLength());
 
     outGate = gate("out");
 
     // configuration
     frameCapacity = par("frameCapacity");
 }