ikr.simlib.entities.generators

Class BurstGenerator

java.lang.Object

ikr.simlib.entities.Entity

ikr.simlib.entities.generators.Generator

ikr.simlib.entities.generators.BurstGenerator

All Implemented Interfaces:

ReflectionConstructable, ReflectionConstructable2<SimNode,Parameters>

public class BurstGenerator
extends Generator

BurstGenerator generates bursts of information that are segmented in messages of max. size and sent according to an interPacketTime. MessageFactory and parsing is done as in StdGenerator.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	BurstGenerator.BurstData

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

Entity.PortAlias

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.List<BurstGenerator.BurstData>	activeBursts
protected ContinuousDistribution	burstIATDist
protected DiscreteDistribution	burstLengthDist
protected Duration	interPacketTime
protected int	maxPacketSize
protected BurstGenerator.BurstData	nextBurst

Fields inherited from class ikr.simlib.entities.generators.Generator

activated, currentEventToken, messageFactory, outputPort

Fields inherited from class ikr.simlib.entities.Entity

portAliases, ports, simNode

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

CREATE_INSTANCE_METHOD_NAME

Constructor Summary

Constructors

Constructor and Description
BurstGenerator(DiscreteDistribution burstLengthDist, ContinuousDistribution burstIATDist, Duration interPacketTime, int maxPacketSize, SimNode ownNode)
BurstGenerator(DiscreteDistribution burstLengthDist, ContinuousDistribution burstIATDist, Duration interPacketTime, int maxPacketSize, SimNode ownNode, boolean activateOnStart)
BurstGenerator(DiscreteDistribution burstLengthDist, ContinuousDistribution burstIATDist, Duration interPacketTime, int maxPacketSize, SimNode ownNode, Factory<Message> factory)
BurstGenerator(DiscreteDistribution burstLengthDist, ContinuousDistribution burstIATDist, Duration interPacketTime, int maxPacketSize, SimNode ownNode, Factory<Message> factory, boolean activateOnStart)

Method Summary

Methods

Modifier and Type	Method and Description
static BurstGenerator	createInstance(SimNode ownNode, Parameters pars) as required by ReflectionConstructable
protected Message	createMessage()
protected Message	createMessageToSend(int length)
protected void	createNewNextBurst(PointInTime refTime) creates a new burst and stores it in nextBurst
protected BurstGenerator.BurstData	getCurentBurst() decides which burst is the one which sends the next packet.
protected PointInTime	getNextEventTime(PointInTime currentTime)
void	setActivated(boolean start)

Methods inherited from class ikr.simlib.entities.generators.Generator

activate, deactivate, getMessageFactory, getOutput, handleProcessEvent, setMessageFactory

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

burstLengthDist

protected final DiscreteDistribution burstLengthDist

burstIATDist

protected final ContinuousDistribution burstIATDist

interPacketTime

protected final Duration interPacketTime

maxPacketSize

protected final int maxPacketSize

activeBursts

protected final java.util.List<BurstGenerator.BurstData> activeBursts

nextBurst

protected BurstGenerator.BurstData nextBurst

Constructor Detail

BurstGenerator

public BurstGenerator(DiscreteDistribution burstLengthDist,
              ContinuousDistribution burstIATDist,
              Duration interPacketTime,
              int maxPacketSize,
              SimNode ownNode,
              Factory<Message> factory,
              boolean activateOnStart)

BurstGenerator

public BurstGenerator(DiscreteDistribution burstLengthDist,
              ContinuousDistribution burstIATDist,
              Duration interPacketTime,
              int maxPacketSize,
              SimNode ownNode,
              Factory<Message> factory)

BurstGenerator

public BurstGenerator(DiscreteDistribution burstLengthDist,
              ContinuousDistribution burstIATDist,
              Duration interPacketTime,
              int maxPacketSize,
              SimNode ownNode)

BurstGenerator

public BurstGenerator(DiscreteDistribution burstLengthDist,
              ContinuousDistribution burstIATDist,
              Duration interPacketTime,
              int maxPacketSize,
              SimNode ownNode,
              boolean activateOnStart)

Method Detail

createInstance

public static BurstGenerator createInstance(SimNode ownNode,
                            Parameters pars)

as required by ReflectionConstructable

setActivated

public void setActivated(boolean start)

Overrides:

setActivated in class Generator

getNextEventTime

protected PointInTime getNextEventTime(PointInTime currentTime)

Specified by:

getNextEventTime in class Generator

createMessage

protected Message createMessage()

Overrides:

createMessage in class Generator

createMessageToSend

protected Message createMessageToSend(int length)

createNewNextBurst

protected void createNewNextBurst(PointInTime refTime)

creates a new burst and stores it in nextBurst

Parameters:

refTime - PointInTime which serves as reference for the burst IAT

getCurentBurst

protected BurstGenerator.BurstData getCurentBurst()

decides which burst is the one which sends the next packet. If the nextBurst is the one to send the next packet, it is added to the burstList and a new nextBurst is created.

Returns:

the burst which sends the next packet