Package org.yamcs.simulator

Class ColSimulator

java.lang.Object

com.google.common.util.concurrent.AbstractService

org.yamcs.simulator.AbstractSimulator

org.yamcs.simulator.ColSimulator

All Implemented Interfaces:

com.google.common.util.concurrent.Service

public class ColSimulator
extends AbstractSimulator

Simulator working with Columbus/ISS kind of packet structure

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	Description
protected BlockingQueue<ColumbusCcsdsPacket>	pendingCommands

Constructor Summary

Constructors

Constructor	Description
ColSimulator(File losDir, File dataDir)

Method Summary

Modifier and Type	Method	Description
protected ColumbusCcsdsPacket	ackPacket(ColumbusCcsdsPacket 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(SimulatorCcsdsPacket tc)
protected ColumbusCcsdsPacket	readLosPacket(DataInputStream dIn)
void	setAOS()
void	setCfdpSender(CfdpSender cfdpSender)
void	setLOS()
void	setLosLink(TcpTmTcLink losLink)
void	setPerfPacketGenerator(PerfPacketGenerator ppg)
void	setTcFrameLink(UdpTcFrameLink tcFrameLink)
void	setTm2Link(TcpTmTcLink tm2Link)
void	setTmFrameLink(UdpTmFrameLink tmFrameLink)
void	setTmLink(TcpTmTcLink tmLink)
void	transmitCfdp(CfdpPacket packet)
void	transmitRealtimeTM(SimulatorCcsdsPacket packet)
protected void	transmitTM2(byte[] packet)

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

addListener, awaitRunning, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, awaitTerminated, doCancelStart, 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 Details

pendingCommands

protected BlockingQueue<ColumbusCcsdsPacket> pendingCommands

Constructor Details

ColSimulator

public ColSimulator(File losDir,
 File dataDir)

Method Details

setCfdpSender

public void setCfdpSender(CfdpSender cfdpSender)

Overrides:

setCfdpSender in class AbstractSimulator

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

transmitTM2

protected void transmitTM2(byte[] packet)

dumpLosDataFile

public void dumpLosDataFile(String filename)

deleteLosDataFile

public void deleteLosDataFile(String filename)

ackPacket

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

setTmLink

public void setTmLink(TcpTmTcLink tmLink)

Specified by:

setTmLink in class AbstractSimulator

setTm2Link

public void setTm2Link(TcpTmTcLink tm2Link)

Specified by:

setTm2Link in class AbstractSimulator

processTc

public void processTc(SimulatorCcsdsPacket tc)

Specified by:

processTc in class AbstractSimulator

readLosPacket

protected ColumbusCcsdsPacket readLosPacket(DataInputStream dIn)

setLosLink

public void setLosLink(TcpTmTcLink losLink)

Specified by:

setLosLink in class AbstractSimulator

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

transmitCfdp

public void transmitCfdp(CfdpPacket packet)

Specified by:

transmitCfdp in class AbstractSimulator

setPerfPacketGenerator

public void setPerfPacketGenerator(PerfPacketGenerator ppg)