Package org.yamcs.tctm

Class AbstractThreadedTcDataLink

java.lang.Object

com.google.common.util.concurrent.AbstractService

org.yamcs.tctm.AbstractLink

org.yamcs.tctm.AbstractTcDataLink

org.yamcs.tctm.AbstractThreadedTcDataLink

All Implemented Interfaces:

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

Direct Known Subclasses:

TcpTcDataLink, UdpTcDataLink

public abstract class AbstractThreadedTcDataLink
extends AbstractTcDataLink
implements Runnable

Abstract link that starts a thread when it's enabled and stops it when it's disabled.

The startUp() and shutDown() methods are called at startup/enable and shutdown/disable times on the working thread.

This class provides queueing and rate limiting function.

args:

• tcQueueSize: maximum size of the queue. If the queue is full, the commands will be rejected. If the argument is not specified, the queue will be unlimited in size.
• tcMaxRate: maximum number of commands to send per second.

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 BlockingQueue<PreparedCommand>	commandQueue

Fields inherited from class org.yamcs.tctm.AbstractTcDataLink

cmdPostProcessor, commandHistoryPublisher, dataCount, housekeepingInterval, sp_dataCount_id, sv_linkStatus_id

Fields inherited from class org.yamcs.tctm.AbstractLink

config, disabled, eventProducer, linkName, log, yamcsInstance

Constructor Summary

Constructors

Constructor	Description
AbstractThreadedTcDataLink()

Method Summary

Modifier and Type	Method	Description
protected void	doDisable()
protected void	doEnable()
protected void	doHousekeeping()	Called each AbstractTcDataLink.housekeepingInterval milliseconds, can be used to establish tcp connections or similar things
protected void	doStart()
protected void	doStop()
void	init(String yamcsInstance, String linkName, YConfiguration config)	Called at startup to initialize the link.
void	run()
void	sendTc(PreparedCommand pc)	Sends
protected abstract void	shutDown()	Called at shutdown (if the link is enabled) or when the link is disabled
protected abstract void	startUp()	Called at start up (if the link is enabled) or when the link is enabled
protected abstract void	uplinkCommand(PreparedCommand pc)	Called

Methods inherited from class org.yamcs.tctm.AbstractTcDataLink

ackCommand, failedCommand, getCurrentTime, getDataInCount, getDataOutCount, getParent, getYamcsInstance, initPostprocessor, resetCounters, setCommandHistoryPublisher, setParent

Methods inherited from class org.yamcs.tctm.AbstractLink

collectSystemParameters, connectionStatus, disable, enable, getConfig, getDetailedStatus, getEventLoop, getLinkStatus, getName, getSystemParameters, isDisabled, isRunningAndEnabled, setupSystemParameters

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, getDetailedStatus, getLinkStatus, getName, getSpec, isDisabled, setupSystemParameters

Field Detail

commandQueue

protected BlockingQueue<PreparedCommand> commandQueue

Constructor Detail

AbstractThreadedTcDataLink

public AbstractThreadedTcDataLink()

Method Detail

init

public void init(String yamcsInstance,
                 String linkName,
                 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 AbstractTcDataLink

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

Throws:

ConfigurationException

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

sendTc

public void sendTc(PreparedCommand pc)

Sends

Specified by:

sendTc in interface TcDataLink

run

public void run()

Specified by:

run in interface Runnable

doEnable

protected void doEnable()

Overrides:

doEnable in class AbstractLink

doDisable

protected void doDisable()

Overrides:

doDisable in class AbstractLink

doHousekeeping

protected void doHousekeeping()

Called each AbstractTcDataLink.housekeepingInterval milliseconds, can be used to establish tcp connections or similar things

uplinkCommand

protected abstract void uplinkCommand(PreparedCommand pc)
                               throws IOException

Called

Parameters:

pc -

Throws:

IOException

startUp

protected abstract void startUp()
                         throws Exception

Called at start up (if the link is enabled) or when the link is enabled

Throws:

Exception

shutDown

protected abstract void shutDown()
                          throws Exception

Called at shutdown (if the link is enabled) or when the link is disabled

Throws:

Exception