Package org.yamcs.tctm.ccsds

Class TcPacketHandler

java.lang.Object

com.google.common.util.concurrent.AbstractService

org.yamcs.tctm.AbstractLink

org.yamcs.tctm.AbstractTcDataLink

org.yamcs.tctm.ccsds.TcPacketHandler

All Implemented Interfaces:

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

public class TcPacketHandler
extends AbstractTcDataLink
implements VcUplinkHandler

Assembles command packets into TC frames as per CCSDS 232.0-B-3.

All frames have the bypass flag set (i.e. they are BD frames).

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, timeService, yamcsInstance

Constructor Summary

Constructors

Constructor	Description
TcPacketHandler(String yamcsInstance, String linkName, TcManagedParameters.TcVcManagedParameters vmp)

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
protected void	doStart()
protected void	doStop()
long	getFirstFrameTimestamp()	Returns the timestamp of the first frame ready to be dispatched or TimeEncoding.INVALID_INSTANT if there is no frame.
TcTransferFrame	getFrame()	Retrieves the next frame in the Virtual Channel, or returns null if there is no frame available at the moment.
VcUplinkManagedParameters	getParameters()	return the virtual channel parameters
void	sendTc(PreparedCommand preparedCommand)
void	setDataAvailableSemaphore(Semaphore dataAvailableSemaphore)	The semaphore will be used by the virtual channel to signal to MasterChannelFrameMultiplexer that data is available to be uplinked

Methods inherited from class org.yamcs.tctm.AbstractTcDataLink

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

Methods inherited from class org.yamcs.tctm.AbstractLink

collectSystemParameters, disable, doDisable, doEnable, 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

TcPacketHandler

public TcPacketHandler(String yamcsInstance,
                       String linkName,
                       TcManagedParameters.TcVcManagedParameters vmp)
                throws ConfigurationException

Throws:

ConfigurationException

Method Detail

sendTc

public void sendTc(PreparedCommand preparedCommand)

Specified by:

sendTc in interface TcDataLink

getFrame

public TcTransferFrame getFrame()

Description copied from interface: VcUplinkHandler

Retrieves the next frame in the Virtual Channel, or returns null if there is no frame available at the moment.

Specified by:

getFrame in interface VcUplinkHandler

Returns:

getFirstFrameTimestamp

public long getFirstFrameTimestamp()

Description copied from interface: VcUplinkHandler

Returns the timestamp of the first frame ready to be dispatched or TimeEncoding.INVALID_INSTANT if there is no frame.

The timestamp is used by the MasterChannelFrameMultiplexer to select the Virtual Channel from which the next frame is sent in case of FIFO priority scheme.

Specified by:

getFirstFrameTimestamp in interface VcUplinkHandler

Returns:

getParameters

public VcUplinkManagedParameters getParameters()

Description copied from interface: VcUplinkHandler

return the virtual channel parameters

Specified by:

getParameters in interface VcUplinkHandler

Returns:

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

setDataAvailableSemaphore

public void setDataAvailableSemaphore(Semaphore dataAvailableSemaphore)

Description copied from interface: VcUplinkHandler

The semaphore will be used by the virtual channel to signal to MasterChannelFrameMultiplexer that data is available to be uplinked

Specified by:

setDataAvailableSemaphore in interface VcUplinkHandler

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