Package org.nustaq.serialization.util

Class FSTInputStream

java.lang.Object

java.io.InputStream

org.nustaq.serialization.util.FSTInputStream

All Implemented Interfaces:

Closeable, AutoCloseable

public final class FSTInputStream
extends InputStream

Created with IntelliJ IDEA. User: ruedi Date: 27.11.12 Time: 00:35 To change this template use File | Settings | File Templates.

Field Summary

Fields

Modifier and Type	Field	Description
byte[]	buf
boolean	byteBacked
static ThreadLocal<byte[]>	cachedBuffer
int	chunk_size
int	count
int	pos
static boolean	REPORT_READ_FAILS

Constructor Summary

Constructors

Constructor	Description
FSTInputStream(byte[] buf)
FSTInputStream(byte[] buf, int offset, int length)
FSTInputStream(InputStream in)

Method Summary

Modifier and Type	Method	Description
int	available()
void	close()
void	ensureCapacity(int siz)
void	ensureReadAhead(int bytes)
void	initFromStream(InputStream in)
boolean	isFullyRead()
void	mark(int readAheadLimit)
boolean	markSupported()
int	read()
int	read(byte[] b, int off, int len)
void	readNextChunk(InputStream in)
void	reset()
void	resetForReuse(byte[] b, int length)
long	skip(long n)

Methods inherited from class java.io.InputStream

nullInputStream, read, readAllBytes, readNBytes, readNBytes, skipNBytes, transferTo

Methods inherited from class java.lang.Object

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

Field Details

REPORT_READ_FAILS

public static boolean REPORT_READ_FAILS

chunk_size

public int chunk_size

cachedBuffer

public static ThreadLocal<byte[]> cachedBuffer

buf

public byte[] buf

pos

public int pos

count

public int count

byteBacked

public boolean byteBacked

Constructor Details

FSTInputStream

public FSTInputStream(InputStream in)

FSTInputStream

public FSTInputStream(byte[] buf)

FSTInputStream

public FSTInputStream(byte[] buf, int offset, int length)

Method Details

resetForReuse

public void resetForReuse(byte[] b, int length)

initFromStream

public void initFromStream(InputStream in)

isFullyRead

public boolean isFullyRead()

readNextChunk

public void readNextChunk(InputStream in)

ensureCapacity

public void ensureCapacity(int siz)

read

public int read()

Specified by:

read in class InputStream

read

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

Overrides:

read in class InputStream

skip

public long skip(long n)

Overrides:

skip in class InputStream

available

public int available()

Overrides:

available in class InputStream

markSupported

public boolean markSupported()

Overrides:

markSupported in class InputStream

mark

public void mark(int readAheadLimit)

Overrides:

mark in class InputStream

reset

public void reset()

Overrides:

reset in class InputStream

close

public void close() throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class InputStream

Throws:

IOException

ensureReadAhead

public void ensureReadAhead(int bytes)