ikr.simlib.entities.multiphase

Class MultiPhasePrioServer

java.lang.Object

ikr.simlib.entities.Entity

ikr.simlib.entities.multiphase.MultiPhasePrioServer

public class MultiPhasePrioServer
extends Entity

MultiPhasePrioServer provides a priority server component with an arbitrary number of phases. A phase can be created by the method CreatePhase. The overall preemption behaviour can be defined by the preemption distance. A phase can be interrupted by another phase if the difference of the priorities is greater than the preemption distance.

Each phase has its own name, priority, service time distribution, queueing strategy and preemption strategy. A phase is realized by the class ServerPhase.

All phases with the same priority share a common object of class ServerPriorityQueue which is automatically created by MultiPhasePrioServer.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	MultiPhasePrioServer.State

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

Entity.PortAlias

Field Summary

Fields

Modifier and Type	Field and Description
protected ServerJob	currentJob
protected int	currentQueueLength
protected double	entryTime
protected Event	event
protected IntegralStatistic	occupancy
protected java.util.Map<java.lang.String,ServerPhase>	phaseMap
protected int	preemptionDistance
protected java.util.List<ServerPriorityQueue>	priorityQueueList
protected IntegralStatistic	queueLength
protected MultiPhasePrioServer.State	state
protected SampleStatistic	transferTime
protected SampleStatistic	waitingTime

Fields inherited from class ikr.simlib.entities.Entity

portAliases, ports, simNode

Constructor Summary

Constructors

Constructor and Description
MultiPhasePrioServer(int preemptionDistance, SimNode ownNode)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	addPhase(ServerPhase phase)
void	createPhase(java.lang.String phaseName, ContinuousDistribution serviceTime)
void	createPhase(java.lang.String phaseName, ContinuousDistribution serviceTime, int priority)
void	createPhase(java.lang.String phaseName, ContinuousDistribution serviceTime, int priority, PreemptionStrategy preemptionStrategy)
void	createPhase(java.lang.String phaseName, ContinuousDistribution serviceTime, int priority, PreemptionStrategy preemptionStrategy, QueueingStrategy queueingStrategy)
void	deletePhase(java.lang.String phaseName)
protected ServerJob	get()
int	getNoOfPhases()
protected SynchronousOutputPort	getOutputPort(ServerJob job)
ServerPriorityQueue	getPriorityQueue(int priority)
void	handleProcessEvent(double eventTime)
protected void	interrupt(ServerJob job)
void	put(Message msg, ServerPhase phase)
protected void	removePhase(ServerPhase phase)
protected void	run(ServerJob job)
protected void	updateStatisticsAtEndOfService(ServerJob job, double currentTime)
protected void	updateStatisticsAtGet(ServerJob job, double currentTime)
protected void	updateStatisticsAtInterrupt(ServerJob job, double currentTime)
protected void	updateStatisticsAtPut(ServerJob job, double currentTime)
protected void	updateStatisticsAtRun(ServerJob job, double currentTime)

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

event

protected final Event event

preemptionDistance

protected final int preemptionDistance

phaseMap

protected final java.util.Map<java.lang.String,ServerPhase> phaseMap

priorityQueueList

protected final java.util.List<ServerPriorityQueue> priorityQueueList

state

protected MultiPhasePrioServer.State state

currentJob

protected ServerJob currentJob

entryTime

protected double entryTime

currentQueueLength

protected int currentQueueLength

occupancy

protected final IntegralStatistic occupancy

queueLength

protected final IntegralStatistic queueLength

transferTime

protected final SampleStatistic transferTime

waitingTime

protected final SampleStatistic waitingTime

Constructor Detail

MultiPhasePrioServer

public MultiPhasePrioServer(int preemptionDistance,
                    SimNode ownNode)

Method Detail

addPhase

protected void addPhase(ServerPhase phase)

removePhase

protected void removePhase(ServerPhase phase)

getOutputPort

protected SynchronousOutputPort getOutputPort(ServerJob job)

get

protected ServerJob get()

run

protected void run(ServerJob job)

interrupt

protected void interrupt(ServerJob job)

updateStatisticsAtPut

protected void updateStatisticsAtPut(ServerJob job,
                         double currentTime)

updateStatisticsAtGet

protected void updateStatisticsAtGet(ServerJob job,
                         double currentTime)

updateStatisticsAtRun

protected void updateStatisticsAtRun(ServerJob job,
                         double currentTime)

updateStatisticsAtInterrupt

protected void updateStatisticsAtInterrupt(ServerJob job,
                               double currentTime)

updateStatisticsAtEndOfService

protected void updateStatisticsAtEndOfService(ServerJob job,
                                  double currentTime)

createPhase

public void createPhase(java.lang.String phaseName,
               ContinuousDistribution serviceTime,
               int priority,
               PreemptionStrategy preemptionStrategy,
               QueueingStrategy queueingStrategy)

createPhase

public final void createPhase(java.lang.String phaseName,
               ContinuousDistribution serviceTime,
               int priority,
               PreemptionStrategy preemptionStrategy)

createPhase

public final void createPhase(java.lang.String phaseName,
               ContinuousDistribution serviceTime,
               int priority)

createPhase

public final void createPhase(java.lang.String phaseName,
               ContinuousDistribution serviceTime)

deletePhase

public void deletePhase(java.lang.String phaseName)

getNoOfPhases

public int getNoOfPhases()

put

public void put(Message msg,
       ServerPhase phase)

getPriorityQueue

public ServerPriorityQueue getPriorityQueue(int priority)

handleProcessEvent

public void handleProcessEvent(double eventTime)