ikr.simlib.entities.queues

Class FIFODropTailQueue

java.lang.Object

ikr.simlib.entities.Entity

ikr.simlib.entities.queues.SingleServerQueue

ikr.simlib.entities.queues.StdSingleServerQueue

ikr.simlib.entities.queues.FIFODropTailQueue

All Implemented Interfaces:

MessageReceiver

public class FIFODropTailQueue
extends StdSingleServerQueue

FIFODropTailQueue is a subclass of StdSingleServerQueue and defines the ReceiveMessage method called on message arrival as well as HandleEndOfService. Incoming messages are immediately processed if the server is free or stored in a queue if the server is busy. When the server has completed service the message at the head of the queue enters service.

CanEnqueue returns true if the total message length including the message that has just arrived is <= the buffer size which can be specified in the input file.

If the DequeueForService flag is not set the message is always appended to the queue and remains there until service completion.

Nested Class Summary

Nested classes/interfaces inherited from class ikr.simlib.entities.Entity

Entity.PortAlias

Field Summary

Fields

Modifier and Type	Field and Description
protected DistributionStatistic	busyPeriodDistStat
protected SampleStatistic	busyPeriodMeanStat
protected double	busyPeriodStartTime
protected boolean	dequeueForService
protected Message	msgInService
protected ProbabilityStatistic	packetLossStat
protected java.util.Deque<Message>	queue
protected int	queueLength
protected IntegralStatistic	queueLengthStat
protected boolean	traceOccupancy
protected boolean	traceQueueLength

Fields inherited from class ikr.simlib.entities.queues.StdSingleServerQueue

bufferSize, occupancyStat, serviceTime, useStatistics

Fields inherited from class ikr.simlib.entities.queues.SingleServerQueue

eosEvent, inputPort, outputPort

Fields inherited from class ikr.simlib.entities.Entity

portAliases, ports, simNode

Constructor Summary

Constructors

Modifier	Constructor and Description
	FIFODropTailQueue(boolean dequeueForService, boolean traceQLength, boolean traceOccupancy, int bufferSize, double serviceRate, boolean useStatistics, java.lang.String name, SimNode parentNode)
protected	FIFODropTailQueue(java.lang.String name, SimNode parentNode)

Method Summary

Methods

Modifier and Type	Method and Description
protected boolean	CanEnqueue(Message msg)
void	handleEndOfService(double currentTime)
void	receiveMessage(Message msg)

Methods inherited from class ikr.simlib.entities.queues.StdSingleServerQueue

calcServiceTime

Methods inherited from class ikr.simlib.entities.Entity

addPort, aliasPort, aliasPort, connect, disconnect, getName, getNode, getPortByName, getPorts, isPortKnown, unaliasPort

Methods inherited from class java.lang.Object

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

Field Detail

dequeueForService

protected boolean dequeueForService

traceQueueLength

protected boolean traceQueueLength

traceOccupancy

protected boolean traceOccupancy

queue

protected final java.util.Deque<Message> queue

queueLength

protected int queueLength

msgInService

protected Message msgInService

busyPeriodStartTime

protected double busyPeriodStartTime

packetLossStat

protected ProbabilityStatistic packetLossStat

queueLengthStat

protected IntegralStatistic queueLengthStat

busyPeriodDistStat

protected DistributionStatistic busyPeriodDistStat

busyPeriodMeanStat

protected SampleStatistic busyPeriodMeanStat

Constructor Detail

FIFODropTailQueue

public FIFODropTailQueue(boolean dequeueForService,
                 boolean traceQLength,
                 boolean traceOccupancy,
                 int bufferSize,
                 double serviceRate,
                 boolean useStatistics,
                 java.lang.String name,
                 SimNode parentNode)

FIFODropTailQueue

protected FIFODropTailQueue(java.lang.String name,
                 SimNode parentNode)

Method Detail

CanEnqueue

protected boolean CanEnqueue(Message msg)

handleEndOfService

public void handleEndOfService(double currentTime)

Specified by:

handleEndOfService in class SingleServerQueue

receiveMessage

public void receiveMessage(Message msg)

Specified by:

receiveMessage in interface MessageReceiver

Specified by:

receiveMessage in class SingleServerQueue