org.gridgain.grid.kernal.processors.cache

Class GridCacheIoManager<K,V>

java.lang.Object

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

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

All Implemented Interfaces:

GridCacheManager<K,V>

public class GridCacheIoManager<K,V>
extends GridCacheManagerAdapter<K,V>

Cache communication manager.

Field Summary

Fields inherited from class org.gridgain.grid.kernal.processors.cache.GridCacheManagerAdapter

cctx, log

Constructor Summary

Constructors

Constructor and Description
GridCacheIoManager()

Method Summary

Methods

Modifier and Type	Method and Description
void	addHandler(Class<? extends GridCacheMessage> type, GridBiInClosure<UUID,? extends GridCacheMessage<K,V>> c) Adds message handler.
void	addOrderedHandler(Object topic, GridBiInClosure<UUID,? extends GridCacheMessage<K,V>> c) Adds ordered message handler.
long	messageId(Object topic, UUID nodeId)
long	nextIoId()
protected void	onKernalStop0(boolean cancel)
void	printMemoryStats() Prints memory statistics (sizes of internal data structures, etc.).
void	removeHandler(Class<?> type, GridBiInClosure<UUID,?> c) Removes message handler.
void	removeMessageId(Object topic)
void	removeOrderedHandler(Object topic) Removed ordered message handler.
boolean	safeSend(Collection<? extends GridNode> nodes, GridCacheMessage<K,V> msg, GridPredicate<GridNode> fallback) Sends message and automatically accounts for lefts nodes.
void	send(GridNode node, GridCacheMessage<K,V> msg) Sends communication message.
void	send(GridNode node, GridCacheMessage<K,V> msg, GridIoPolicy plc) Sends communication message.
void	send(UUID nodeId, GridCacheMessage<K,V> msg) Sends communication message.
void	sendOrderedMessage(GridNode node, Object topic, long msgId, GridCacheMessage<K,V> msg, long timeout)
void	start0()

Methods inherited from class org.gridgain.grid.kernal.processors.cache.GridCacheManagerAdapter

context, kernalStartInfo, kernalStopInfo, log, onKernalStart, onKernalStart0, onKernalStop, start, startInfo, stop, stop0, stopInfo, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

GridCacheIoManager

public GridCacheIoManager()

Method Detail

start0

public void start0()
            throws GridException

Overrides:

start0 in class GridCacheManagerAdapter<K,V>

Throws:

GridException - If failed.

onKernalStop0

protected void onKernalStop0(boolean cancel)

Overrides:

onKernalStop0 in class GridCacheManagerAdapter<K,V>

Parameters:

cancel - Cancel flag.

send

public void send(GridNode node,
        GridCacheMessage<K,V> msg)
          throws GridException

Sends communication message.

Parameters:

node - Node to send the message to.

msg - Message to send.

Throws:

GridException - If sending failed.

GridTopologyException - If receiver left.

send

public void send(GridNode node,
        GridCacheMessage<K,V> msg,
        GridIoPolicy plc)
          throws GridException

Sends communication message.

Parameters:

node - Node to send the message to.

msg - Message to send.

Throws:

GridException - If sending failed.

GridTopologyException - If receiver left.

safeSend

public boolean safeSend(Collection<? extends GridNode> nodes,
               GridCacheMessage<K,V> msg,
               @Nullable
               GridPredicate<GridNode> fallback)
                 throws GridException

Sends message and automatically accounts for lefts nodes.

Parameters:

nodes - Nodes to send to.

msg - Message to send.

fallback - Callback for failed nodes.

Returns:

True if nodes are empty or message was sent, false if all nodes have left topology while sending this message.

Throws:

GridException - If send failed.

send

public void send(UUID nodeId,
        GridCacheMessage<K,V> msg)
          throws GridException

Sends communication message.

Parameters:

nodeId - ID of node to send the message to.

msg - Message to send.

Throws:

GridException - If sending failed.

sendOrderedMessage

public void sendOrderedMessage(GridNode node,
                      Object topic,
                      long msgId,
                      GridCacheMessage<K,V> msg,
                      long timeout)
                        throws GridException

Parameters:

node - Destination node.

topic - Topic to send the message to.

msgId - Ordered message ID.

msg - Message to send.

timeout - Timeout to keep a message on receiving queue.

Throws:

GridException - Thrown in case of any errors.

messageId

public long messageId(Object topic,
             UUID nodeId)

Parameters:

topic - Message topic.

nodeId - Node ID.

Returns:

Next ordered message ID.

nextIoId

public long nextIoId()

Returns:

ID that auto-grows based on local counter and counters received from other nodes.

addHandler

public void addHandler(Class<? extends GridCacheMessage> type,
              GridBiInClosure<UUID,? extends GridCacheMessage<K,V>> c)

Adds message handler.

Parameters:

type - Type of message.

c - Handler.

removeHandler

public void removeHandler(Class<?> type,
                 GridBiInClosure<UUID,?> c)

Removes message handler.

Parameters:

type - Type of message.

c - Handler.

addOrderedHandler

public void addOrderedHandler(Object topic,
                     GridBiInClosure<UUID,? extends GridCacheMessage<K,V>> c)

Adds ordered message handler.

Parameters:

topic - Topic.

c - Handler.

removeOrderedHandler

public void removeOrderedHandler(Object topic)

Removed ordered message handler.

Parameters:

topic - Topic.

removeMessageId

public void removeMessageId(Object topic)

Parameters:

topic - Message topic.

printMemoryStats

public void printMemoryStats()

Prints memory statistics (sizes of internal data structures, etc.). NOTE: this method is for testing and profiling purposes only.

Specified by:

printMemoryStats in interface GridCacheManager<K,V>

Overrides:

printMemoryStats in class GridCacheManagerAdapter<K,V>