Package org.yamcs.ygw

Class YgwNodeLink

java.lang.Object

com.google.common.util.concurrent.AbstractService

org.yamcs.tctm.AbstractLink

org.yamcs.tctm.AbstractTcTmParamLink

org.yamcs.ygw.YgwNodeLink

All Implemented Interfaces:

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

public class YgwNodeLink
extends AbstractTcTmParamLink
implements AggregatedDataLink

Corresponds to a Node in the Yamcs Gateway or to a sub-link (in the gateway each node can have zero or more sub-links)

Each sub-link has an id and the node itself functions as a link with id 0

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.AbstractTcTmParamLink

cmdPostProcessor, commandHistoryPublisher, packetCount, packetPreprocessor, parameterCount, parameterSink, updateSimulationTime

Fields inherited from class org.yamcs.tctm.AbstractLink

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

Constructor Summary

Constructors

Constructor	Description
YgwNodeLink(YgwLink ygwLink, org.yamcs.ygw.protobuf.Ygw.Node node, AggregatedDataLink parent, boolean replay)	Builds an object corresponding to a gateway node.
YgwNodeLink(YgwLink ygwLink, YgwNodeLink parent, org.yamcs.ygw.protobuf.Ygw.Link link, boolean replay)	Builds an object corresponding to a gateway sub-link.

Method Summary

Modifier and Type	Method	Description
void	addSublink(int linkId, YgwNodeLink nodeSublink)
protected Link.Status	connectionStatus()
protected void	doStart()
protected void	doStop()
AggregatedDataLink	getParent()
String	getPpStreamName()
YgwNodeLink	getSublink(int linkId)
List<Link>	getSubLinks()
String	getTmStreamName()
void	init(String instance, String name, YConfiguration config)
boolean	isParameterDataLinkImplemented()
boolean	isTcDataLinkImplemented()
boolean	isTmPacketDataLinkImplemented()
void	processCommandAck(int linkId, org.yamcs.ygw.protobuf.Ygw.CommandAck cmdAck)
void	processLinkStatus(int linkId, org.yamcs.ygw.protobuf.Ygw.LinkStatus lstatus)
void	processParameters(int linkId, String group, int seqNum, List<ParameterValue> pvList)
void	processTmFrame(int linkId, io.netty.buffer.ByteBuf buf)
void	processTmPacket(int linkId, io.netty.buffer.ByteBuf buf)
boolean	sendCommand(PreparedCommand pc)
boolean	sendCommand(PreparedCommand pc, Integer ygwCmdId)	send a command
CompletableFuture<Void>	sendTcFrame(byte[] data)

Methods inherited from class org.yamcs.tctm.AbstractTcTmParamLink

ackCommand, failedCommand, getDefaultSpec, initTc, initTm, postprocess, processPacket, setCommandHistoryPublisher, setParameterSink, setTmSink

Methods inherited from class org.yamcs.tctm.AbstractLink

addAction, collectSystemParameters, dataIn, dataOut, disable, doDisable, doEnable, enable, getAction, getActions, getConfig, getCurrentTime, getDataInCount, 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, getDataInCount, getDataOutCount, getDefaultSpec, getDetailedStatus, getExtraInfo, getLinkStatus, getName, getSpec, isDisabled, isEffectivelyDisabled, resetCounters, setParent, setupSystemParameters

Methods inherited from interface org.yamcs.parameter.SystemParametersProducer

getFrequency

Methods inherited from interface org.yamcs.tctm.TcDataLink

isCommandingAvailable

Constructor Details

YgwNodeLink

public YgwNodeLink(YgwLink ygwLink,
 org.yamcs.ygw.protobuf.Ygw.Node node,
 AggregatedDataLink parent,
 boolean replay)

Builds an object corresponding to a gateway node.

YgwNodeLink

public YgwNodeLink(YgwLink ygwLink,
 YgwNodeLink parent,
 org.yamcs.ygw.protobuf.Ygw.Link link,
 boolean replay)

Builds an object corresponding to a gateway sub-link.

If replayLink is not null, this is used for replays

Method Details

init

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

Specified by:

init in interface Link

Overrides:

init in class AbstractTcTmParamLink

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

processParameters

public void processParameters(int linkId,
 String group,
 int seqNum,
 List<ParameterValue> pvList)

processTmPacket

public void processTmPacket(int linkId,
 io.netty.buffer.ByteBuf buf)

processTmFrame

public void processTmFrame(int linkId,
 io.netty.buffer.ByteBuf buf)

getSublink

public YgwNodeLink getSublink(int linkId)

processLinkStatus

public void processLinkStatus(int linkId,
 org.yamcs.ygw.protobuf.Ygw.LinkStatus lstatus)

sendCommand

public boolean sendCommand(PreparedCommand pc)

Specified by:

sendCommand in interface TcDataLink

sendCommand

public boolean sendCommand(PreparedCommand pc,
 Integer ygwCmdId)

send a command

relativeName is set for the commands registered from the gateway

sendTcFrame

public CompletableFuture<Void> sendTcFrame(byte[] data)

processCommandAck

public void processCommandAck(int linkId,
 org.yamcs.ygw.protobuf.Ygw.CommandAck cmdAck)

getParent

public AggregatedDataLink getParent()

Specified by:

getParent in interface Link

Overrides:

getParent in class AbstractLink

isTmPacketDataLinkImplemented

public boolean isTmPacketDataLinkImplemented()

Specified by:

isTmPacketDataLinkImplemented in interface TmPacketDataLink

isTcDataLinkImplemented

public boolean isTcDataLinkImplemented()

Specified by:

isTcDataLinkImplemented in interface TcDataLink

isParameterDataLinkImplemented

public boolean isParameterDataLinkImplemented()

Specified by:

isParameterDataLinkImplemented in interface ParameterDataLink

addSublink

public void addSublink(int linkId,
 YgwNodeLink nodeSublink)

getSubLinks

public List<Link> getSubLinks()

Specified by:

getSubLinks in interface AggregatedDataLink

getTmStreamName

public String getTmStreamName()

Specified by:

getTmStreamName in interface TmPacketDataLink

getPpStreamName

public String getPpStreamName()

Specified by:

getPpStreamName in interface ParameterDataLink