ikr.simlib.algorithms.queuingDisciplines

Class MessageFairQueuing

java.lang.Object

ikr.simlib.algorithms.queuingDisciplines.StackableQueuingDiscipline

ikr.simlib.algorithms.queuingDisciplines.FairQueuing

ikr.simlib.algorithms.queuingDisciplines.MessageFairQueuing

All Implemented Interfaces:

QueuingDiscipline, ReflectionConstructable, ReflectionConstructable2<SimNode,Parameters>

public class MessageFairQueuing
extends FairQueuing

This class implements fair queuing by messages. This means

• it needs a MessageClassificator to aggregate incoming Message s
• it maintains one StackableQueuingDiscipline per class of Messages, as identified by the MessageClassificator
• the fairness is per-message: if one class consists of 60 Byte packets while the other if of 1500 Byte messages, both will get same packet rate but very different bitrates (1:25 in average)
• it does no stochastic aggregating of messages that belong to different aggregates according to the MessageClassificator. This can be achieved by using a MessageClassificator, that uses a limited number of classes as for the usual Stochastic Fair Queuing (perturbation would have to be implemented in the MessageClassificator, too).

Author:

dwagner

Nested Class Summary

Nested classes/interfaces inherited from class ikr.simlib.algorithms.queuingDisciplines.FairQueuing

FairQueuing.SortableQDiscContainer

Nested classes/interfaces inherited from interface ikr.simlib.algorithms.queuingDisciplines.QueuingDiscipline

QueuingDiscipline.QueueEntry

Field Summary

Fields

Modifier and Type	Field and Description
protected int	activeQIndex
protected java.util.LinkedList<FairQueuing.SortableQDiscContainer>	activeQs

Fields inherited from class ikr.simlib.algorithms.queuingDisciplines.FairQueuing

activeQ, longestQList, maxSizeInUnits, queues

Fields inherited from class ikr.simlib.algorithms.queuingDisciplines.StackableQueuingDiscipline

lossProbability, numberOfMessages, numberOfUnits, parent, simNode, transferTime, waitingTime

Fields inherited from interface ikr.simlib.parameters.reflection.ReflectionConstructable

CREATE_INSTANCE_METHOD_NAME

Constructor Summary

Constructors

Constructor and Description
MessageFairQueuing(SimNode ownNode, Parameters pars)

Method Summary

Methods

Modifier and Type	Method and Description
protected boolean	activeQListIsEmpty()
protected void	addToActiveQList(FairQueuing.SortableQDiscContainer sq)
protected void	advanceActiveQ()
static MessageFairQueuing	createInstance(SimNode ownNode, Parameters pars) as required by ReflectionConstructable
FairQueuing.SortableQDiscContainer	createSortableQDisc(StackableQueuingDiscipline q)
protected void	updateActiveQList(FairQueuing.SortableQDiscContainer sq, double oldPos)
boolean	wouldStore(Message msg)

Methods inherited from class ikr.simlib.algorithms.queuingDisciplines.FairQueuing

bufferStealing, getMaxSizeInUnits, isEmpty, peekInternal, pop, push, updateLongestQList

Methods inherited from class ikr.simlib.algorithms.queuingDisciplines.StackableQueuingDiscipline

dequeue, dropScheduledNext, enqueue, getCurrentNumberOfMessages, getCurrentNumberOfUnits, getName, getNode, getParent, handleLossMessage, handleLossMessageInternal, handleMessage, handleRejectedMessage, hasSpaceFor, peek, statsUpdateDequeue, statsUpdateEnqueue, statsUpdateLoss, statsUpdateReject

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

activeQs

protected java.util.LinkedList<FairQueuing.SortableQDiscContainer> activeQs

activeQIndex

protected int activeQIndex

Constructor Detail

MessageFairQueuing

public MessageFairQueuing(SimNode ownNode,
                  Parameters pars)

Method Detail

createInstance

public static MessageFairQueuing createInstance(SimNode ownNode,
                                Parameters pars)

as required by ReflectionConstructable

wouldStore

public boolean wouldStore(Message msg)

Specified by:

wouldStore in interface QueuingDiscipline

Specified by:

wouldStore in class FairQueuing

Returns:

true if the queue would store the given message. May return false due to a bounded buffer size or a probabilistic decision, for ProbabilisticQueuingDisciplines. For these, two subsequent calls with the same message may return different results!

createSortableQDisc

public FairQueuing.SortableQDiscContainer createSortableQDisc(StackableQueuingDiscipline q)

Specified by:

createSortableQDisc in class FairQueuing

activeQListIsEmpty

protected boolean activeQListIsEmpty()

Specified by:

activeQListIsEmpty in class FairQueuing

addToActiveQList

protected void addToActiveQList(FairQueuing.SortableQDiscContainer sq)

Specified by:

addToActiveQList in class FairQueuing

updateActiveQList

protected void updateActiveQList(FairQueuing.SortableQDiscContainer sq,
                     double oldPos)

Specified by:

updateActiveQList in class FairQueuing

advanceActiveQ

protected void advanceActiveQ()

Specified by:

advanceActiveQ in class FairQueuing