org.yamcs.tctm

Class TcpTcDataLink

java.lang.Object

com.google.common.util.concurrent.AbstractService

org.yamcs.tctm.TcpTcDataLink

All Implemented Interfaces:

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

public class TcpTcDataLink
extends com.google.common.util.concurrent.AbstractService
implements Runnable, TcDataLink, SystemParametersProducer

Sends raw packets on Tcp socket.

Author:

nm

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	TcpTcDataLink.TcAckStatus

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 and Description
protected CommandHistoryPublisher	commandHistoryListener
protected BlockingQueue<PreparedCommand>	commandQueue
protected boolean	disabled
protected String	host
protected org.slf4j.Logger	log
protected int	minimumTcPacketLength
protected int	port
protected Selector	selector
protected CcsdsSeqAndChecksumFiller	seqAndChecksumFiller
protected SocketChannel	socketChannel
protected long	tcCount
protected ScheduledThreadPoolExecutor	timer

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	TcpTcDataLink()
	TcpTcDataLink(String host, int port)
	TcpTcDataLink(String yamcsInstance, String name, String spec)

Method Summary

Modifier and Type	Method and Description
void	disable() Disable any data I/O through this link.
protected void	disconnect()
protected void	doStart()
void	doStop()
void	enable() Reenable the data transit if disabled by the disable() method.
protected long	getCurrentTime()
long	getDataCount()
String	getDetailedStatus()
Link.Status	getLinkStatus() Returns the current link status.
int	getMiniminimumTcPacketLength()
Collection<ParameterValue>	getSystemParameters() return the next bunch of parameter values.
boolean	isDisabled()
protected boolean	isSocketOpen() we check if the socket is open by trying a select on the read part of it
protected void	openSocket()
void	run()
void	sendTc(PreparedCommand pc) Sends
void	setCommandHistoryPublisher(CommandHistoryPublisher commandHistoryListener)
protected void	setupSysVariables()

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 com.google.common.util.concurrent.Service

addListener, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, failureCause, isRunning, startAsync, state, stopAsync

Field Detail

socketChannel

protected SocketChannel socketChannel

host

protected String host

port

protected int port

commandHistoryListener

protected CommandHistoryPublisher commandHistoryListener

selector

protected Selector selector

seqAndChecksumFiller

protected CcsdsSeqAndChecksumFiller seqAndChecksumFiller

timer

protected ScheduledThreadPoolExecutor timer

disabled

protected volatile boolean disabled

minimumTcPacketLength

protected int minimumTcPacketLength

commandQueue

protected BlockingQueue<PreparedCommand> commandQueue

tcCount

protected volatile long tcCount

log

protected final org.slf4j.Logger log

Constructor Detail

TcpTcDataLink

public TcpTcDataLink(String yamcsInstance,
                     String name,
                     String spec)
              throws ConfigurationException

Throws:

ConfigurationException

TcpTcDataLink

protected TcpTcDataLink()

TcpTcDataLink

public TcpTcDataLink(String host,
                     int port)

Method Detail

getCurrentTime

protected long getCurrentTime()

doStart

protected void doStart()

Specified by:

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

openSocket

protected void openSocket()

disconnect

protected void disconnect()

isSocketOpen

protected boolean isSocketOpen()

we check if the socket is open by trying a select on the read part of it

Returns:

sendTc

public void sendTc(PreparedCommand pc)

Sends

Specified by:

sendTc in interface TcDataLink

setCommandHistoryPublisher

public void setCommandHistoryPublisher(CommandHistoryPublisher commandHistoryListener)

Specified by:

setCommandHistoryPublisher in interface TcDataLink

getLinkStatus

public Link.Status getLinkStatus()

Description copied from interface: Link

Returns the current link status.

Specified by:

getLinkStatus in interface Link

getDetailedStatus

public String getDetailedStatus()

Specified by:

getDetailedStatus in interface Link

Returns:

more detailed status information

disable

public void disable()

Description copied from interface: Link

Disable any data I/O through this link. Any connection to a server is closed. Can be reenabled using the enable method. Note that this method can be called before starting the service if it's configured as such in the configuration file

Specified by:

disable in interface Link

enable

public void enable()

Description copied from interface: Link

Reenable the data transit if disabled by the disable() method.

Specified by:

enable in interface Link

isDisabled

public boolean isDisabled()

Specified by:

isDisabled in interface Link

run

public void run()

Specified by:

run in interface Runnable

doStop

public void doStop()

Specified by:

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

getDataCount

public long getDataCount()

Specified by:

getDataCount in interface Link

setupSysVariables

protected void setupSysVariables()

getSystemParameters

public Collection<ParameterValue> getSystemParameters()

Description copied from interface: SystemParametersProducer

return the next bunch of parameter values. The values must contain a reference to a Parameter (i.e. parameter definition) and that Parameter does not need to be coming from the XtceDB - the provider can just make it up on the fly.

Specified by:

getSystemParameters in interface SystemParametersProducer

getMiniminimumTcPacketLength

public int getMiniminimumTcPacketLength()