org.gridgain.grid.kernal.managers.communication

Class GridIoManager

java.lang.Object

org.gridgain.grid.kernal.managers.GridManagerAdapter<GridCommunicationSpi<Serializable>>

org.gridgain.grid.kernal.managers.communication.GridIoManager

All Implemented Interfaces:

GridComponent, GridManager

public class GridIoManager
extends GridManagerAdapter<GridCommunicationSpi<Serializable>>

Grid communication manager.

Field Summary

Fields

Modifier and Type	Field and Description
static int	MAX_CLOSED_TOPICS Max closed topics to store.

Fields inherited from class org.gridgain.grid.kernal.managers.GridManagerAdapter

ctx, log

Constructor Summary

Constructors

Constructor and Description
GridIoManager(GridKernalContext ctx)

Method Summary

Methods

Modifier and Type	Method and Description
void	addMessageListener(GridTopic topic, GridMessageListener lsnr)
void	addMessageListener(Object topic, GridMessageListener lsnr)
void	addUserMessageListener(Object topic, GridBiPredicate<UUID,?> p)
int	getOutboundMessagesQueueSize() Gets outbound messages queue size.
long	getReceivedBytesCount() Gets received bytes count.
int	getReceivedMessagesCount() Gets received messages count.
long	getSentBytesCount() Gets sent bytes count.
int	getSentMessagesCount() Gets sent messages count.
long	nextMessageId(Object topic, UUID nodeId)
void	onKernalStart0()
void	onKernalStop0(boolean cancel)
void	printMemoryStats() Prints memory statistics (sizes of internal structures, etc.).
void	removeMessageId(Object topic)
boolean	removeMessageListener(GridTopic topic)
boolean	removeMessageListener(GridTopic topic, GridMessageListener lsnr)
boolean	removeMessageListener(Object topic)
boolean	removeMessageListener(Object topic, GridMessageListener lsnr)
void	removeUserMessageListener(Object topic, GridBiPredicate<UUID,?> p)
void	resetMetrics() Resets metrics for this manager.
void	send(Collection<? extends GridNode> nodes, GridTopic topic, GridTcpCommunicationMessageAdapter msg, GridIoPolicy plc)
void	send(Collection<? extends GridNode> nodes, Object topic, GridTcpCommunicationMessageAdapter msg, GridIoPolicy plc)
void	send(GridNode node, GridTopic topic, GridTcpCommunicationMessageAdapter msg, GridIoPolicy plc)
void	send(GridNode node, Object topic, GridTcpCommunicationMessageAdapter msg, GridIoPolicy plc)
void	send(UUID nodeId, GridTopic topic, GridTcpCommunicationMessageAdapter msg, GridIoPolicy plc)
void	send(UUID nodeId, Object topic, GridTcpCommunicationMessageAdapter msg, GridIoPolicy plc)
void	sendOrderedMessage(Collection<? extends GridNode> nodes, Object topic, long msgId, GridTcpCommunicationMessageAdapter msg, GridIoPolicy plc, long timeout, boolean skipOnTimeout)
void	sendOrderedMessage(GridNode node, Object topic, long msgId, GridTcpCommunicationMessageAdapter msg, GridIoPolicy plc, long timeout, boolean skipOnTimeout)
void	sendOrderedMessage(UUID nodeId, Object topic, long msgId, GridTcpCommunicationMessageAdapter msg, GridIoPolicy plc, long timeout, boolean skipOnTimeout)
void	sendUserMessage(Collection<? extends GridNode> nodes, Object msg) Sends a peer deployable user message.
void	sendUserMessage(Collection<? extends GridNode> nodes, Object msg, Object topic, boolean ordered, long timeout) Sends a peer deployable user message.
void	start() Starts grid component.
void	stop(boolean cancel) Stops grid component.

Methods inherited from class org.gridgain.grid.kernal.managers.GridManagerAdapter

addSpiAttributes, assertParameter, collectDiscoveryData, enabled, getSpi, getSpi, getSpis, onDiscoveryDataReceived, onKernalStart, onKernalStop, startInfo, startSpi, stopInfo, stopSpi, toString, validateNode

Methods inherited from class java.lang.Object

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

Field Detail

MAX_CLOSED_TOPICS

public static final int MAX_CLOSED_TOPICS

