org.gridgain.grid.kernal.processors.cache

Class GridCacheMessage<K,V>

java.lang.Object

org.gridgain.grid.util.direct.GridTcpCommunicationMessageAdapter

org.gridgain.grid.kernal.processors.cache.GridCacheMessage<K,V>

All Implemented Interfaces:

Serializable, Cloneable

Direct Known Subclasses:

GridCacheDgcRequest, GridCacheDgcResponse, GridCacheEvictionRequest, GridCacheEvictionResponse, GridCacheQueryRequest, GridCacheQueryResponse, GridDhtAffinityAssignmentRequest, GridDhtAffinityAssignmentResponse, GridDhtAtomicDeferredUpdateResponse, GridDhtAtomicUpdateRequest, GridDhtAtomicUpdateResponse, GridDhtForceKeysRequest, GridDhtForceKeysResponse, GridDhtPartitionDemandMessage, GridDhtPartitionsFullMessage, GridDhtPartitionsSingleMessage, GridDhtPartitionsSingleRequest, GridDhtPartitionSupplyMessage, GridDistributedBaseMessage, GridDistributedTxFinishResponse, GridNearAtomicUpdateRequest, GridNearAtomicUpdateResponse, GridNearGetRequest, GridNearGetResponse

public abstract class GridCacheMessage<K,V>
extends GridTcpCommunicationMessageAdapter

Parent of all cache messages.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static String	CACHE_MSG_INDEX_FIELD_NAME Cache message index field name.
static int	MAX_CACHE_MSG_LOOKUP_INDEX Maximum number of cache lookup indexes.

Fields inherited from class org.gridgain.grid.util.direct.GridTcpCommunicationMessageAdapter

BIT_SET_NOT_READ, BOOLEAN_ARR_NOT_READ, BYTE_ARR_LIST_NOT_READ, BYTE_ARR_NOT_READ, CACHE_VER_NOT_READ, CHAR_ARR_NOT_READ, CLOCK_DELTA_VER_NOT_READ, commState, DHT_PART_EXCHANGE_ID_NOT_READ, DOUBLE_ARR_NOT_READ, DR_INT_REQ_ENTRY_NOT_READ, ENUM_NOT_READ, FLOAT_ARR_NOT_READ, GRID_UUID_NOT_READ, INT_ARR_NOT_READ, LONG_ARR_NOT_READ, LONG_LIST_NOT_READ, MSG_NOT_READ, NULL, SHORT_ARR_NOT_READ, STR_NOT_READ, UUID_NOT_READ, VAL_BYTES_NOT_READ

Constructor Summary

Constructors

Constructor and Description
GridCacheMessage()

Method Summary

Methods

