public class TimestampCurrentTimeEventGenerationFilter extends AbstractCurrentTimeEventGenerationFilter<java.lang.Long>
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 |
---|
TimestampCurrentTimeEventGenerationFilter(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(java.lang.Long timestamp)
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 TimestampCurrentTimeEventGenerationFilter(long timerResolution)
timerResolution
- The timer resolution usedprotected void execute(java.lang.Long timestamp)
execute
in class AbstractCurrentTimeEventGenerationFilter<java.lang.Long>
timestamp
- The next timestamp.Copyright 2020 Kieker Project, http://kieker-monitoring.net