Max closed topics to store.

See Also:

Constant Field Values

Constructor Detail

GridIoManager

public GridIoManager(GridKernalContext ctx)

Parameters:

ctx - Grid kernal context.

Method Detail

resetMetrics

public void resetMetrics()

Resets metrics for this manager.

start

public void start()
           throws GridException

Starts grid component.

Throws:

GridException - Throws in case of any errors.

onKernalStart0

public void onKernalStart0()
                    throws GridException

Overrides:

onKernalStart0 in class GridManagerAdapter<GridCommunicationSpi<Serializable>>

Throws:

GridException - If failed.

onKernalStop0

public void onKernalStop0(boolean cancel)

Overrides:

onKernalStop0 in class GridManagerAdapter<GridCommunicationSpi<Serializable>>

Parameters:

cancel - Cancel flag.

stop

public void stop(boolean cancel)
          throws GridException

Stops grid component.

Parameters:

cancel - If true, then all ongoing tasks or jobs for relevant components need to be cancelled.

Throws:

GridException - Thrown in case of any errors.

send

public void send(UUID nodeId,
        Object topic,
        GridTcpCommunicationMessageAdapter msg,
        GridIoPolicy plc)
          throws GridException

Parameters:

nodeId - Id of destination node.

topic - Topic to send the message to.

msg - Message to send.

plc - Type of processing.

Throws:

GridException - Thrown in case of any errors.

send

public void send(UUID nodeId,
        GridTopic topic,
        GridTcpCommunicationMessageAdapter msg,
        GridIoPolicy plc)
          throws GridException

Parameters:

nodeId - Id of destination node.

topic - Topic to send the message to.

msg - Message to send.

plc - Type of processing.

Throws:

GridException - Thrown in case of any errors.

send

public void send(GridNode node,
        Object topic,
        GridTcpCommunicationMessageAdapter msg,
        GridIoPolicy plc)
          throws GridException

Parameters:

node - Destination node.

topic - Topic to send the message to.

msg - Message to send.

plc - Type of processing.

Throws:

GridException - Thrown in case of any errors.

send

public void send(GridNode node,
        GridTopic topic,
        GridTcpCommunicationMessageAdapter msg,
        GridIoPolicy plc)
          throws GridException

Parameters:

node - Destination node.

topic - Topic to send the message to.

msg - Message to send.

plc - Type of processing.

Throws:

GridException - Thrown in case of any errors.

nextMessageId

public long nextMessageId(Object topic,
                 UUID nodeId)

Parameters:

topic - Message topic.

nodeId - Node ID.

Returns:

Next ordered message ID.

removeMessageId

public void removeMessageId(Object topic)

Parameters:

topic - Message topic.

sendOrderedMessage

public void sendOrderedMessage(GridNode node,
                      Object topic,
                      long msgId,
                      GridTcpCommunicationMessageAdapter msg,
                      GridIoPolicy plc,
                      long timeout,
                      boolean skipOnTimeout)
                        throws GridException

Parameters:

node - Destination node.

topic - Topic to send the message to.

msgId - Ordered message ID.

msg - Message to send.

plc - Type of processing.

timeout - Timeout to keep a message on receiving queue.

skipOnTimeout - Whether message can be skipped on timeout.

Throws:

GridException - Thrown in case of any errors.

sendOrderedMessage

public void sendOrderedMessage(UUID nodeId,
                      Object topic,
                      long msgId,
                      GridTcpCommunicationMessageAdapter msg,
                      GridIoPolicy plc,
                      long timeout,
                      boolean skipOnTimeout)
                        throws GridException

Parameters:

nodeId - Destination node.

topic - Topic to send the message to.

msgId - Ordered message ID.

msg - Message to send.

plc - Type of processing.

timeout - Timeout to keep a message on receiving queue.

skipOnTimeout - Whether message can be skipped on timeout.

Throws:

GridException - Thrown in case of any errors.

sendOrderedMessage

public void sendOrderedMessage(Collection<? extends GridNode> nodes,
                      Object topic,
                      long msgId,
                      GridTcpCommunicationMessageAdapter msg,
                      GridIoPolicy plc,
                      long timeout,
                      boolean skipOnTimeout)
                        throws GridException

Parameters:

