Package 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
ConstructorDescriptionUdpTmFrameLink
(String frameType, String host, int port, int frameLength, double framesPerSec, IntSupplier clcwSupplier) -
Method Summary
Modifier and TypeMethodDescriptionvoid
queuePacket
(int vcId, byte[] packet) queue packet for virtual channelprotected void
protected com.google.common.util.concurrent.AbstractScheduledService.Scheduler
protected void
startUp()
Methods inherited from class com.google.common.util.concurrent.AbstractScheduledService
addListener, awaitRunning, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, awaitTerminated, executor, failureCause, isRunning, serviceName, shutDown, startAsync, state, stopAsync, toString
-
Constructor Details
-
UdpTmFrameLink
public UdpTmFrameLink(String frameType, String host, int port, int frameLength, double framesPerSec, IntSupplier clcwSupplier)
-
-
Method Details
-
startUp
- Overrides:
startUp
in classcom.google.common.util.concurrent.AbstractScheduledService
- Throws:
Exception
-
scheduler
protected com.google.common.util.concurrent.AbstractScheduledService.Scheduler scheduler()- Specified by:
scheduler
in classcom.google.common.util.concurrent.AbstractScheduledService
-
runOneIteration
- Specified by:
runOneIteration
in classcom.google.common.util.concurrent.AbstractScheduledService
- Throws:
Exception
-
queuePacket
public void queuePacket(int vcId, byte[] packet) queue packet for virtual channel- Parameters:
vcId
-packet
-
-