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.

Constructor Summary

Constructors

Constructor	Description
YarchReplay(ReplayServer replayServer, ReplayOptions rr, ReplayListener listener, XtceDb xtceDb)

Method Summary

Modifier and Type	Method	Description
void	changeSpeed(org.yamcs.protobuf.Yamcs.ReplaySpeed newSpeed)
org.yamcs.protobuf.Yamcs.ReplayRequest	getCurrentReplayRequest()
org.yamcs.protobuf.Yamcs.ReplayStatus.ReplayState	getState()
void	onTuple(Stream s, Tuple t)
void	pause()
void	quit()
void	seek(long newReplayTime)
void	start()
void	streamClosed(Stream stream)

Methods inherited from class java.lang.Object

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

Constructor Details

YarchReplay

public YarchReplay(ReplayServer replayServer,
 ReplayOptions rr,
 ReplayListener listener,
 XtceDb xtceDb)
            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)
          throws YamcsException

Throws:

YamcsException

changeSpeed

public void changeSpeed(org.yamcs.protobuf.Yamcs.ReplaySpeed newSpeed)

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 org.yamcs.protobuf.Yamcs.ReplayRequest getCurrentReplayRequest()