Package org.yamcs.tctm

Class TcpTcTmDataLink

java.lang.Object

com.google.common.util.concurrent.AbstractService

org.yamcs.tctm.AbstractLink

org.yamcs.tctm.AbstractTmDataLink

org.yamcs.tctm.TcpTcTmDataLink

All Implemented Interfaces:

com.google.common.util.concurrent.Service, Runnable, SystemParametersProducer, Link, TcDataLink, TmPacketDataLink

public class TcpTcTmDataLink
extends AbstractTmDataLink
implements TcDataLink, Runnable

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
protected CommandPostprocessor	cmdPostProcessor
protected CommandHistoryPublisher	commandHistoryPublisher
protected AtomicLong	dataOutCount
protected String	host
protected long	initialDelay
protected int	port
protected Socket	tmSocket

Fields inherited from class org.yamcs.tctm.AbstractTmDataLink

packetCount, packetPreprocessor, updateSimulationTime

Fields inherited from class org.yamcs.tctm.AbstractLink

config, disabled, eventProducer, linkName, log, timeService, yamcsInstance

Constructor Summary

Constructors

Constructor	Description
TcpTcTmDataLink()

Method Summary

Modifier and Type	Method	Description
protected void	ackCommand(org.yamcs.protobuf.Commanding.CommandId commandId)	send an ack in the command history that the command has been sent out of the link
protected void	checkAndOpenSocket()
protected void	closeSocket()
protected Link.Status	connectionStatus()	In case the link should be connected (i.e. is running and enabled) this method is called to return the actual connection status
void	doDisable()
void	doEnable()
void	doStart()
void	doStop()
protected void	failedCommand(org.yamcs.protobuf.Commanding.CommandId commandId, String reason)	Send to command history the failed command
protected long	getCurrentTime()
long	getDataOutCount()
String	getDetailedStatus()
TmPacket	getNextPacket()
AggregatedDataLink	getParent()	If this link is a sublink of an aggregated link, get the parent link.
void	init(String instance, String name, YConfiguration config)	Called at startup to initialize the link.
protected void	initPostprocessor(String instance, YConfiguration config)
protected boolean	isSocketOpen()
void	resetCounters()
void	run()
protected void	sendBuffer(byte[] data)
void	sendTc(PreparedCommand pc)
void	setCommandHistoryPublisher(CommandHistoryPublisher commandHistoryListener)
void	setParent(AggregatedDataLink parent)	Set the parent link if this is a sublink of an aggregated link.

Methods inherited from class org.yamcs.tctm.AbstractTmDataLink

collectSystemParameters, getDataInCount, processPacket, setTmSink, setupSystemParameters, updateStats

Methods inherited from class org.yamcs.tctm.AbstractLink

disable, enable, getConfig, getEventLoop, getLinkStatus, getName, getSystemParameters, isDisabled, isRunningAndEnabled

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

addListener, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, 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, getLinkStatus, getName, getSpec, isDisabled, setupSystemParameters

Methods inherited from interface org.yamcs.parameter.SystemParametersProducer

getSystemParameters

Field Detail

commandHistoryPublisher

protected CommandHistoryPublisher commandHistoryPublisher

dataOutCount

protected AtomicLong dataOutCount

cmdPostProcessor

protected CommandPostprocessor cmdPostProcessor

tmSocket

protected Socket tmSocket

host

protected String host

port

protected int port

initialDelay

protected long initialDelay

Constructor Detail

TcpTcTmDataLink

public TcpTcTmDataLink()

Method Detail

init

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

Description copied from interface: Link

Called at startup to initialize the link.

The config corresponds to the map that is under the link definition in yamcs.instance.yaml.

Specified by:

init in interface Link

Overrides:

init in class AbstractTmDataLink

config - - the configuration - cannot be null (but can be empty)

Throws:

ConfigurationException

checkAndOpenSocket

protected void checkAndOpenSocket()
                           throws IOException

Throws:

IOException

isSocketOpen

protected boolean isSocketOpen()

sendBuffer

protected void sendBuffer(byte[] data)
                   throws IOException

Throws:

IOException

closeSocket

protected void closeSocket()

run

public void run()

Specified by:

run in interface Runnable

getNextPacket

public TmPacket getNextPacket()

initPostprocessor

protected void initPostprocessor(String instance,
                                 YConfiguration config)
                          throws ConfigurationException

Throws:

ConfigurationException

sendTc

public void sendTc(PreparedCommand pc)

Specified by:

sendTc in interface TcDataLink

setCommandHistoryPublisher

public void setCommandHistoryPublisher(CommandHistoryPublisher commandHistoryListener)

Specified by:

setCommandHistoryPublisher in interface TcDataLink

failedCommand

protected void failedCommand(org.yamcs.protobuf.Commanding.CommandId commandId,
                             String reason)

Send to command history the failed command

ackCommand

protected void ackCommand(org.yamcs.protobuf.Commanding.CommandId commandId)

send an ack in the command history that the command has been sent out of the link

Parameters:

commandId -

doStart

public void doStart()

Specified by:

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

doStop

public void doStop()

Specified by:

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

getCurrentTime

protected long getCurrentTime()

Overrides:

getCurrentTime in class AbstractLink

getDataOutCount

public long getDataOutCount()

Specified by:

getDataOutCount in interface Link

Overrides:

getDataOutCount in class AbstractTmDataLink

resetCounters

public void resetCounters()

Specified by:

resetCounters in interface Link

Overrides:

resetCounters in class AbstractTmDataLink

getParent

public AggregatedDataLink getParent()

Description copied from interface: Link

If this link is a sublink of an aggregated link, get the parent link.

Specified by:

getParent in interface Link

setParent

public void setParent(AggregatedDataLink parent)

Description copied from interface: Link

Set the parent link if this is a sublink of an aggregated link.

Specified by:

setParent in interface Link

doDisable

public void doDisable()

Overrides:

doDisable in class AbstractLink

doEnable

public void doEnable()

Overrides:

doEnable in class AbstractLink

getDetailedStatus

public String getDetailedStatus()

Specified by:

getDetailedStatus in interface Link

Overrides:

getDetailedStatus in class AbstractLink

Returns:

more detailed status information

connectionStatus

protected Link.Status connectionStatus()

Description copied from class: AbstractLink

In case the link should be connected (i.e. is running and enabled) this method is called to return the actual connection status

Specified by:

connectionStatus in class AbstractLink