Modifier and Type	Method and Description
boolean	allowForStartup()
Exception	classError()
protected void	clone0(GridTcpCommunicationMessageAdapter _msg) Clones all fields of the provided message to this.
GridDeploymentInfo	deployInfo()
void	finishUnmarshal(GridCacheContext<K,V> ctx, ClassLoader ldr) This method is called after the message is deserialized and is responsible for unmarshalling state marshalled in prepareMarshal(GridCacheContext) method.
boolean	ignoreClassErrors()
int	lookupIndex() Gets message lookup index.
protected LinkedHashMap<byte[],Boolean>	marshalBooleanLinkedMap(LinkedHashMap<?,Boolean> map, GridCacheContext<K,V> ctx)
protected List<byte[]>	marshalCollection(Collection<?> col, GridCacheContext<K,V> ctx)
protected <T> byte[][]	marshalFilter(GridPredicate<GridCacheEntry<K,V>>[] filter, GridCacheContext<K,V> ctx)
protected void	marshalInfo(GridCacheEntryInfo<K,V> info, GridCacheContext<K,V> ctx)
protected void	marshalInfos(Iterable<? extends GridCacheEntryInfo<K,V>> infos, GridCacheContext<K,V> ctx)
protected void	marshalTx(Iterable<GridCacheTxEntry<K,V>> txEntries, GridCacheContext<K,V> ctx)
protected List<GridCacheValueBytes>	marshalValuesCollection(Collection<?> col, GridCacheContext<K,V> ctx)
long	messageId()
static int	nextIndexId() Gets next ID for indexed message ID.
void	onClassError(Exception err) If class loading error occurred during unmarshalling and ignoreClassErrors() is set to true, then the error will be passed into this method.
void	prepare(GridDeploymentInfo depInfo)
protected void	prepareFilter(GridPredicate<GridCacheEntry<K,V>>[] filters, GridCacheContext<K,V> ctx)
void	prepareMarshal(GridCacheContext<K,V> ctx) This method is called before the whole message is serialized and is responsible for pre-marshalling state.
protected void	prepareObject(Object o, GridCacheContext<K,V> ctx)
protected void	prepareObjects(Iterable<?> col, GridCacheContext<K,V> ctx)
boolean	readFrom(ByteBuffer buf)
long	topologyVersion() Gets topology version or -1 in case of topology version is not required for this message.
String	toString()
protected <K1> LinkedHashMap<K1,Boolean>	unmarshalBooleanLinkedMap(Map<byte[],Boolean> byteMap, GridCacheContext<K,V> ctx, ClassLoader ldr)
protected <T> List<T>	unmarshalCollection(Collection<byte[]> byteCol, GridCacheContext<K,V> ctx, ClassLoader ldr)
protected <T> GridPredicate<GridCacheEntry<K,V>>[]	unmarshalFilter(byte[][] byteCol, GridCacheContext<K,V> ctx, ClassLoader ldr)
protected void	unmarshalInfo(GridCacheEntryInfo<K,V> info, GridCacheContext<K,V> ctx, ClassLoader ldr)
protected void	unmarshalInfos(Iterable<? extends GridCacheEntryInfo<K,V>> infos, GridCacheContext<K,V> ctx, ClassLoader ldr)
protected void	unmarshalTx(Iterable<GridCacheTxEntry<K,V>> txEntries, GridCacheContext<K,V> ctx, ClassLoader ldr)
protected <T> List<T>	unmarshalValueBytesCollection(Collection<GridCacheValueBytes> byteCol, GridCacheContext<K,V> ctx, ClassLoader ldr)
boolean	writeTo(ByteBuffer buf)

Methods inherited from class org.gridgain.grid.util.direct.GridTcpCommunicationMessageAdapter

arrayIterator, clone, directType, messageReader, messageWriter

Methods inherited from class java.lang.Object

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

Field Detail

MAX_CACHE_MSG_LOOKUP_INDEX

public static final int MAX_CACHE_MSG_LOOKUP_INDEX

Maximum number of cache lookup indexes.

See Also:

Constant Field Values

CACHE_MSG_INDEX_FIELD_NAME

public static final String CACHE_MSG_INDEX_FIELD_NAME

Cache message index field name.

See Also:

Constant Field Values

Constructor Detail

GridCacheMessage

public GridCacheMessage()

Method Detail

nextIndexId

public static int nextIndexId()

Gets next ID for indexed message ID.

Returns:

Message ID.

allowForStartup

public boolean allowForStartup()

Returns:

True if this message is preloader message.

ignoreClassErrors

public boolean ignoreClassErrors()

Returns:

True if class loading errors should be ignored, false otherwise.

lookupIndex

public int lookupIndex()

Gets message lookup index. All messages that does not return -1 in this method must return a unique number in range from 0 to MAX_CACHE_MSG_LOOKUP_INDEX.

Returns:

Message lookup index.

onClassError

public void onClassError(Exception err)

If class loading error occurred during unmarshalling and ignoreClassErrors() is set to true, then the error will be passed into this method.

Parameters:

err - Error.

classError

public Exception classError()

Returns:

Error set via onClassError(Exception) method.

messageId

public long messageId()

Returns:

Message ID.

topologyVersion

