ikr.simlib.algorithms.queuingDisciplines

Class NoDropBoundedFIFOQDisc

java.lang.Object

ikr.simlib.algorithms.queuingDisciplines.StackableQueuingDiscipline

ikr.simlib.algorithms.queuingDisciplines.FIFOQDisc

ikr.simlib.algorithms.queuingDisciplines.BoundedFIFOQDisc

ikr.simlib.algorithms.queuingDisciplines.NoDropBoundedFIFOQDisc

All Implemented Interfaces:

BoundedQDisc, QueuingDiscipline, ReflectionConstructable, ReflectionConstructable2<SimNode,Parameters>, ReflectionConstructable3<SimNode,Parameters,java.lang.Integer>

public class NoDropBoundedFIFOQDisc
extends BoundedFIFOQDisc

This is QDisc intended to be used as "glue queue", i.e. to adapt from a pushing OutputPort to a pulling InputPort.

Author:

dwagner

Nested Class Summary

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

QueuingDiscipline.QueueEntry

Field Summary

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

maxSizeInUnits

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

queue

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
NoDropBoundedFIFOQDisc(SimNode ownNode, int size)
NoDropBoundedFIFOQDisc(SimNode ownNode, Parameters pars)
NoDropBoundedFIFOQDisc(SimNode ownNode, Parameters pars, int size)

Method Summary

Methods

Modifier and Type	Method and Description
static NoDropBoundedFIFOQDisc	createInstance(SimNode ownNode, Parameters pars) as required by ReflectionConstructable
static NoDropBoundedFIFOQDisc	createInstance(SimNode ownNode, Parameters pars, java.lang.Integer size)
int	getMaxNumberOfMessages()
protected void	statsUpdateLoss(QueuingDiscipline.QueueEntry qe) Whatever to be done on loss, e.g.
boolean	wouldStore(Message msg)

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

getMaxSizeInUnits, hasSpaceFor

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

isEmpty, peekInternal, pop, push

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

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

Methods inherited from class java.lang.Object

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

Methods inherited from interface ikr.simlib.algorithms.queuingDisciplines.QueuingDiscipline

dequeue, dropScheduledNext, getCurrentNumberOfMessages, getCurrentNumberOfUnits, getName, getNode, getParent, handleMessage, isEmpty

Constructor Detail

NoDropBoundedFIFOQDisc

public NoDropBoundedFIFOQDisc(SimNode ownNode,
                      int size)

NoDropBoundedFIFOQDisc

public NoDropBoundedFIFOQDisc(SimNode ownNode,
                      Parameters pars)

NoDropBoundedFIFOQDisc

public NoDropBoundedFIFOQDisc(SimNode ownNode,
                      Parameters pars,
                      int size)

Method Detail

createInstance

public static NoDropBoundedFIFOQDisc createInstance(SimNode ownNode,
                                    Parameters pars)

as required by ReflectionConstructable

createInstance

public static NoDropBoundedFIFOQDisc createInstance(SimNode ownNode,
                                    Parameters pars,
                                    java.lang.Integer size)

statsUpdateLoss

protected void statsUpdateLoss(QueuingDiscipline.QueueEntry qe)

Description copied from class: StackableQueuingDiscipline

Whatever to be done on loss, e.g. update the statistics.

Overrides:

statsUpdateLoss in class StackableQueuingDiscipline

wouldStore

public boolean wouldStore(Message msg)

Specified by:

wouldStore in interface QueuingDiscipline

Overrides:

wouldStore in class StackableQueuingDiscipline

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!

getMaxNumberOfMessages

public int getMaxNumberOfMessages()