Package org.yamcs.ygw

Class YgwReplayLink

java.lang.Object

com.google.common.util.concurrent.AbstractService

org.yamcs.tctm.AbstractLink

org.yamcs.ygw.YgwReplayLink

All Implemented Interfaces:

com.google.common.util.concurrent.Service, SystemParametersProducer, AggregatedDataLink, Link, LinkActionProvider

public class YgwReplayLink
extends AbstractLink
implements AggregatedDataLink

Groups all the sub-links in replay mode

Nested Class Summary

Nested classes/interfaces inherited from interface org.yamcs.tctm.Link

Link.Status

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.tctm.AbstractLink

config, dataInCount, dataOutCount, disabled, eventProducer, LINK_NAMESPACE, linkName, log, timeService, yamcsInstance

Constructor Summary

Constructors

Constructor	Description
YgwReplayLink(YgwLink ygwLink, String host, int replayPort)

Method Summary

Modifier and Type	Method	Description
void	addSubLink(YgwNodeLink nodeLink)
void	cleanNodes()	Called by YgwLink when a list of nodes is received from the Yamcs Gateway
void	cleanReplays()
protected Link.Status	connectionStatus()
protected void	doStart()
protected void	doStop()
long	getDataInCount()
AggregatedDataLink	getParent()
List<Link>	getSubLinks()
void	init(String instance, String name, YConfiguration config)
void	scheduleReplay(long startRn, long stopRn)

Methods inherited from class org.yamcs.tctm.AbstractLink

addAction, collectSystemParameters, dataIn, dataOut, disable, doDisable, doEnable, enable, getAction, getActions, getConfig, getCurrentTime, getDataOutCount, getDetailedStatus, getEventLoop, getLinkStatus, getName, getSystemParameters, getYamcsInstance, isDisabled, isRunningAndEnabled, resetCounters, setParent, setupSystemParameters

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.tctm.Link

disable, enable, getConfig, getDataOutCount, getDefaultSpec, getDetailedStatus, getExtraInfo, getLinkStatus, getName, getSpec, isDisabled, isEffectivelyDisabled, resetCounters, setParent, setupSystemParameters

Methods inherited from interface org.yamcs.parameter.SystemParametersProducer

getFrequency

Constructor Details

YgwReplayLink

public YgwReplayLink(YgwLink ygwLink,
 String host,
 int replayPort)

Method Details

init

public void init(String instance,
 String name,
 YConfiguration config)

Specified by:

init in interface Link

Overrides:

init in class AbstractLink

getSubLinks

public List<Link> getSubLinks()

Specified by:

getSubLinks in interface AggregatedDataLink

connectionStatus

protected Link.Status connectionStatus()

Specified by:

connectionStatus in class AbstractLink

doStart

protected void doStart()

Specified by:

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

doStop

protected void doStop()

Specified by:

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

addSubLink

public void addSubLink(YgwNodeLink nodeLink)

getParent

public AggregatedDataLink getParent()

Specified by:

getParent in interface Link

Overrides:

getParent in class AbstractLink

scheduleReplay

public void scheduleReplay(long startRn,
 long stopRn)

cleanNodes

public void cleanNodes()

Called by YgwLink when a list of nodes is received from the Yamcs Gateway

cleanReplays

public void cleanReplays()

getDataInCount

public long getDataInCount()

Specified by:

getDataInCount in interface Link

Overrides:

getDataInCount in class AbstractLink