public long topologyVersion()

Gets topology version or -1 in case of topology version is not required for this message.

Returns:

Topology version.

prepareFilter

protected final void prepareFilter(@Nullable
                 GridPredicate<GridCacheEntry<K,V>>[] filters,
                 GridCacheContext<K,V> ctx)
                            throws GridException

Parameters:

filters - Predicate filters.

ctx - Context.

Throws:

GridException - If failed.

prepareObject

protected final void prepareObject(@Nullable
                 Object o,
                 GridCacheContext<K,V> ctx)
                            throws GridException

Parameters:

o - Object to prepare for marshalling.

ctx - Context.

Throws:

GridException - If failed.

prepareObjects

protected final void prepareObjects(@Nullable
                  Iterable<?> col,
                  GridCacheContext<K,V> ctx)
                             throws GridException

Parameters:

col - Collection of objects to prepare for marshalling.

ctx - Cache context.

Throws:

GridException - If failed.

prepare

public final void prepare(GridDeploymentInfo depInfo)

Parameters:

depInfo - Deployment to set.

See Also:

GridCacheDeployable.prepare(GridDeploymentInfo)

deployInfo

public GridDeploymentInfo deployInfo()

Returns:

Preset deployment info.

See Also:

GridCacheDeployable.deployInfo()

prepareMarshal

public void prepareMarshal(GridCacheContext<K,V> ctx)
                    throws GridException

This method is called before the whole message is serialized and is responsible for pre-marshalling state.

Parameters:

ctx - Cache context.

Throws:

GridException - If failed.

finishUnmarshal

public void finishUnmarshal(GridCacheContext<K,V> ctx,
                   ClassLoader ldr)
                     throws GridException

This method is called after the message is deserialized and is responsible for unmarshalling state marshalled in prepareMarshal(GridCacheContext) method.

Parameters:

ctx - Context.

ldr - Class loader.

Throws:

GridException - If failed.

marshalInfo

protected final void marshalInfo(GridCacheEntryInfo<K,V> info,
               GridCacheContext<K,V> ctx)
                          throws GridException

Parameters:

info - Entry to marshal.

ctx - Context.

Throws:

GridException - If failed.

unmarshalInfo

protected final void unmarshalInfo(GridCacheEntryInfo<K,V> info,
                 GridCacheContext<K,V> ctx,
                 ClassLoader ldr)
                            throws GridException

Parameters:

info - Entry to unmarshal.

ctx - Context.

ldr - Loader.

Throws:

GridException - If failed.

marshalInfos

protected final void marshalInfos(Iterable<? extends GridCacheEntryInfo<K,V>> infos,
                GridCacheContext<K,V> ctx)
                           throws GridException

Parameters:

infos - Entries to marshal.

ctx - Context.

Throws:

GridException - If failed.

unmarshalInfos

protected final void unmarshalInfos(Iterable<? extends GridCacheEntryInfo<K,V>> infos,
                  GridCacheContext<K,V> ctx,
                  ClassLoader ldr)
                             throws GridException

Parameters:

infos - Entries to unmarshal.

ctx - Context.

ldr - Loader.

Throws:

GridException - If failed.

marshalTx

protected final void marshalTx(Iterable<GridCacheTxEntry<K,V>> txEntries,
             GridCacheContext<K,V> ctx)
                        throws GridException

Parameters:

txEntries - Entries to marshal.

ctx - Context.

Throws:

GridException - If failed.

unmarshalTx

protected final void unmarshalTx(Iterable<GridCacheTxEntry<K,V>> txEntries,
               GridCacheContext<K,V> ctx,
               ClassLoader ldr)
                          throws GridException

Parameters:

txEntries - Entries to unmarshal.

ctx - Context.

ldr - Loader.

Throws:

GridException - If failed.

marshalFilter

@Nullable
protected final <T> byte[][] marshalFilter(@Nullable
                                  GridPredicate<GridCacheEntry<K,V>>[] filter,
                                  GridCacheContext<K,V> ctx)
                                throws GridException

