kieker.tools.logReplayer
Class RealtimeReplayDistributor

java.lang.Object
  kieker.analysis.plugin.AbstractPlugin
      kieker.analysis.plugin.filter.AbstractFilterPlugin
          kieker.tools.logReplayer.RealtimeReplayDistributor

All Implemented Interfaces:

IFilterPlugin, IPlugin

public class RealtimeReplayDistributor
extends AbstractFilterPlugin

IMonitoringRecordConsumerPlugin that distributes the log records to the worker thread for "real time" replays.
This class has exactly one input port named "in" and one output ports named "out".
TODO: Currently this class can not be used for the later analysis tool, as the objects for the constructor cannot be configured with a configuration object.

Author:

Robert von Massow

Nested Class Summary

Nested classes/interfaces inherited from interface kieker.analysis.plugin.IPlugin

IPlugin.PluginInputPortReference

Field Summary

static String	CONFIG_PROPERTY_NAME_NUM_WORKERS
static String	INPUT_PORT_NAME_MONITORING_RECORDS

Fields inherited from class kieker.analysis.plugin.AbstractPlugin

CONFIG_NAME

Constructor Summary

RealtimeReplayDistributor(Configuration configuration)
Constructs a RealtimeReplayDistributor.

Method Summary

void	decreaseActive()
Configuration	getCurrentConfiguration() This method should deliver a Configuration object containing the current configuration of this instance.
int	getNumWorkers()
long	getOffset()
long	getStartTime()
void	inputMonitoringRecords(IMonitoringRecord monitoringRecord)
void	setCons(kieker.tools.logReplayer.FSReaderRealtime.FSReaderRealtimeCons cons)
void	setConstInputPortName(String constInputPortName)
void	setController(AnalysisController controller)
void	setTerminationLatch(CountDownLatch terminationLatch)
void	terminate(boolean error) Initiates a termination of the component.

Methods inherited from class kieker.analysis.plugin.filter.AbstractFilterPlugin

init

Methods inherited from class kieker.analysis.plugin.AbstractPlugin

areAllRepositoryPortsConnected, connect, connect, getAllInputPortNames, getAllOutputPortNames, getConnectedPlugins, getCurrentRepositories, getName, getPluginDescription, getPluginName, isConnectionAllowed

Methods inherited from class java.lang.Object

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

Field Detail

INPUT_PORT_NAME_MONITORING_RECORDS

public static final String INPUT_PORT_NAME_MONITORING_RECORDS

See Also:

Constant Field Values

CONFIG_PROPERTY_NAME_NUM_WORKERS

public static final String CONFIG_PROPERTY_NAME_NUM_WORKERS

See Also:

Constant Field Values

Constructor Detail

RealtimeReplayDistributor

public RealtimeReplayDistributor(Configuration configuration)

Constructs a RealtimeReplayDistributor.

Parameters:

configuration - The configuration object used to configure this instance.

Method Detail

setCons

public void setCons(kieker.tools.logReplayer.FSReaderRealtime.FSReaderRealtimeCons cons)

setConstInputPortName

public void setConstInputPortName(String constInputPortName)

setTerminationLatch

public void setTerminationLatch(CountDownLatch terminationLatch)

setController

public void setController(AnalysisController controller)

inputMonitoringRecords

public void inputMonitoringRecords(IMonitoringRecord monitoringRecord)

getOffset

public final long getOffset()

getStartTime

public final long getStartTime()

terminate

public void terminate(boolean error)

Description copied from interface: IFilterPlugin

Initiates a termination of the component. The value of the parameter error indicates whether an error occurred.

Specified by:

terminate in interface IFilterPlugin

Overrides:

terminate in class AbstractFilterPlugin

Parameters:

error - true iff an error occurred.

decreaseActive

public void decreaseActive()

getNumWorkers

public int getNumWorkers()

getCurrentConfiguration

public Configuration getCurrentConfiguration()

Description copied from interface: IPlugin

This method should deliver a Configuration object containing the current configuration of this instance. In other words: The constructor should be able to use the given object to initialize a new instance of this class with the same intern properties.

Returns:

A completely filled configuration object.