org.yamcs.tctm

Class FilePollingTmDataLink

java.lang.Object

com.google.common.util.concurrent.AbstractExecutionThreadService

org.yamcs.tctm.AbstractTmDataLink

org.yamcs.tctm.FilePollingTmDataLink

All Implemented Interfaces:

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

public class FilePollingTmDataLink
extends AbstractTmDataLink

Reads telemetry files from the directory yamcs.incomingDir/tm

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
FilePollingTmDataLink(String instance, String name) used when no spec is specified, the incomingDir is based on the property with the same name from the yamcs.yaml
FilePollingTmDataLink(String yamcsInstance, String name, Map<String,Object> args)
FilePollingTmDataLink(String yamcsInstance, String name, String incomingDir)

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()
Link.Status	getLinkStatus() Returns the current link status.
TmFileReader	getTmFileReader(String fileName)
boolean	isDisabled()
void	run()
void	setTmSink(TmSink tmSink) sets the tm processor that should get all the tm packets

Methods inherited from class org.yamcs.tctm.AbstractTmDataLink

getSystemParameters, initPreprocessor

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

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

Constructor Detail

FilePollingTmDataLink

public FilePollingTmDataLink(String yamcsInstance,
                             String name,
                             Map<String,Object> args)

FilePollingTmDataLink

public FilePollingTmDataLink(String yamcsInstance,
                             String name,
                             String incomingDir)

FilePollingTmDataLink

public FilePollingTmDataLink(String instance,
                             String name)
                      throws ConfigurationException

used when no spec is specified, the incomingDir is based on the property with the same name from the yamcs.yaml

Parameters:

instance -

Throws:

ConfigurationException

Method Detail

run

public void run()

Overrides:

run in class AbstractTmDataLink

getTmFileReader

public TmFileReader getTmFileReader(String fileName)
                             throws IOException

Throws:

IOException

getDetailedStatus

public String getDetailedStatus()

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

enable

public void enable()

Description copied from interface: Link

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

isDisabled

public boolean isDisabled()

getLinkStatus

public Link.Status getLinkStatus()

Description copied from interface: Link

Returns the current link status.

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

Overrides:

setTmSink in class AbstractTmDataLink

getDataCount

public long getDataCount()