nodes - Destination nodes.

topic - Topic to send the message to.

msgId - Ordered message ID.

msg - Message to send.

plc - Type of processing.

timeout - Timeout to keep a message on receiving queue.

skipOnTimeout - Whether message can be skipped on timeout.

Throws:

GridException - Thrown in case of any errors.

send

public void send(Collection<? extends GridNode> nodes,
        Object topic,
        GridTcpCommunicationMessageAdapter msg,
        GridIoPolicy plc)
          throws GridException

Parameters:

nodes - Destination nodes.

topic - Topic to send the message to.

msg - Message to send.

plc - Type of processing.

Throws:

GridException - Thrown in case of any errors.

send

public void send(Collection<? extends GridNode> nodes,
        GridTopic topic,
        GridTcpCommunicationMessageAdapter msg,
        GridIoPolicy plc)
          throws GridException

Parameters:

nodes - Destination nodes.

topic - Topic to send the message to.

msg - Message to send.

plc - Type of processing.

Throws:

GridException - Thrown in case of any errors.

sendUserMessage

public void sendUserMessage(Collection<? extends GridNode> nodes,
                   Object msg)
                     throws GridException

Sends a peer deployable user message.

Parameters:

nodes - Destination nodes.

msg - Message to send.

Throws:

GridException - Thrown in case of any errors.

sendUserMessage

public void sendUserMessage(Collection<? extends GridNode> nodes,
                   Object msg,
                   @Nullable
                   Object topic,
                   boolean ordered,
                   long timeout)
                     throws GridException

Sends a peer deployable user message.

Parameters:

nodes - Destination nodes.

msg - Message to send.

topic - Message topic to use.

ordered - Is message ordered?

timeout - Message timeout in milliseconds for ordered messages.

Throws:

GridException - Thrown in case of any errors.

addUserMessageListener

public void addUserMessageListener(@Nullable
                          Object topic,
                          @Nullable
                          GridBiPredicate<UUID,?> p)

Parameters:

topic - Topic to subscribe to.

p - Message predicate.

removeUserMessageListener

public void removeUserMessageListener(@Nullable
                             Object topic,
                             GridBiPredicate<UUID,?> p)

Parameters:

topic - Topic to unsubscribe from.

p - Message predicate.

addMessageListener

public void addMessageListener(GridTopic topic,
                      GridMessageListener lsnr)

Parameters:

topic - Listener's topic.

lsnr - Listener to add.

addMessageListener

public void addMessageListener(Object topic,
                      GridMessageListener lsnr)

Parameters:

topic - Listener's topic.

lsnr - Listener to add.

removeMessageListener

public boolean removeMessageListener(GridTopic topic)

Parameters:

topic - Message topic.

Returns:

Whether or not listener was indeed removed.

removeMessageListener

public boolean removeMessageListener(Object topic)

Parameters:

topic - Message topic.

Returns:

Whether or not listener was indeed removed.

removeMessageListener

public boolean removeMessageListener(GridTopic topic,
                            @Nullable
                            GridMessageListener lsnr)

Parameters:

topic - Listener's topic.

lsnr - Listener to remove.

Returns:

Whether or not the lsnr was removed.

removeMessageListener

public boolean removeMessageListener(Object topic,
                            @Nullable
                            GridMessageListener lsnr)

Parameters:

topic - Listener's topic.

lsnr - Listener to remove.

Returns:

Whether or not the lsnr was removed.

getSentMessagesCount

public int getSentMessagesCount()

Gets sent messages count.

Returns:

Sent messages count.

getSentBytesCount

public long getSentBytesCount()

Gets sent bytes count.

Returns:

Sent bytes count.

getReceivedMessagesCount

public int getReceivedMessagesCount()

Gets received messages count.

Returns:

Received messages count.

getReceivedBytesCount

public long getReceivedBytesCount()

Gets received bytes count.

Returns:

Received bytes count.

getOutboundMessagesQueueSize

public int getOutboundMessagesQueueSize()

Gets outbound messages queue size.

Returns:

Outbound messages queue size.

printMemoryStats

public void printMemoryStats()

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

Specified by:

printMemoryStats in interface GridComponent

Overrides:

printMemoryStats in class GridManagerAdapter<GridCommunicationSpi<Serializable>>