org.yamcs.simulator

Class UdpTmFrameLink

java.lang.Object

com.google.common.util.concurrent.AbstractScheduledService

org.yamcs.simulator.UdpTmFrameLink

All Implemented Interfaces:

com.google.common.util.concurrent.Service

public class UdpTmFrameLink
extends com.google.common.util.concurrent.AbstractScheduledService

Simulator link implementing the TM frames using one of the three CCSDS specs: AOS CCSDS 732.0-B-3 TM CCSDS 132.0-B-2 USLP CCSDS 732.1-B-1 Sends frames of predefined size at a configured frequency. If there is no data to send, it sends idle frames.

Nested Class Summary

Nested classes/interfaces inherited from class com.google.common.util.concurrent.AbstractScheduledService

com.google.common.util.concurrent.AbstractScheduledService.CustomScheduler, com.google.common.util.concurrent.AbstractScheduledService.Scheduler

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
UdpTmFrameLink(String frameType, String host, int port, int frameLength, double framesPerSec, IntSupplier clcwSupplier)

Method Summary

Modifier and Type	Method and Description
void	queuePacket(int vcId, byte[] packet) queue packet for virtual channel
protected void	runOneIteration()
protected com.google.common.util.concurrent.AbstractScheduledService.Scheduler	scheduler()
protected void	startUp()

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

addListener, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, executor, failureCause, isRunning, serviceName, shutDown, startAsync, state, stopAsync, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

UdpTmFrameLink

public UdpTmFrameLink(String frameType,
                      String host,
                      int port,
                      int frameLength,
                      double framesPerSec,
                      IntSupplier clcwSupplier)

Method Detail

startUp

protected void startUp()
                throws Exception

Overrides:

startUp in class com.google.common.util.concurrent.AbstractScheduledService

Throws:

Exception

scheduler

protected com.google.common.util.concurrent.AbstractScheduledService.Scheduler scheduler()

Specified by:

scheduler in class com.google.common.util.concurrent.AbstractScheduledService

runOneIteration

protected void runOneIteration()
                        throws Exception

Specified by:

runOneIteration in class com.google.common.util.concurrent.AbstractScheduledService

Throws:

Exception

queuePacket

public void queuePacket(int vcId,
                        byte[] packet)

queue packet for virtual channel

Parameters:

vcId -

packet -