org.yamcs.tctm

Class TcpTmDataLink

java.lang.Object

com.google.common.util.concurrent.AbstractExecutionThreadService

org.yamcs.tctm.TcpTmDataLink

All Implemented Interfaces:

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

public class TcpTmDataLink
extends com.google.common.util.concurrent.AbstractExecutionThreadService
implements TmPacketDataLink, SystemParametersProducer

Nested Class Summary

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 boolean	disabled
protected String	host
protected org.slf4j.Logger	log
protected long	packetcount
protected int	port
protected TimeService	timeService
protected Socket	tmSocket

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	TcpTmDataLink(String instance, String name)
	TcpTmDataLink(String instance, String name, String spec)

Method Summary

Modifier and Type	Method and Description
void	disable() Disable any data I/O through this link.
void	enable() Reenable the data transit if disabled by the disable() method.
long	getDataCount()
String	getDetailedStatus()
String	getLinkStatus() Returns one of "OK" or "UNAVAIL".
PacketWithTime	getNextPacket()
Collection<ParameterValue>	getSystemParameters()
boolean	isDisabled()
protected void	openSocket()
protected boolean	readWithBlocking(byte[] b, int pos, int n) Read n bytes from the tmSocket, blocking if necessary till all bytes are available.
void	run()
void	setTmSink(TmSink tmSink) sets the tm processor that should get all the tm packets
protected void	setupSysVariables()
void	triggerShutdown()

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

addListener, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, executor, failureCause, isRunning, serviceName, shutDown, startAsync, startUp, 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

packetcount

protected volatile long packetcount

tmSocket

protected Socket tmSocket

host

protected String host

port

protected int port

disabled

protected volatile boolean disabled

log

protected final org.slf4j.Logger log

timeService

protected final TimeService timeService

Constructor Detail

TcpTmDataLink

protected TcpTmDataLink(String instance,
                        String name)

TcpTmDataLink

public TcpTmDataLink(String instance,
                     String name,
                     String spec)
              throws ConfigurationException

Throws:

ConfigurationException

Method Detail

openSocket

protected void openSocket()
                   throws IOException

Throws:

IOException

setTmSink

public void setTmSink(TmSink tmSink)

Description copied from interface: TmPacketDataLink

sets the tm processor that should get all the tm packets

Specified by:

setTmSink in interface TmPacketDataLink

run

public void run()

Specified by:

run in class com.google.common.util.concurrent.AbstractExecutionThreadService

getNextPacket

public PacketWithTime getNextPacket()

readWithBlocking

protected boolean readWithBlocking(byte[] b,
                                   int pos,
                                   int n)
                            throws IOException

Read n bytes from the tmSocket, blocking if necessary till all bytes are available. Returns true if all the bytes have been read and false if the stream has closed before all the bytes have been read.

Parameters:

b -

n -

Returns:

Throws:

IOException

getLinkStatus

public String getLinkStatus()

Description copied from interface: Link

Returns one of "OK" or "UNAVAIL". It's sure what the difference between uplink status and forward link status is.

Specified by:

getLinkStatus in interface Link

Returns:

triggerShutdown

public void triggerShutdown()

Overrides:

triggerShutdown in class com.google.common.util.concurrent.AbstractExecutionThreadService

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

getDetailedStatus

public String getDetailedStatus()

Specified by:

getDetailedStatus in interface Link

Returns:

more detailed status information

getDataCount

public long getDataCount()

Specified by:

getDataCount in interface Link

setupSysVariables

protected void setupSysVariables()

getSystemParameters

public Collection<ParameterValue> getSystemParameters()

Specified by:

getSystemParameters in interface SystemParametersProducer