inet::WRRScheduler Class Reference

This module implements a Weighted Round Robin Scheduler. More...

#include <WRRScheduler.h>

Inheritance diagram for inet::WRRScheduler:

Public Member Functions
	WRRScheduler ()
Public Member Functions inherited from inet::SchedulerBase
	SchedulerBase ()
virtual	~SchedulerBase ()
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 bool	isEmpty () override
	Return true when queue is empty, otherwise return false. More...
virtual void	clear () override
	Clear all queued packets and stored requests. More...
virtual cMessage *	pop () override
	Returns a packet directly from the queue, bypassing the primary, send-on-request mechanism. More...
virtual void	packetEnqueued (IPassiveQueue *inputQueue) override
	A packet arrived and it was added to the queue (the queue length increased by one). More...
virtual void	addListener (IPassiveQueueListener *listener) override
	Adds a new listener to the listener list. More...
virtual void	removeListener (IPassiveQueueListener *listener) override
	Removes a listener from the listener list. More...
Public Member Functions inherited from inet::IPassiveQueue
virtual	~IPassiveQueue ()
Public Member Functions inherited from inet::IPassiveQueueListener
virtual	~IPassiveQueueListener ()

Protected Member Functions
virtual	~WRRScheduler ()
virtual void	initialize () override
virtual bool	schedulePacket () override
Protected Member Functions inherited from inet::SchedulerBase
virtual void	finalize ()
virtual void	handleMessage (cMessage *msg) override
virtual void	sendOut (cMessage *msg)
virtual void	notifyListeners ()

Protected Attributes
int	numInputs
int *	weights
int *	buckets
Protected Attributes inherited from inet::SchedulerBase
int	packetsRequestedFromUs
int	packetsToBeRequestedFromInputs
std::vector< IPassiveQueue * >	inputQueues
cGate *	outGate
std::list< IPassiveQueueListener * >	listeners

Detailed Description

This module implements a Weighted Round Robin Scheduler.

Constructor & Destructor Documentation

inet::WRRScheduler::WRRScheduler ( )

inline

: numInputs(0), weights(nullptr), buckets(nullptr) {}

inet::WRRScheduler::~WRRScheduler ( )

protectedvirtual

{
    delete[] weights;
    delete[] buckets;
}

Member Function Documentation

void inet::WRRScheduler::initialize ( )

overrideprotectedvirtual

Reimplemented from inet::SchedulerBase.

{
    SchedulerBase::initialize();

    numInputs = gateSize("in");
    ASSERT(numInputs == (int)inputQueues.size());

    weights = new int[numInputs];
    buckets = new int[numInputs];

    cStringTokenizer tokenizer(par("weights"));
    int i;
    for (i = 0; i < numInputs && tokenizer.hasMoreTokens(); ++i)
        buckets[i] = weights[i] = (int)utils::atoul(tokenizer.nextToken());

    if (i < numInputs)
        throw cRuntimeError("Too few values given in the weights parameter.");
    if (tokenizer.hasMoreTokens())
        throw cRuntimeError("Too many values given in the weights parameter.");
}

bool inet::WRRScheduler::schedulePacket ( )

overrideprotectedvirtual

Implements inet::SchedulerBase.

{
    bool allQueueIsEmpty = true;
    for (int i = 0; i < numInputs; ++i) {
        if (!inputQueues[i]->isEmpty()) {
            allQueueIsEmpty = false;
            if (buckets[i] > 0) {
                buckets[i]--;
                inputQueues[i]->requestPacket();
                return true;
            }
        }
    }

    if (allQueueIsEmpty)
        return false;

    bool packetRequested = false;
    for (int i = 0; i < numInputs; ++i) {
        buckets[i] = weights[i];
        if (!packetRequested && buckets[i] > 0 && !inputQueues[i]->isEmpty()) {
            buckets[i]--;
            inputQueues[i]->requestPacket();
            packetRequested = true;
        }
    }

    return packetRequested;
}

Member Data Documentation

int* inet::WRRScheduler::buckets

protected

Referenced by initialize(), schedulePacket(), and ~WRRScheduler().

int inet::WRRScheduler::numInputs

protected

Referenced by initialize(), and schedulePacket().

int* inet::WRRScheduler::weights

protected

Referenced by initialize(), schedulePacket(), and ~WRRScheduler().

---

The documentation for this class was generated from the following files:

• WRRScheduler.h
• WRRScheduler.cc