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.

Author:

nm

Constructor Summary

Constructors

Constructor and Description
YarchReplay(ReplayServer replayServer, Yamcs.ReplayRequest rr, ReplayListener listener, XtceDb xtceDb, AuthenticationToken authToken)

Method Summary

Modifier and Type	Method and Description
void	changeSpeed(Yamcs.ReplaySpeed newSpeed)
Yamcs.ReplayRequest	getCurrentReplayRequest()
Yamcs.ReplayStatus.ReplayState	getState()
void	onTuple(Stream s, Tuple t)
void	pause()
void	quit()
void	seek(long newReplayTime)
void	setRequest(Yamcs.ReplayRequest newRequest, AuthenticationToken authToken)
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 Detail

YarchReplay

public YarchReplay(ReplayServer replayServer,
                   Yamcs.ReplayRequest rr,
                   ReplayListener listener,
                   XtceDb xtceDb,
                   AuthenticationToken authToken)
            throws IOException,
                   YamcsException,
                   YamcsApiException

Throws:

IOException

YamcsException

YamcsApiException

Method Detail

setRequest

public void setRequest(Yamcs.ReplayRequest newRequest,
                       AuthenticationToken authToken)
                throws YamcsException

Throws:

YamcsException

getState

public Yamcs.ReplayStatus.ReplayState getState()

start

public void start()

seek

public void seek(long newReplayTime)
          throws YamcsException

Throws:

YamcsException

changeSpeed

public void changeSpeed(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 Yamcs.ReplayRequest getCurrentReplayRequest()