ikr.simlib.algorithms.queuingDisciplines

Class BoundedFIFOQDisc

java.lang.Object

ikr.simlib.algorithms.queuingDisciplines.StackableQueuingDiscipline

ikr.simlib.algorithms.queuingDisciplines.FIFOQDisc

ikr.simlib.algorithms.queuingDisciplines.BoundedFIFOQDisc

All Implemented Interfaces:

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

Direct Known Subclasses:

NoDropBoundedFIFOQDisc

public class BoundedFIFOQDisc
extends FIFOQDisc
implements BoundedQDisc

This class implements a bounded FIFO (First In First Out) queuing discipline, i.e., it has a finite buffer size. If a new message arrives and there is not enough buffer space left in the queue to store the message, the arriving message is lost, i.e., it is deleted by the HandleLossMessage()-method. You can overwrite this method if you want something else to be done with the message.

Nested Class Summary

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

QueuingDiscipline.QueueEntry

Field Summary

Fields

Modifier and Type	Field and Description
protected int	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
BoundedFIFOQDisc(SimNode ownNode, int size)
BoundedFIFOQDisc(SimNode ownNode, Parameters pars)

Method Summary

Methods

Modifier and Type	Method and Description
static BoundedFIFOQDisc	createInstance(SimNode ownNode, Parameters pars) as required by ReflectionConstructable
static BoundedFIFOQDisc	createInstance(SimNode ownNode, Parameters pars, java.lang.Integer size)
int	getMaxSizeInUnits()
boolean	hasSpaceFor(Message msg) return true if message fits into maxSizeInUnits, else false

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, statsUpdateLoss, statsUpdateReject, wouldStore

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, wouldStore

Field Detail

maxSizeInUnits

protected int maxSizeInUnits

Constructor Detail

BoundedFIFOQDisc

public BoundedFIFOQDisc(SimNode ownNode,
                int size)

BoundedFIFOQDisc

public BoundedFIFOQDisc(SimNode ownNode,
                Parameters pars)

Method Detail

createInstance

public static BoundedFIFOQDisc createInstance(SimNode ownNode,
                              Parameters pars)

as required by ReflectionConstructable

createInstance

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

getMaxSizeInUnits

public int getMaxSizeInUnits()

Specified by:

getMaxSizeInUnits in interface QueuingDiscipline

Overrides:

getMaxSizeInUnits in class FIFOQDisc

Returns:

maximum size of queue or Integer.MAX_VALUE if queue is unbounded.

hasSpaceFor

public boolean hasSpaceFor(Message msg)

return true if message fits into maxSizeInUnits, else false

Overrides:

hasSpaceFor in class StackableQueuingDiscipline

Returns:

true if the QueuingDiscipline has space for that message.