com.goldencode.p2j.xml

Class SaxReaderImpl.MemptrInputStream

java.lang.Object

java.io.InputStream

com.goldencode.p2j.xml.SaxReaderImpl.MemptrInputStream

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

Enclosing class:

SaxReaderImpl

static class SaxReaderImpl.MemptrInputStream
extends java.io.InputStream

Special wrapper to wrap read from memptr in lazy mode. It's means that first try to read will check if memptr is available.

Field Summary

Fields

Modifier and Type	Field and Description
private boolean	isStarted Lazy initialization flag.
private memptr	mptr A valid memptr
private java.util.concurrent.atomic.AtomicLong	position Current read cursor position, started from index 1.
private long	totalSize total size of memptr.

Constructor Summary

Constructors

Constructor and Description
MemptrInputStream(memptr source) Constructor accepting a memptr, which will read after first call.

Method Summary

Modifier and Type	Method and Description
int	read() Reads the next byte of data from the input stream.
int	read(byte[] array, int off, int len) Read a chunk of bytes from the current read position in the stream to the offset calculated by given length or to the EOF, whichever comes first.
void	reset() Resets the input stream to begin reading from the first character of this input stream's underlying buffer.

Methods inherited from class java.io.InputStream

available, close, mark, markSupported, read, skip

Methods inherited from class java.lang.Object

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

Field Detail

isStarted

private volatile boolean isStarted

Lazy initialization flag.

mptr

private final memptr mptr

A valid memptr

position

private final java.util.concurrent.atomic.AtomicLong position

Current read cursor position, started from index 1.

totalSize

private long totalSize

total size of memptr.

Constructor Detail

MemptrInputStream

MemptrInputStream(memptr source)

Constructor accepting a memptr, which will read after first call.

Parameters:

source - A valid memptr object.

Method Detail

read

public int read()
         throws java.io.IOException

Reads the next byte of data from the input stream. The value byte is returned as an int in the range 0 to 255. If no byte is available because the end of the stream has been reached, the value -1 is returned.

Specified by:

read in class java.io.InputStream

Throws:

java.io.IOException

read

public int read(byte[] array,
                int off,
                int len)
         throws java.io.IOException

Read a chunk of bytes from the current read position in the stream to the offset calculated by given length or to the EOF, whichever comes first. The EOF character is not returned.

Overrides:

read in class java.io.InputStream

Parameters:

array - The array in which to save bytes.

off - The offset into the array at which to start saving bytes.

len - The maximum number of bytes to read.

Returns:

The number of bytes read or -1 if EOF has been reached). The number of bytes read will be the smaller of the len parameter or the actual bytes left before the EOF.

Throws:

java.io.IOException - If an I/O error occurs.

reset

public void reset()
           throws java.io.IOException

Resets the input stream to begin reading from the first character of this input stream's underlying buffer.

Overrides:

reset in class java.io.InputStream

Throws:

java.io.IOException