org.yamcs.simulator

Class Simulator

java.lang.Object

com.google.common.util.concurrent.AbstractService

org.yamcs.simulator.Simulator

All Implemented Interfaces:

com.google.common.util.concurrent.Service

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

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)
protected void	doStart()
protected void	doStop()
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	setAOS()
void	setLOS()
void	setLosLink(TcpTmTcLink losLink)
void	setTcFrameLink(UdpTcFrameLink tcFrameLink)
void	setTm2Link(TcpTmTcLink tm2Link)
void	setTmFrameLink(UdpTmFrameLink tmFrameLink)
void	setTmLink(TcpTmTcLink tmLink)
void	transmitRealtimeTM(CCSDSPacket packet)
protected void	transmitTM2(byte[] packet)

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

addListener, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, failureCause, isRunning, notifyFailed, notifyStarted, notifyStopped, startAsync, state, stopAsync, toString

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

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()

transmitRealtimeTM

public void transmitRealtimeTM(CCSDSPacket packet)

transmitTM2

protected void transmitTM2(byte[] 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(TcpTmTcLink tmLink)

setTm2Link

public void setTm2Link(TcpTmTcLink tm2Link)

processTc

public void processTc(CCSDSPacket tc)

readLosPacket

protected CCSDSPacket readLosPacket(DataInputStream dIn)

setLosLink

public void setLosLink(TcpTmTcLink losLink)

setTmFrameLink

public void setTmFrameLink(UdpTmFrameLink tmFrameLink)

setTcFrameLink

public void setTcFrameLink(UdpTcFrameLink tcFrameLink)

doStart

protected void doStart()

Specified by:

doStart in class com.google.common.util.concurrent.AbstractService

doStop

protected void doStop()

Specified by:

doStop in class com.google.common.util.concurrent.AbstractService