kieker.tools.logReplayer

Class FilesystemLogReplayer

java.lang.Object

kieker.tools.logReplayer.AbstractLogReplayer

kieker.tools.logReplayer.FilesystemLogReplayer

public class FilesystemLogReplayer
extends AbstractLogReplayer

An implementation of the AbstractLogReplayer, using the FSReader to replay IMonitoringRecords from a list of file system monitoring logs.

Since:

0.95a

Author:

Andre van Hoorn

Field Summary

Fields inherited from class kieker.tools.logReplayer.AbstractLogReplayer

MAX_TIMESTAMP, MIN_TIMESTAMP

Constructor Summary

Constructors

Constructor and Description
FilesystemLogReplayer(java.lang.String monitoringConfigurationFile, boolean realtimeMode, double realtimeAccelerationFactor, boolean keepOriginalLoggingTimestamps, int numRealtimeWorkerThreads, long ignoreRecordsBeforeTimestamp, long ignoreRecordsAfterTimestamp, java.lang.String[] inputDirs) Creates a new instance of this class using the given parameters.

Method Summary

Methods

Modifier and Type	Method and Description
protected AbstractReaderPlugin	createReader(IAnalysisController analysisInstance) Implementing classes return the reader to be used for reading the monitoring log.
protected java.lang.String	readerOutputPortName() Implementing classes returns the name of the reader's output port which provides the IMonitoringRecords from the monitoring log.

Methods inherited from class kieker.tools.logReplayer.AbstractLogReplayer

replay

Methods inherited from class java.lang.Object

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

Constructor Detail

FilesystemLogReplayer

public FilesystemLogReplayer(java.lang.String monitoringConfigurationFile,
                     boolean realtimeMode,
                     double realtimeAccelerationFactor,
                     boolean keepOriginalLoggingTimestamps,
                     int numRealtimeWorkerThreads,
                     long ignoreRecordsBeforeTimestamp,
                     long ignoreRecordsAfterTimestamp,
                     java.lang.String[] inputDirs)

Creates a new instance of this class using the given parameters.

Parameters:

monitoringConfigurationFile - The name of the monitoring configuration file.

realtimeMode - Whether realtime mode should be used.

realtimeAccelerationFactor - Determines whether to accelerate (value > 1.0) or slow down (<1.0) the replay in realtime mode by the given factor. Choose a value of 1.0 for "real" realtime mode (i.e., no acceleration/slow down)

keepOriginalLoggingTimestamps - Whether to keep the original logging timestamps or not.

numRealtimeWorkerThreads - The number of realtime worker threads to be used.

ignoreRecordsBeforeTimestamp - The lower limit for the timestamps.

ignoreRecordsAfterTimestamp - The upper limit for the timestamps.

inputDirs - The array containing the input directories.

Method Detail

createReader

protected AbstractReaderPlugin createReader(IAnalysisController analysisInstance)

Implementing classes return the reader to be used for reading the monitoring log.

Specified by:

createReader in class AbstractLogReplayer

Parameters:

analysisInstance - The analysis controller which will be the parent of the reader.

Returns:

The reader which can be used to read the monitoring log.

readerOutputPortName

protected java.lang.String readerOutputPortName()

Implementing classes returns the name of the reader's output port which provides the IMonitoringRecords from the monitoring log.

Specified by:

readerOutputPortName in class AbstractLogReplayer

Returns:

The name of the reader's output port.