Package org.yamcs.ygw

Class YgwLink

java.lang.Object

com.google.common.util.concurrent.AbstractService

org.yamcs.tctm.AbstractLink

org.yamcs.ygw.YgwLink

All Implemented Interfaces:

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

public class YgwLink
extends AbstractLink
implements AggregatedDataLink

Yamcs gateway link.

This is a Yamcs aggregated data link. It has a number of sub-links that correspond to the Yamcs Gateway nodes. Each node can have itself a list of sub-links.

The nodes and nodes sub-links are handled by the YgwNodeLink - there is one such object for each node and for each node' sub-link.

The list of nodes and their sub-links are created dynamically when Yamcs connects to the Gateway.

Configuration wise it looks like a normal Yamcs link configuration (where one can set the tm stream/pre-processor, tc stream/post-processor) but there is the possibility to override the main configuration at the level of nodes and sublinks.

Each Gateway node specify itself if it can handle TM/TC and they only added in the processing chain by the LinkManager if they support TM/TC.

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

Modifier and Type	Field	Description
static final byte	VERSION

Fields inherited from class org.yamcs.tctm.AbstractLink

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

Constructor Summary

Constructors

Constructor	Description
YgwLink()

Method Summary

Modifier and Type	Method	Description
protected Link.Status	connectionStatus()
void	doDisable()
void	doEnable()
protected void	doStart()
protected void	doStop()
YConfiguration	getConfig()
long	getDataInCount()
long	getDataOutCount()
String	getName()
YgwParameterManager	getParameterManager()
Spec	getSpec()
List<Link>	getSubLinks()
void	init(String instance, String name, YConfiguration config)
List<ParameterValue>	processParameters(int nodeId, org.yamcs.ygw.protobuf.Ygw.ParameterData pdata)
void	resetCounters()
CompletableFuture<Void>	sendMessage(byte msgType, int nodeId, int linkId, byte[] data)

Methods inherited from class org.yamcs.tctm.AbstractLink

addAction, collectSystemParameters, dataIn, dataOut, disable, enable, getAction, getActions, getCurrentTime, getDetailedStatus, getEventLoop, getLinkStatus, getParent, getSystemParameters, getYamcsInstance, isDisabled, isRunningAndEnabled, 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, getDefaultSpec, getDetailedStatus, getExtraInfo, getLinkStatus, getParent, isDisabled, isEffectivelyDisabled, setParent, setupSystemParameters

Methods inherited from interface org.yamcs.parameter.SystemParametersProducer

getFrequency

Field Details

VERSION

public static final byte VERSION

See Also:

• Constant Field Values

Constructor Details

YgwLink

public YgwLink()

Method Details

init

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

Specified by:

init in interface Link

Overrides:

init in class AbstractLink

getSpec

public Spec getSpec()

Specified by:

getSpec in interface Link

getConfig

public YConfiguration getConfig()

Specified by:

getConfig in interface Link

Overrides:

getConfig in class AbstractLink

getSubLinks

public List<Link> getSubLinks()

Specified by:

getSubLinks in interface AggregatedDataLink

getDataInCount

public long getDataInCount()

Specified by:

getDataInCount in interface Link

Overrides:

getDataInCount in class AbstractLink

getDataOutCount

public long getDataOutCount()

Specified by:

getDataOutCount in interface Link

Overrides:

getDataOutCount in class AbstractLink

resetCounters

public void resetCounters()

Specified by:

resetCounters in interface Link

Overrides:

resetCounters in class AbstractLink

doDisable

public void doDisable()

Overrides:

doDisable in class AbstractLink

doEnable

public void doEnable()

Overrides:

doEnable in class AbstractLink

getName

public String getName()

Specified by:

getName in interface Link

Overrides:

getName in class AbstractLink

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

sendMessage

public CompletableFuture<Void> sendMessage(byte msgType,
 int nodeId,
 int linkId,
 byte[] data)

processParameters

public List<ParameterValue> processParameters(int nodeId,
 org.yamcs.ygw.protobuf.Ygw.ParameterData pdata)

getParameterManager

public YgwParameterManager getParameterManager()