Module org.yamcs.core

Package org.yamcs.archive

Class YarchReplay

java.lang.Object

org.yamcs.archive.YarchReplay

All Implemented Interfaces:

StreamSubscriber

public class YarchReplay
extends Object
implements StreamSubscriber

Performs a replay from Yarch So far supported are: TM packets, PP groups, Events, Parameters and Command History.

It relies on handlers for each data type. Each handler creates a stream, the streams are merged and the output is sent to the listener This class can also handle pause/resume: simply stop sending data seek: closes the streams and creates new ones with a different starting time.

Field Summary

Fields

Modifier and Type	Field	Description
static final long	MAX_WAIT_TIME	maximum time to wait if SPEED is ORIGINAL meaning that if there is a gap in the data longer than this, we continue)

Constructor Summary

Constructors

Constructor	Description
YarchReplay(ReplayServer replayServer, ReplayOptions rr, ReplayListener listener, Mdb mdb)

Method Summary

Modifier and Type	Method	Description
void	changeEndAction(org.yamcs.protobuf.Yamcs.EndAction endAction)
void	changeRange(long start, long stop)
void	changeSpeed(SpeedSpec newSpeed)
ReplayOptions	getCurrentReplayRequest()
long	getReplayTime()
org.yamcs.protobuf.Yamcs.ReplayStatus.ReplayState	getState()
void	onTuple(Stream s, Tuple t)
void	pause()
void	quit()
void	seek(long newReplayTime, boolean autostart)
void	start()
void	streamClosed(Stream stream)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

MAX_WAIT_TIME

public static final long MAX_WAIT_TIME

maximum time to wait if SPEED is ORIGINAL meaning that if there is a gap in the data longer than this, we continue)

See Also:

• Constant Field Values

Constructor Details

YarchReplay

public YarchReplay(ReplayServer replayServer,
 ReplayOptions rr,
 ReplayListener listener,
 Mdb mdb)
            throws YamcsException

Throws:

YamcsException

Method Details

getState

public org.yamcs.protobuf.Yamcs.ReplayStatus.ReplayState getState()

start

public void start()

seek

public void seek(long newReplayTime,
 boolean autostart)
          throws YamcsException

Throws:

YamcsException

changeRange

public void changeRange(long start,
 long stop)
                 throws YamcsException

Throws:

YamcsException

changeSpeed

public void changeSpeed(SpeedSpec newSpeed)

changeEndAction

public void changeEndAction(org.yamcs.protobuf.Yamcs.EndAction endAction)

pause

public void pause()

quit

public void quit()

onTuple

public void onTuple(Stream s,
 Tuple t)

Specified by:

onTuple in interface StreamSubscriber

streamClosed

public void streamClosed(Stream stream)

Specified by:

streamClosed in interface StreamSubscriber

getCurrentReplayRequest

public ReplayOptions getCurrentReplayRequest()

getReplayTime

public long getReplayTime()