public class RecordCurrentTimeEventGenerationFilter extends AbstractCurrentTimeEventGenerationFilter<IMonitoringRecord>
IMonitoringRecord
s.
TimestampRecord
with the given timestamp.AbstractCurrentTimeEventGenerationFilter.firstTimestamp
and future events are generated at AbstractCurrentTimeEventGenerationFilter.firstTimestamp
+ i *
AbstractCurrentTimeEventGenerationFilter.timerResolution
.IMonitoringRecord
may lead to future TimestampRecord
as follows:
IMonitoringRecord
with logging timestamp tstamp leads to the new timer events satisfying
AbstractCurrentTimeEventGenerationFilter.firstTimestamp
+ i * AbstractCurrentTimeEventGenerationFilter.timerResolution
< tstamp.currentTimeRecordOutputPort, currentTimeValueOutputPort, firstTimestamp, maxTimestamp, mostRecentEventFired, timerResolution
Constructor and Description |
---|
RecordCurrentTimeEventGenerationFilter(long timerResolution)
Creates an event generator which generates time events with the given resolution in timeunits.
|
Modifier and Type | Method and Description |
---|---|
protected void |
execute(IMonitoringRecord record)
Evaluates the given timestamp internal current time which may lead to
newly generated events via currentTimeRecordOutputPort.
|
getCurrentTimeRecordOutputPort, getCurrentTimeValueOutputPort
createInputPort, execute, getInputPort
abort, addInputPortRemovedListener, addOutputPortRemovedListener, compareAndSetBeingExecuted, createInputPort, createInputPort, createInputPort, createOutputPort, createOutputPort, createOutputPort, createOutputPort, declareActive, declarePassive, executeByFramework, getCurrentState, getId, getInputPorts, getOutputPorts, getOwningThread, getTerminationStrategy, isActive, isBeingExecuted, isPaused, isProducer, isStateless, onSignal, onStarting, onTerminating, onValidating, removeDynamicPort, removeDynamicPort, setPaused, setStateless, shouldBeTerminated, signalAlreadyReceived, terminateStage, toString, workCompleted
public RecordCurrentTimeEventGenerationFilter(long timerResolution)
timerResolution
- The timer resolution usedprotected void execute(IMonitoringRecord record)
execute
in class AbstractCurrentTimeEventGenerationFilter<IMonitoringRecord>
record
- The next record.Copyright 2020 Kieker Project, http://kieker-monitoring.net