Parameters:

filter - Collection to marshal.

ctx - Context.

Returns:

Marshalled collection.

Throws:

GridException - If failed.

unmarshalFilter

@Nullable
protected final <T> GridPredicate<GridCacheEntry<K,V>>[] unmarshalFilter(@Nullable
                                                                byte[][] byteCol,
                                                                GridCacheContext<K,V> ctx,
                                                                ClassLoader ldr)
                                                              throws GridException

Parameters:

byteCol - Collection to unmarshal.

ctx - Context.

ldr - Loader.

Returns:

Unmarshalled collection.

Throws:

GridException - If failed.

marshalValuesCollection

@Nullable
protected List<GridCacheValueBytes> marshalValuesCollection(@Nullable
                                                         Collection<?> col,
                                                         GridCacheContext<K,V> ctx)
                                                     throws GridException

Parameters:

col - Values collection to marshal.

ctx - Context.

Returns:

Marshaled collection.

Throws:

GridException - If failed.

unmarshalValueBytesCollection

@Nullable
protected <T> List<T> unmarshalValueBytesCollection(@Nullable
                                                 Collection<GridCacheValueBytes> byteCol,
                                                 GridCacheContext<K,V> ctx,
                                                 ClassLoader ldr)
                                         throws GridException

Parameters:

byteCol - Collection to unmarshal.

ctx - Context.

ldr - Loader.

Returns:

Unmarshalled collection.

Throws:

GridException - If failed.

marshalCollection

@Nullable
protected List<byte[]> marshalCollection(@Nullable
                                      Collection<?> col,
                                      GridCacheContext<K,V> ctx)
                                  throws GridException

Parameters:

col - Collection to marshal.

ctx - Context.

Returns:

Marshalled collection.

Throws:

GridException - If failed.

unmarshalCollection

@Nullable
protected <T> List<T> unmarshalCollection(@Nullable
                                       Collection<byte[]> byteCol,
                                       GridCacheContext<K,V> ctx,
                                       ClassLoader ldr)
                               throws GridException

Parameters:

byteCol - Collection to unmarshal.

ctx - Context.

ldr - Loader.

Returns:

Unmarshalled collection.

Throws:

GridException - If failed.

marshalBooleanLinkedMap

@Nullable
protected final LinkedHashMap<byte[],Boolean> marshalBooleanLinkedMap(@Nullable
                                                             LinkedHashMap<?,Boolean> map,
                                                             GridCacheContext<K,V> ctx)
                                                               throws GridException

Parameters:

map - Map to marshal.

ctx - Context.

Returns:

Marshalled map.

Throws:

GridException - If failed.

unmarshalBooleanLinkedMap

@Nullable
protected final <K1> LinkedHashMap<K1,Boolean> unmarshalBooleanLinkedMap(@Nullable
                                                                Map<byte[],Boolean> byteMap,
                                                                GridCacheContext<K,V> ctx,
                                                                ClassLoader ldr)
                                                             throws GridException

Parameters:

byteMap - Map to unmarshal.

ctx - Context.

ldr - Loader.

Returns:

Unmarshalled map.

Throws:

GridException - If failed.

clone0

protected void clone0(GridTcpCommunicationMessageAdapter _msg)

Clones all fields of the provided message to this.

Specified by:

clone0 in class GridTcpCommunicationMessageAdapter

Parameters:

_msg - Message to clone from.

writeTo

public boolean writeTo(ByteBuffer buf)

Specified by:

writeTo in class GridTcpCommunicationMessageAdapter

Parameters:

buf - Byte buffer.

Returns:

Whether message was fully written.

readFrom

public boolean readFrom(ByteBuffer buf)

Specified by:

readFrom in class GridTcpCommunicationMessageAdapter

Parameters:

buf - Byte buffer.

Returns:

Whether message was fully read.

toString

public String toString()

Overrides:

toString in class Object