Package 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
-
-
Field Summary
Fields Modifier and Type Field Description protected BlockingQueue<CCSDSPacket>pendingCommands
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected CCSDSPacketackPacket(CCSDSPacket commandPacket, int stage, int result)voiddeleteLosDataFile(String filename)protected voiddoStart()protected voiddoStop()voiddumpLosDataFile(String filename)DategetLastLosStart()DategetLastLosStop()LosRecordergetLosDataRecorder()this runs in a separate thread but pushes commands to the main TM threadbooleanisLOS()voidprocessTc(CCSDSPacket tc)protected CCSDSPacketreadLosPacket(DataInputStream dIn)voidsetAOS()voidsetLOS()voidsetLosLink(TcpTmTcLink losLink)voidsetTcFrameLink(UdpTcFrameLink tcFrameLink)voidsetTm2Link(TcpTmTcLink tm2Link)voidsetTmFrameLink(UdpTmFrameLink tmFrameLink)voidsetTmLink(TcpTmTcLink tmLink)voidtransmitRealtimeTM(CCSDSPacket packet)protected voidtransmitTM2(byte[] packet)
-
-
-
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:
doStartin classcom.google.common.util.concurrent.AbstractService
-
doStop
protected void doStop()
- Specified by:
doStopin classcom.google.common.util.concurrent.AbstractService
-
-