org.gridgain.grid.util.direct

Class GridTcpCommunicationMessageAdapter

java.lang.Object

org.gridgain.grid.util.direct.GridTcpCommunicationMessageAdapter

All Implemented Interfaces:

Serializable, Cloneable

Direct Known Subclasses:

GridCacheMessage, GridCheckpointRequest, GridClientHandshakeRequestWrapper, GridClientHandshakeResponseWrapper, GridClientMessageWrapper, GridClientPingPacketWrapper, GridClockDeltaSnapshotMessage, GridContinuousMessage, GridDataLoadRequest, GridDataLoadResponse, GridDeploymentInfoBean, GridDeploymentRequest, GridDeploymentResponse, GridDrInternalRequest, GridDrInternalResponse, GridEventStorageMessage, GridIoMessage, GridIoUserMessage, GridJobCancelRequest, GridJobExecuteRequest, GridJobExecuteResponse, GridJobSiblingsRequest, GridJobSiblingsResponse, GridJobStealingRequest, GridMemcachedMessageWrapper, GridStreamerCancelRequest, GridStreamerExecutionRequest, GridStreamerResponse, GridTaskCancelRequest, GridTaskResultRequest, GridTaskResultResponse, GridTaskSessionRequest, GridTcpCommunicationSpi.NodeIdMessage

public abstract class GridTcpCommunicationMessageAdapter
extends Object
implements Serializable, Cloneable

Communication message adapter.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static BitSet	BIT_SET_NOT_READ
static boolean[]	BOOLEAN_ARR_NOT_READ
static GridByteArrayList	BYTE_ARR_LIST_NOT_READ
static byte[]	BYTE_ARR_NOT_READ
static GridCacheVersion	CACHE_VER_NOT_READ
static char[]	CHAR_ARR_NOT_READ
static GridClockDeltaVersion	CLOCK_DELTA_VER_NOT_READ
protected GridTcpCommunicationMessageState	commState
static GridDhtPartitionExchangeId	DHT_PART_EXCHANGE_ID_NOT_READ
static double[]	DOUBLE_ARR_NOT_READ
static GridDrInternalRequestEntry	DR_INT_REQ_ENTRY_NOT_READ
static Enum<?>	ENUM_NOT_READ
static float[]	FLOAT_ARR_NOT_READ
static GridUuid	GRID_UUID_NOT_READ
static int[]	INT_ARR_NOT_READ
static long[]	LONG_ARR_NOT_READ
static GridLongList	LONG_LIST_NOT_READ
static GridTcpCommunicationMessageAdapter	MSG_NOT_READ
protected static Object	NULL
static short[]	SHORT_ARR_NOT_READ
static String	STR_NOT_READ
static UUID	UUID_NOT_READ
static GridCacheValueBytes	VAL_BYTES_NOT_READ

Constructor Summary

Constructors

Constructor and Description
GridTcpCommunicationMessageAdapter()

Method Summary

Methods

Modifier and Type	Method and Description
protected Iterator<?>	arrayIterator(Object[] arr)
abstract GridTcpCommunicationMessageAdapter	clone()
protected abstract void	clone0(GridTcpCommunicationMessageAdapter _msg) Clones all fields of the provided message to this.
abstract byte	directType()
void	messageReader(GridNioMessageReader msgReader, UUID nodeId)
void	messageWriter(GridNioMessageWriter msgWriter, UUID nodeId)
abstract boolean	readFrom(ByteBuffer buf)
abstract boolean	writeTo(ByteBuffer buf)

Methods inherited from class java.lang.Object

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

Field Detail

BYTE_ARR_NOT_READ

public static final byte[] BYTE_ARR_NOT_READ

SHORT_ARR_NOT_READ

public static final short[] SHORT_ARR_NOT_READ

INT_ARR_NOT_READ

public static final int[] INT_ARR_NOT_READ

LONG_ARR_NOT_READ

public static final long[] LONG_ARR_NOT_READ

FLOAT_ARR_NOT_READ

public static final float[] FLOAT_ARR_NOT_READ

DOUBLE_ARR_NOT_READ

public static final double[] DOUBLE_ARR_NOT_READ

CHAR_ARR_NOT_READ

public static final char[] CHAR_ARR_NOT_READ

BOOLEAN_ARR_NOT_READ

public static final boolean[] BOOLEAN_ARR_NOT_READ

UUID_NOT_READ

public static final UUID UUID_NOT_READ

GRID_UUID_NOT_READ

public static final GridUuid GRID_UUID_NOT_READ

CLOCK_DELTA_VER_NOT_READ

public static final GridClockDeltaVersion CLOCK_DELTA_VER_NOT_READ

BYTE_ARR_LIST_NOT_READ

public static final GridByteArrayList BYTE_ARR_LIST_NOT_READ

LONG_LIST_NOT_READ

public static final GridLongList LONG_LIST_NOT_READ

CACHE_VER_NOT_READ

public static final GridCacheVersion CACHE_VER_NOT_READ

DHT_PART_EXCHANGE_ID_NOT_READ

public static final GridDhtPartitionExchangeId DHT_PART_EXCHANGE_ID_NOT_READ

VAL_BYTES_NOT_READ

public static final GridCacheValueBytes VAL_BYTES_NOT_READ

DR_INT_REQ_ENTRY_NOT_READ

public static final GridDrInternalRequestEntry DR_INT_REQ_ENTRY_NOT_READ

STR_NOT_READ

public static final String STR_NOT_READ

BIT_SET_NOT_READ

public static final BitSet BIT_SET_NOT_READ

ENUM_NOT_READ

public static final Enum<?> ENUM_NOT_READ

MSG_NOT_READ

public static final GridTcpCommunicationMessageAdapter MSG_NOT_READ

NULL

protected static final Object NULL

commState

protected final GridTcpCommunicationMessageState commState

Constructor Detail

GridTcpCommunicationMessageAdapter

public GridTcpCommunicationMessageAdapter()

Method Detail

messageWriter

public void messageWriter(GridNioMessageWriter msgWriter,
                 @Nullable
                 UUID nodeId)

Parameters:

msgWriter - Message writer.

nodeId - Node ID (provided only if versions are different).

messageReader

public void messageReader(GridNioMessageReader msgReader,
                 @Nullable
                 UUID nodeId)

Parameters:

msgReader - Message reader.

nodeId - Node ID (provided only if versions are different).

writeTo

public abstract boolean writeTo(ByteBuffer buf)

Parameters:

buf - Byte buffer.

Returns:

Whether message was fully written.

readFrom

public abstract boolean readFrom(ByteBuffer buf)

Parameters:

buf - Byte buffer.

Returns:

Whether message was fully read.

directType

public abstract byte directType()

Returns:

Message type.

clone

public abstract GridTcpCommunicationMessageAdapter clone()

Overrides:

clone in class Object

clone0

protected abstract void clone0(GridTcpCommunicationMessageAdapter _msg)

Clones all fields of the provided message to this.

Parameters:

_msg - Message to clone from.

arrayIterator

protected final Iterator<?> arrayIterator(Object[] arr)

Parameters:

arr - Array.

Returns:

Array iterator.