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

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

    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

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
  • Constructor Details

    • UdpTmFrameLink

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

    • 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 -