org.yamcs.tctm

Class AbstractTmDataLink

java.lang.Object

com.google.common.util.concurrent.AbstractExecutionThreadService

org.yamcs.tctm.AbstractTmDataLink

All Implemented Interfaces:

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

Direct Known Subclasses:

FilePollingTmDataLink, TcpTmDataLink, UdpTmDataLink

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

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

Constructor Summary

Constructors

Constructor and Description
AbstractTmDataLink()

Method Summary

Modifier and Type	Method and Description
Collection<ParameterValue>	getSystemParameters() return the next bunch of parameter values.
protected void	initPreprocessor(String instance, Map<String,Object> args)
protected void	run()
void	setTmSink(TmSink tmSink) sets the tm processor that should get all the tm packets

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, triggerShutdown

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, getDataCount, getDetailedStatus, getLinkStatus, isDisabled

Methods inherited from interface com.google.common.util.concurrent.Service

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

Constructor Detail

AbstractTmDataLink

public AbstractTmDataLink()

Method Detail

initPreprocessor

protected void initPreprocessor(String instance,
                                Map<String,Object> args)

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

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

protected void run()
            throws Exception

Specified by:

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

Throws:

Exception