org.apache.ignite.internal.portable.streams

Class PortableOffheapOutputStream

java.lang.Object

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

org.apache.ignite.internal.portable.streams.PortableAbstractOutputStream

org.apache.ignite.internal.portable.streams.PortableOffheapOutputStream

All Implemented Interfaces:

AutoCloseable, PortableOutputStream, PortableStream

public class PortableOffheapOutputStream
extends PortableAbstractOutputStream

Portable offheap output stream.

Field Summary

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
PortableOffheapOutputStream(int cap) Constructor.
PortableOffheapOutputStream(long ptr, int cap) Constructor.

Method Summary

Methods

Modifier and Type	Method and Description
protected long	allocate(int cap) Allocate memory.
byte[]	array()
byte[]	arrayCopy()
int	capacity()
void	close() Close the stream releasing resources.
protected void	copyAndShift(Object src, long offset, int len) Copy source object to the stream shift position afterwards.
void	ensureCapacity(int cnt) Ensure capacity.
boolean	hasArray()
long	pointer()
protected long	reallocate(long ptr, int cap) Reallocate memory.
protected void	release(long ptr) Release memory.
protected void	writeByteAndShift(byte val) Write next byte to the stream.
protected void	writeCharFast(char val) Write char value (fast path).
protected void	writeIntFast(int val) Write int value (fast path).
protected void	writeIntPositioned(int pos, int val) Write int value to the given position.
protected void	writeLongFast(long val) Write long value (fast path).
protected void	writeShortFast(short val) Write short value (fast path).

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

capacity, offheapPointer, position, write, write, writeBoolean, writeBooleanArray, writeByte, writeByteArray, writeChar, writeCharArray, writeDouble, writeDoubleArray, writeFloat, writeFloatArray, writeInt, writeInt, writeIntArray, writeLong, writeLongArray, writeShort, writeShortArray

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

PortableOffheapOutputStream

public PortableOffheapOutputStream(int cap)

Constructor.

Parameters:

cap - Capacity.

PortableOffheapOutputStream

public PortableOffheapOutputStream(long ptr,
                           int cap)

Constructor.

Parameters:

ptr - Pointer to existing address.

cap - Capacity.

Method Detail

close

public void close()

Close the stream releasing resources.

ensureCapacity

public void ensureCapacity(int cnt)

Ensure capacity.

Specified by:

ensureCapacity in class PortableAbstractOutputStream

Parameters:

cnt - Required byte count.

array

public byte[] array()

Returns:

Underlying array.

arrayCopy

public byte[] arrayCopy()

Returns:

Copy of data in the stream.

pointer

public long pointer()

Returns:

Pointer.

capacity

public int capacity()

Returns:

Capacity.

writeByteAndShift

protected void writeByteAndShift(byte val)

Write next byte to the stream.

Specified by:

writeByteAndShift in class PortableAbstractOutputStream

Parameters:

val - Value.

copyAndShift

protected void copyAndShift(Object src,
                long offset,
                int len)

Copy source object to the stream shift position afterwards.

Specified by:

copyAndShift in class PortableAbstractOutputStream

Parameters:

src - Source.

offset - Offset.

len - Length.

writeShortFast

protected void writeShortFast(short val)

Write short value (fast path).

Specified by:

writeShortFast in class PortableAbstractOutputStream

Parameters:

val - Short value.

writeCharFast

protected void writeCharFast(char val)

Write char value (fast path).

Specified by:

writeCharFast in class PortableAbstractOutputStream

Parameters:

val - Char value.

writeIntFast

protected void writeIntFast(int val)

Write int value (fast path).

Specified by:

writeIntFast in class PortableAbstractOutputStream

Parameters:

val - Int value.

writeLongFast

protected void writeLongFast(long val)

Write long value (fast path).

Specified by:

writeLongFast in class PortableAbstractOutputStream

Parameters:

val - Long value.

writeIntPositioned

protected void writeIntPositioned(int pos,
                      int val)

Write int value to the given position.

Specified by:

writeIntPositioned in class PortableAbstractOutputStream

Parameters:

pos - Position.

val - Value.

hasArray

public boolean hasArray()

Returns:

True is stream is array based.

allocate

protected long allocate(int cap)

Allocate memory.

Parameters:

cap - Capacity.

Returns:

Pointer.

reallocate

protected long reallocate(long ptr,
              int cap)

Reallocate memory.

Parameters:

ptr - Old pointer.

cap - Capacity.

Returns:

New pointer.

release

protected void release(long ptr)

Release memory.

Parameters:

ptr - Pointer.