org.apache.ignite.internal.portable.streams

Class PortableOffheapInputStream

java.lang.Object

org.apache.ignite.internal.portable.streams.PortableAbstractStream

org.apache.ignite.internal.portable.streams.PortableAbstractInputStream

org.apache.ignite.internal.portable.streams.PortableOffheapInputStream

All Implemented Interfaces:

PortableInputStream, PortableStream

public class PortableOffheapInputStream
extends PortableAbstractInputStream

Portable off-heap input stream.

Field Summary

Fields inherited from class org.apache.ignite.internal.portable.streams.PortableAbstractInputStream

len

Fields inherited from class org.apache.ignite.internal.portable.streams.PortableAbstractStream

BOOLEAN_ARR_OFF, BYTE_ARR_OFF, BYTE_ONE, BYTE_ZERO, CHAR_ARR_OFF, DOUBLE_ARR_OFF, FLOAT_ARR_OFF, INT_ARR_OFF, LITTLE_ENDIAN, LONG_ARR_OFF, pos, SHORT_ARR_OFF, UNSAFE

Constructor Summary

Constructors

Constructor and Description
PortableOffheapInputStream(long ptr, int cap) Constructor.
PortableOffheapInputStream(long ptr, int cap, boolean forceHeap) Constructor.

Method Summary

Methods

Modifier and Type	Method and Description
byte[]	array()
byte[]	arrayCopy()
protected void	copyAndShift(Object target, long off, int len) Copy data to target object shift position afterwards.
boolean	hasArray()
long	offheapPointer()
protected byte	readByteAndShift() Read next byte from the stream and perform shift.
protected char	readCharFast() Read char value (fast path).
protected int	readIntFast() Read int value (fast path).
protected int	readIntPositioned(int pos) Internal routine for positioned int value read.
protected long	readLongFast() Read long value (fast path).
protected short	readShortFast() Read short value (fast path).
int	remaining() Gets amount of remaining data in bytes.

Methods inherited from class org.apache.ignite.internal.portable.streams.PortableAbstractInputStream

ensureEnoughData, position, read, readBoolean, readBooleanArray, readByte, readByteArray, readChar, readCharArray, readDouble, readDoubleArray, readFloat, readFloatArray, readInt, readInt, readIntArray, readLong, readLongArray, readShort, readShortArray

Methods inherited from class org.apache.ignite.internal.portable.streams.PortableAbstractStream

position, shift

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.ignite.internal.portable.streams.PortableStream

position

Constructor Detail

PortableOffheapInputStream

public PortableOffheapInputStream(long ptr,
                          int cap)

Constructor.

Parameters:

ptr - Pointer.

cap - Capacity.

PortableOffheapInputStream

public PortableOffheapInputStream(long ptr,
                          int cap,
                          boolean forceHeap)

Constructor.

Parameters:

ptr - Pointer.

cap - Capacity.

forceHeap - If true method offheapPointer() returns 0 and unmarshalling will create heap-based objects.

Method Detail

remaining

public int remaining()

Gets amount of remaining data in bytes.

Returns:

Remaining data.

array

public byte[] array()

Returns:

Underlying array.

arrayCopy

public byte[] arrayCopy()

Returns:

Copy of data in the stream.

hasArray

public boolean hasArray()

Returns:

True is stream is array based.

readByteAndShift

protected byte readByteAndShift()

Read next byte from the stream and perform shift.

Specified by:

readByteAndShift in class PortableAbstractInputStream

Returns:

Next byte.

copyAndShift

protected void copyAndShift(Object target,
                long off,
                int len)

Copy data to target object shift position afterwards.

Specified by:

copyAndShift in class PortableAbstractInputStream

Parameters:

target - Target.

off - Offset.

len - Length.

readShortFast

protected short readShortFast()

Read short value (fast path).

Specified by:

readShortFast in class PortableAbstractInputStream

Returns:

Short value.

readCharFast

protected char readCharFast()

Read char value (fast path).

Specified by:

readCharFast in class PortableAbstractInputStream

Returns:

Char value.

readIntFast

protected int readIntFast()

Read int value (fast path).

Specified by:

readIntFast in class PortableAbstractInputStream

Returns:

Int value.

readLongFast

protected long readLongFast()

Read long value (fast path).

Specified by:

readLongFast in class PortableAbstractInputStream

Returns:

Long value.

readIntPositioned

protected int readIntPositioned(int pos)

Internal routine for positioned int value read.

Specified by:

readIntPositioned in class PortableAbstractInputStream

Parameters:

pos - Position.

Returns:

Int value.

offheapPointer

public long offheapPointer()

Specified by:

offheapPointer in interface PortableStream

Overrides:

offheapPointer in class PortableAbstractInputStream

Returns:

Offheap pointer if stream is offheap based, otherwise 0.