Package org.yamcs.simulation

Class 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

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method 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

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