org.yamcs.web.rest

Class ParameterReplayToChunkedTransferEncoder

java.lang.Object

com.google.common.util.concurrent.Service.Listener

org.yamcs.web.rest.RestReplayListener

org.yamcs.web.rest.RestParameterReplayListener

org.yamcs.web.rest.ParameterReplayToChunkedTransferEncoder

All Implemented Interfaces:

ParameterWithIdConsumer

Direct Known Subclasses:

ParameterReplayToChunkedCSVEncoder, ParameterReplayToChunkedProtobufEncoder

public abstract class ParameterReplayToChunkedTransferEncoder
extends RestParameterReplayListener

Reads a yamcs replay and maps it directly to an output buffer. If that buffer grows larger than the treshold size for one chunk, this will cause a chunk to be written out. Could maybe be replaced by using built-in netty functionality, but would need to investigate.

Field Summary

Fields

Modifier and Type	Field and Description
protected io.netty.buffer.ByteBufOutputStream	bufOut
protected MediaType	contentType
protected boolean	failed
protected List<Yamcs.NamedObjectId>	idList

Fields inherited from class org.yamcs.web.rest.RestParameterReplayListener

req

Constructor Summary

Constructors

Constructor and Description
ParameterReplayToChunkedTransferEncoder(RestRequest req, MediaType contentType, List<Yamcs.NamedObjectId> idList)
ParameterReplayToChunkedTransferEncoder(RestRequest req, MediaType contentType, List<Yamcs.NamedObjectId> idList, String filename)

Method Summary

Modifier and Type	Method and Description
protected void	closeBufferOutputStream()
void	onParameterData(List<ParameterValueWithId> params)
abstract void	processParameterData(List<ParameterValueWithId> params, io.netty.buffer.ByteBufOutputStream bufOut)
void	replayFinished()
protected void	resetBuffer()

Methods inherited from class org.yamcs.web.rest.RestParameterReplayListener

filter, filter, replayFailed, setNoRepeat

Methods inherited from class org.yamcs.web.rest.RestReplayListener

failed, isReplayAbortRequested, onParameterData, requestReplayAbortion, terminated, update, update

Methods inherited from class com.google.common.util.concurrent.Service.Listener

running, starting, stopping

Methods inherited from class java.lang.Object

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

Field Detail

bufOut

protected io.netty.buffer.ByteBufOutputStream bufOut

contentType

protected MediaType contentType

idList

protected List<Yamcs.NamedObjectId> idList

failed

protected boolean failed

Constructor Detail

ParameterReplayToChunkedTransferEncoder

public ParameterReplayToChunkedTransferEncoder(RestRequest req,
                                               MediaType contentType,
                                               List<Yamcs.NamedObjectId> idList)
                                        throws HttpException

Throws:

HttpException

ParameterReplayToChunkedTransferEncoder

public ParameterReplayToChunkedTransferEncoder(RestRequest req,
                                               MediaType contentType,
                                               List<Yamcs.NamedObjectId> idList,
                                               String filename)
                                        throws HttpException

Throws:

HttpException

Method Detail

resetBuffer

protected void resetBuffer()

closeBufferOutputStream

protected void closeBufferOutputStream()
                                throws IOException

Throws:

IOException

onParameterData

public void onParameterData(List<ParameterValueWithId> params)

Overrides:

onParameterData in class RestReplayListener

processParameterData

public abstract void processParameterData(List<ParameterValueWithId> params,
                                          io.netty.buffer.ByteBufOutputStream bufOut)
                                   throws IOException

Throws:

IOException

replayFinished

public void replayFinished()

Overrides:

replayFinished in class RestReplayListener