org.yamcs.simulation.simulator

Class Simulator

java.lang.Object

com.google.common.util.concurrent.AbstractExecutionThreadService

org.yamcs.simulation.simulator.Simulator

All Implemented Interfaces:

com.google.common.util.concurrent.Service

public class Simulator
extends com.google.common.util.concurrent.AbstractExecutionThreadService

Nested Class Summary

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

Field Summary

Fields

Modifier and Type	Field and Description
protected BlockingQueue<CCSDSPacket>	pendingCommands

Constructor Summary

Constructors

Constructor and Description
Simulator(File dataDir, int tmPort, int tcPort, int losPort)

Method Summary

Modifier and Type	Method and Description
protected CCSDSPacket	ackPacket(CCSDSPacket commandPacket, int stage, int result)
void	deleteLosDataFile(String filename)
void	dumpLosDataFile(String filename)
Date	getLastLosStart()
Date	getLastLosStop()
LosRecorder	getLosDataRecorder() this runs in a separate thread but pushes commands to the main TM thread
boolean	isLOS()
void	processTc(CCSDSPacket tc)
protected CCSDSPacket	readLosPacket(DataInputStream dIn)
void	run()
void	setAOS()
void	setLOS()
void	setLosLink(TmTcLink losLink)
void	setTmLink(TmTcLink tmLink)
protected void	transmitTM(CCSDSPacket packet)

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

Field Detail

pendingCommands

protected BlockingQueue<CCSDSPacket> pendingCommands

Constructor Detail

Simulator

public Simulator(File dataDir,
                 int tmPort,
                 int tcPort,
                 int losPort)

Method Detail

run

public void run()

Specified by:

run in class com.google.common.util.concurrent.AbstractExecutionThreadService

getLosDataRecorder

public LosRecorder getLosDataRecorder()

this runs in a separate thread but pushes commands to the main TM thread

isLOS

public boolean isLOS()

getLastLosStart

public Date getLastLosStart()

getLastLosStop

public Date getLastLosStop()

setAOS

public void setAOS()

setLOS

public void setLOS()

transmitTM

protected void transmitTM(CCSDSPacket packet)

dumpLosDataFile

public void dumpLosDataFile(String filename)

deleteLosDataFile

public void deleteLosDataFile(String filename)

ackPacket

protected CCSDSPacket ackPacket(CCSDSPacket commandPacket,
                                int stage,
                                int result)

setTmLink

public void setTmLink(TmTcLink tmLink)

processTc

public void processTc(CCSDSPacket tc)

readLosPacket

protected CCSDSPacket readLosPacket(DataInputStream dIn)

setLosLink

public void setLosLink(TmTcLink losLink)