org.archive.io

Class ReplayInputStream

java.lang.Object

java.io.InputStream

org.archive.io.SeekInputStream

org.archive.io.ReplayInputStream

All Implemented Interfaces:

it.unimi.dsi.fastutil.io.RepositionableStream, Closeable, AutoCloseable

public class ReplayInputStream
extends SeekInputStream

Replays the bytes recorded from a RecordingInputStream or RecordingOutputStream. This InputStream supports mark and reset.

Author:

gojomo

Field Summary

Fields

Modifier and Type	Field and Description
protected File	backingFile
protected long	responseBodyStart Where the response body starts, if marked

Constructor Summary

Constructors

Constructor and Description
ReplayInputStream(byte[] buffer, long size, long responseBodyStart, String backingFilename) Constructor.
ReplayInputStream(byte[] buffer, long size, String backingFilename) Constructor.
ReplayInputStream(InputStream fillStream) Create a ReplayInputStream from the given source stream.

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
void	destroy() Close & destroy any internally-generated temporary files.
protected byte[]	getBuffer()
long	getContentSize() Total size of content.
long	getHeaderSize() Total size of header.
long	getSize() Total size of stream content.
long	position()
void	position(long p) Reposition the stream.
int	read()
int	read(byte[] b, int off, int len)
void	readContentTo(OutputStream os)
void	readContentTo(OutputStream os, long maxSize) Convenience method to copy content out to target stream.
static void	readFullyTo(InputStream in, OutputStream os)
void	readFullyTo(OutputStream os)
void	readHeaderTo(OutputStream os)
long	remaining()
long	setToResponseBodyStart()
protected void	setupDiskStream(File backingFile)

Methods inherited from class org.archive.io.SeekInputStream

mark, markSupported, reset

Methods inherited from class java.io.InputStream

available, read, skip

Methods inherited from class java.lang.Object

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

Field Detail

responseBodyStart

protected long responseBodyStart

Where the response body starts, if marked

backingFile

protected File backingFile

Constructor Detail

ReplayInputStream

public ReplayInputStream(byte[] buffer,
                 long size,
                 long responseBodyStart,
                 String backingFilename)
                  throws IOException

Constructor.

Parameters:

buffer - Buffer to read from.

size - Size of data to replay.

responseBodyStart - Start of the response body.

backingFilename - Backing file that sits behind the buffer. If size > than buffer then we go to backing file to read data that is beyond buffer.length.

Throws:

IOException - If we fail to open an input stream on backing file.

ReplayInputStream

public ReplayInputStream(byte[] buffer,
                 long size,
                 String backingFilename)
                  throws IOException

Constructor.

Parameters:

buffer - Buffer to read from.

size - Size of data to replay.

backingFilename - Backing file that sits behind the buffer. If size > than buffer then we go to backing file to read data that is beyond buffer.length.

Throws:

IOException - If we fail to open an input stream on backing file.

ReplayInputStream

public ReplayInputStream(InputStream fillStream)
                  throws IOException

Create a ReplayInputStream from the given source stream. Requires reading the entire stream (and possibly overflowing to a temporary file). Primary reason for doing so would be to have a repositionable version of the original stream's contents. If created via this constructor, use the destroy() method to ensure prompt deletion of any associated tmp file when done.

Parameters:

fillStream -

Throws:

IOException

Method Detail

setupDiskStream

protected void setupDiskStream(File backingFile)
                        throws IOException

Throws:

IOException

destroy

public void destroy()

Close & destroy any internally-generated temporary files.

setToResponseBodyStart

public long setToResponseBodyStart()
                            throws IOException

Throws:

IOException

read

public int read()
         throws IOException

Specified by:

read in class InputStream

Throws:

IOException

read

public int read(byte[] b,
       int off,
       int len)
         throws IOException

Overrides:

read in class InputStream

Throws:

IOException

readFullyTo

public void readFullyTo(OutputStream os)
                 throws IOException

Throws:

IOException

readFullyTo

public static void readFullyTo(InputStream in,
               OutputStream os)
                        throws IOException

Throws:

IOException

readHeaderTo

public void readHeaderTo(OutputStream os)
                  throws IOException

Throws:

IOException

readContentTo

public void readContentTo(OutputStream os)
                   throws IOException

Throws:

IOException

readContentTo

public void readContentTo(OutputStream os,
                 long maxSize)
                   throws IOException

Convenience method to copy content out to target stream.

Parameters:

os - stream to write content to

maxSize - maximum count of bytes to copy

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class InputStream

Throws:

IOException

getSize

public long getSize()

Total size of stream content.

Returns:

Returns the size.

getHeaderSize

public long getHeaderSize()

Total size of header.

Returns:

the size of the header.

getContentSize

public long getContentSize()

Total size of content.

Returns:

the size of the content.

remaining

public long remaining()

Returns:

Amount THEORETICALLY remaining (TODO: Its not theoretical seemingly. The class implemetentation depends on it being exact).

position

public void position(long p)
              throws IOException

Reposition the stream.

Parameters:

p - the new position for this stream

Throws:

IOException - if an IO error occurs

position

public long position()
              throws IOException

Throws:

IOException

getBuffer

protected byte[] getBuffer()