Module org.yamcs.core

Package org.yamcs.tctm

Class TcpTmDataLink

java.lang.Object

com.google.common.util.concurrent.AbstractService

org.yamcs.tctm.AbstractLink

org.yamcs.tctm.AbstractTmDataLink

org.yamcs.tctm.TcpTmDataLink

All Implemented Interfaces:

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

public class TcpTmDataLink
extends AbstractTmDataLink
implements 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 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
TcpTmDataLink()

Method Summary

Modifier and Type	Method	Description
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()
String	getDetailedStatus()
TmPacket	getNextPacket()
void	init(String instance, String name, YConfiguration config)	Called at startup to initialize the link.
protected void	openSocket()
void	run()

Methods inherited from class org.yamcs.tctm.AbstractTmDataLink

collectSystemParameters, getDataInCount, getDataOutCount, processPacket, resetCounters, setTmSink, setupSystemParameters, updateStats

Methods inherited from class org.yamcs.tctm.AbstractLink

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

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, getLinkStatus, getName, getParent, getSpec, isDisabled, isEffectivelyDisabled, setParent

Methods inherited from interface org.yamcs.parameter.SystemParametersProducer

getFrequency, getSystemParameters, getSystemParameters

Field Details

tmSocket

protected Socket tmSocket

host

protected String host

port

protected int port

initialDelay

protected long initialDelay

Constructor Details

TcpTmDataLink

public TcpTmDataLink()

Method Details

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

openSocket

protected void openSocket()
                   throws IOException

Throws:

IOException

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

run

public void run()

Specified by:

run in interface Runnable

getNextPacket

public TmPacket getNextPacket()

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