org.apache.ignite.internal.portable.streams

Class PortableAbstractOutputStream

java.lang.Object

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

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

All Implemented Interfaces:

AutoCloseable, PortableOutputStream, PortableStream

Direct Known Subclasses:

PortableHeapOutputStream, PortableOffheapOutputStream

public abstract class PortableAbstractOutputStream
extends PortableAbstractStream
implements PortableOutputStream

Base portable 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
PortableAbstractOutputStream()

Method Summary

Methods

Modifier and Type	Method and Description
protected static int	capacity(int curCap, int reqCap) Calculate new capacity.
protected abstract void	copyAndShift(Object src, long off, int len) Copy source object to the stream shift position afterwards.
protected abstract void	ensureCapacity(int cnt) Ensure capacity.
long	offheapPointer()
void	position(int pos)
void	write(byte[] arr, int off, int len) Write byte array.
void	write(long addr, int cnt) Write data from unmanaged memory.
void	writeBoolean(boolean val) Write boolean value.
void	writeBooleanArray(boolean[] val) Write boolean array.
void	writeByte(byte val) Write byte value.
protected abstract void	writeByteAndShift(byte val) Write next byte to the stream.
void	writeByteArray(byte[] val) Write byte array.
void	writeChar(char val) Write char value.
void	writeCharArray(char[] val) Write char array.
protected abstract void	writeCharFast(char val) Write char value (fast path).
void	writeDouble(double val) Write double value.
void	writeDoubleArray(double[] val) Write double array.
void	writeFloat(float val) Write float value.
void	writeFloatArray(float[] val) Write float array.
void	writeInt(int val) Write int value.
void	writeInt(int pos, int val) Write int value to the given position.
void	writeIntArray(int[] val) Write int array.
protected abstract void	writeIntFast(int val) Write int value (fast path).
protected abstract void	writeIntPositioned(int pos, int val) Write int value to the given position.
void	writeLong(long val) Write long value.
void	writeLongArray(long[] val) Write long array.
protected abstract void	writeLongFast(long val) Write long value (fast path).
void	writeShort(short val) Write short value.
void	writeShortArray(short[] val) Write short array.
protected abstract void	writeShortFast(short val) Write short value (fast path).

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.PortableOutputStream

close

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

array, arrayCopy, hasArray, position

Constructor Detail

PortableAbstractOutputStream

public PortableAbstractOutputStream()

Method Detail

writeByte

public void writeByte(byte val)

Write byte value.

Specified by:

writeByte in interface PortableOutputStream

Parameters:

val - Byte value.

writeByteArray

public void writeByteArray(byte[] val)

Write byte array.

Specified by:

writeByteArray in interface PortableOutputStream

Parameters:

val - Byte array.

writeBoolean

public void writeBoolean(boolean val)

Write boolean value.

Specified by:

writeBoolean in interface PortableOutputStream

Parameters:

val - Boolean value.

writeBooleanArray

public void writeBooleanArray(boolean[] val)

Write boolean array.

Specified by:

writeBooleanArray in interface PortableOutputStream

Parameters:

val - Boolean array.

writeShort

public void writeShort(short val)

Write short value.

Specified by:

writeShort in interface PortableOutputStream

Parameters:

val - Short value.

writeShortArray

public void writeShortArray(short[] val)

Write short array.

Specified by:

writeShortArray in interface PortableOutputStream

Parameters:

val - Short array.

writeChar

public void writeChar(char val)

Write char value.

Specified by:

writeChar in interface PortableOutputStream

Parameters:

val - Char value.

writeCharArray

public void writeCharArray(char[] val)

Write char array.

Specified by:

writeCharArray in interface PortableOutputStream

Parameters:

val - Char array.

writeInt

public void writeInt(int val)

Write int value.

Specified by:

writeInt in interface PortableOutputStream

Parameters:

val - Int value.

writeInt

public void writeInt(int pos,
            int val)

Write int value to the given position.

Specified by:

writeInt in interface PortableOutputStream

Parameters:

pos - Position.

val - Value.

writeIntArray

public void writeIntArray(int[] val)

Write int array.

Specified by:

writeIntArray in interface PortableOutputStream

Parameters:

val - Int array.

writeFloat

public void writeFloat(float val)

Write float value.

Specified by:

writeFloat in interface PortableOutputStream

Parameters:

val - Float value.

writeFloatArray

public void writeFloatArray(float[] val)

Write float array.

Specified by:

writeFloatArray in interface PortableOutputStream

Parameters:

val - Float array.

writeLong

public void writeLong(long val)

Write long value.

Specified by:

writeLong in interface PortableOutputStream

Parameters:

val - Long value.

writeLongArray

public void writeLongArray(long[] val)

Write long array.

Specified by:

writeLongArray in interface PortableOutputStream

Parameters:

val - Long array.

writeDouble

public void writeDouble(double val)

Write double value.

Specified by:

writeDouble in interface PortableOutputStream

Parameters:

val - Double value.

writeDoubleArray

public void writeDoubleArray(double[] val)

Write double array.

Specified by:

writeDoubleArray in interface PortableOutputStream

Parameters:

val - Double array.

write

public void write(byte[] arr,
         int off,
         int len)

Write byte array.

Specified by:

write in interface PortableOutputStream

Parameters:

arr - Array.

off - Offset.

len - Length.

write

public void write(long addr,
         int cnt)

Write data from unmanaged memory.

Specified by:

write in interface PortableOutputStream

Parameters:

addr - Address.

cnt - Count.

position

public void position(int pos)

Specified by:

position in interface PortableStream

Parameters:

pos - Position.

offheapPointer

public long offheapPointer()

Specified by:

offheapPointer in interface PortableStream

Returns:

Offheap pointer if stream is offheap based, otherwise 0.

capacity

protected static int capacity(int curCap,
           int reqCap)

Calculate new capacity.

Parameters:

curCap - Current capacity.

reqCap - Required capacity.

Returns:

New capacity.

writeByteAndShift

protected abstract void writeByteAndShift(byte val)

Write next byte to the stream.

Parameters:

val - Value.

copyAndShift

protected abstract void copyAndShift(Object src,
                long off,
                int len)

Copy source object to the stream shift position afterwards.

Parameters:

src - Source.

off - Offset.

len - Length.

writeShortFast

protected abstract void writeShortFast(short val)

Write short value (fast path).

Parameters:

val - Short value.

writeCharFast

protected abstract void writeCharFast(char val)

Write char value (fast path).

Parameters:

val - Char value.

writeIntFast

protected abstract void writeIntFast(int val)

Write int value (fast path).

Parameters:

val - Int value.

writeLongFast

protected abstract void writeLongFast(long val)

Write long value (fast path).

Parameters:

val - Long value.

writeIntPositioned

protected abstract void writeIntPositioned(int pos,
                      int val)

Write int value to the given position.

Parameters:

pos - Position.

val - Value.

ensureCapacity

protected abstract void ensureCapacity(int cnt)

Ensure capacity.

Parameters:

cnt - Required byte count.