kieker.analysis.source.tcp

Class MultipleConnectionTcpSourceStage

java.lang.Object

teetime.framework.AbstractStage

teetime.framework.AbstractProducerStage<IMonitoringRecord>

kieker.analysis.source.tcp.MultipleConnectionTcpSourceStage

public class MultipleConnectionTcpSourceStage
extends teetime.framework.AbstractProducerStage<IMonitoringRecord>

This is a multi connection tcp source stage.

Since:

1.15

Author:

Reiner Jung

Field Summary

Fields inherited from class teetime.framework.AbstractProducerStage

outputPort

Fields inherited from class teetime.framework.AbstractStage

logger

Constructor Summary

Constructors

Constructor and Description
MultipleConnectionTcpSourceStage(int inputPort, int bufferSize, ITraceMetadataRewriter recordRewriter) Create a single threaded multi connection tcp reader stage.

Method Summary

Modifier and Type	Method and Description
protected void	execute()
protected void	onTerminating()
void	rejectNewConnection()

Methods inherited from class teetime.framework.AbstractProducerStage

getOutputPort, getTerminationStrategy

Methods inherited from class teetime.framework.AbstractStage

abort, addInputPortRemovedListener, addOutputPortRemovedListener, compareAndSetBeingExecuted, createInputPort, createInputPort, createInputPort, createInputPort, createOutputPort, createOutputPort, createOutputPort, createOutputPort, declareActive, declarePassive, executeByFramework, getCurrentState, getId, getInputPorts, getOutputPorts, getOwningThread, isActive, isBeingExecuted, isPaused, isProducer, isStateless, onSignal, onStarting, onValidating, removeDynamicPort, removeDynamicPort, setPaused, setStateless, shouldBeTerminated, signalAlreadyReceived, terminateStage, toString, workCompleted

Methods inherited from class java.lang.Object

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

Constructor Detail

MultipleConnectionTcpSourceStage

public MultipleConnectionTcpSourceStage(int inputPort,
                                        int bufferSize,
                                        ITraceMetadataRewriter recordRewriter)

Create a single threaded multi connection tcp reader stage.

Parameters:

inputPort - used to accept IMonitoringRecords and string registry entries.

bufferSize - capacity of the receiving buffer

recordRewriter - rewriting records

Method Detail

execute

protected void execute()

Specified by:

execute in class teetime.framework.AbstractStage

rejectNewConnection

public void rejectNewConnection()

onTerminating

protected void onTerminating()

Overrides:

onTerminating in class teetime.framework.AbstractStage