Package org.yamcs.tctm

Class ReplayService

java.lang.Object

com.google.common.util.concurrent.AbstractService

org.yamcs.AbstractProcessorService

org.yamcs.tctm.ReplayService

All Implemented Interfaces:

com.google.common.util.concurrent.Service, ReplayListener, CommandHistoryProvider, ParameterProvider, ProcessorService, ArchiveTmPacketProvider, TmPacketProvider

public class ReplayService
extends AbstractProcessorService
implements ReplayListener, ArchiveTmPacketProvider, ParameterProvider, CommandHistoryProvider

Provides telemetry packets and processed parameters from the yamcs archive.

Nested Class Summary

Nested classes/interfaces inherited from interface com.google.common.util.concurrent.Service

com.google.common.util.concurrent.Service.Listener, com.google.common.util.concurrent.Service.State

Field Summary

Fields inherited from class org.yamcs.AbstractProcessorService

config, log, processor

Constructor Summary

Constructors

Constructor	Description
ReplayService()

Method Summary

Modifier and Type	Method	Description
boolean	canProvide(Yamcs.NamedObjectId id)	Returns whether or not a given parameter can be provided by this provider
boolean	canProvide(Parameter p)
void	changeEndAction(Yamcs.EndAction endAction)
void	changeRange(long start, long stop)
void	changeSpeed(Yamcs.ReplaySpeed speed)
void	doStart()
void	doStop()
Yamcs.ReplayRequest	getCurrentReplayRequest()
Parameter	getParameter(Yamcs.NamedObjectId id)	Returns the parameterDefinition corresponding to the parameter id
Yamcs.ReplayRequest	getReplayRequest()
Yamcs.ReplayStatus.ReplayState	getReplayState()
long	getReplayTime()
Yamcs.ReplaySpeed	getSpeed()
void	init(Processor proc, YConfiguration args, Object spec)
boolean	isArchiveReplay()	true if this is a replay from archive
void	newData(Db.ProtoDataType type, Object data)
void	pause()
void	resume()
void	seek(long time, boolean autostart)
void	setCommandHistoryRequestManager(CommandHistoryRequestManager chrm)
void	setParameterProcessor(ParameterProcessor ppm)	Send parameters to this processor.
void	startProviding(Parameter paramDef)	Adds a new parameter to the list of parameters that have to provided
void	startProvidingAll()	start providing all known parameters
void	stateChanged(Yamcs.ReplayStatus rs)
void	stopProviding(Parameter paramDef)	Removes a parameter from the list of parameters that have to be provided

Methods inherited from class org.yamcs.AbstractProcessorService

getConfig, getYamcsInstance

Methods inherited from class com.google.common.util.concurrent.AbstractService

addListener, awaitRunning, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, awaitTerminated, doCancelStart, failureCause, isRunning, notifyFailed, notifyStarted, notifyStopped, startAsync, state, stopAsync, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.yamcs.ProcessorService

getSpec

Methods inherited from interface com.google.common.util.concurrent.Service

addListener, awaitRunning, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, awaitTerminated, failureCause, isRunning, startAsync, state, stopAsync

Constructor Details

ReplayService

public ReplayService()

Method Details

init

public void init(Processor proc,
 YConfiguration args,
 Object spec)

Specified by:

init in interface ProcessorService

Overrides:

init in class AbstractProcessorService

args - service configuration as specified in processor.yaml

spec - passed by the user when creating the processor (for instance via the REST API)

isArchiveReplay

public boolean isArchiveReplay()

Description copied from interface: TmPacketProvider

true if this is a replay from archive

Specified by:

isArchiveReplay in interface TmPacketProvider

Returns:

newData

public void newData(Db.ProtoDataType type,
 Object data)

Specified by:

newData in interface ReplayListener

stateChanged

public void stateChanged(Yamcs.ReplayStatus rs)

Specified by:

stateChanged in interface ReplayListener

doStop

public void doStop()

Specified by:

doStop in class com.google.common.util.concurrent.AbstractService

doStart

public void doStart()

Specified by:

doStart in class com.google.common.util.concurrent.AbstractService

pause

public void pause()

Specified by:

pause in interface ArchiveTmPacketProvider

resume

public void resume()

Specified by:

resume in interface ArchiveTmPacketProvider

seek

public void seek(long time,
 boolean autostart)

Specified by:

seek in interface ArchiveTmPacketProvider

setParameterProcessor

public void setParameterProcessor(ParameterProcessor ppm)

Description copied from interface: ParameterProvider

Send parameters to this processor.

Specified by:

setParameterProcessor in interface ParameterProvider

startProviding

public void startProviding(Parameter paramDef)

Description copied from interface: ParameterProvider

Adds a new parameter to the list of parameters that have to provided

Specified by:

startProviding in interface ParameterProvider

startProvidingAll

public void startProvidingAll()

Description copied from interface: ParameterProvider

start providing all known parameters

Specified by:

startProvidingAll in interface ParameterProvider

stopProviding

public void stopProviding(Parameter paramDef)

Description copied from interface: ParameterProvider

Removes a parameter from the list of parameters that have to be provided

Specified by:

stopProviding in interface ParameterProvider

canProvide

public boolean canProvide(Yamcs.NamedObjectId id)

Description copied from interface: ParameterProvider

Returns whether or not a given parameter can be provided by this provider

Specified by:

canProvide in interface ParameterProvider

Returns:

canProvide

public boolean canProvide(Parameter p)

Specified by:

canProvide in interface ParameterProvider

getParameter

public Parameter getParameter(Yamcs.NamedObjectId id)
                       throws InvalidIdentification

Description copied from interface: ParameterProvider

Returns the parameterDefinition corresponding to the parameter id

Specified by:

getParameter in interface ParameterProvider

Parameters:

id - - id of the parameter that is returned

Returns:

Throws:

InvalidIdentification

getSpeed

public Yamcs.ReplaySpeed getSpeed()

Specified by:

getSpeed in interface ArchiveTmPacketProvider

getReplayRequest

public Yamcs.ReplayRequest getReplayRequest()

Specified by:

getReplayRequest in interface ArchiveTmPacketProvider

getCurrentReplayRequest

public Yamcs.ReplayRequest getCurrentReplayRequest()

Specified by:

getCurrentReplayRequest in interface ArchiveTmPacketProvider

getReplayState

public Yamcs.ReplayStatus.ReplayState getReplayState()

Specified by:

getReplayState in interface ArchiveTmPacketProvider

getReplayTime

public long getReplayTime()

Specified by:

getReplayTime in interface ArchiveTmPacketProvider

changeSpeed

public void changeSpeed(Yamcs.ReplaySpeed speed)

Specified by:

changeSpeed in interface ArchiveTmPacketProvider

changeEndAction

public void changeEndAction(Yamcs.EndAction endAction)

Specified by:

changeEndAction in interface ArchiveTmPacketProvider

changeRange

public void changeRange(long start,
 long stop)

Specified by:

changeRange in interface ArchiveTmPacketProvider

setCommandHistoryRequestManager

public void setCommandHistoryRequestManager(CommandHistoryRequestManager chrm)

Specified by:

setCommandHistoryRequestManager in interface CommandHistoryProvider