org.gridgain.grid.spi.discovery.tcp.messages

Class GridTcpDiscoveryNodeAddedMessage

java.lang.Object

org.gridgain.grid.spi.discovery.tcp.messages.GridTcpDiscoveryAbstractMessage

org.gridgain.grid.spi.discovery.tcp.messages.GridTcpDiscoveryNodeAddedMessage

All Implemented Interfaces:

Externalizable, Serializable

@GridTcpDiscoveryEnsureDelivery
public class GridTcpDiscoveryNodeAddedMessage
extends GridTcpDiscoveryAbstractMessage

Message telling nodes that new node should be added to topology. When newly added node receives the message it connects to its next and finishes join process.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
GridTcpDiscoveryNodeAddedMessage() Public default no-arg constructor for Externalizable interface.
GridTcpDiscoveryNodeAddedMessage(UUID creatorNodeId, GridTcpDiscoveryNode node, List<Object> newNodeDiscoData, long gridStartTime) Constructor.

Method Summary

Methods

Modifier and Type	Method and Description
void	addDiscoveryData(List<Object> discoData)
void	clearDiscoveryData() Clears discovery data to minimize message size.
long	gridStartTime()
Collection<GridTcpDiscoveryAbstractMessage>	messages() Gets pending messages sent to new node by its previous.
void	messages(Collection<GridTcpDiscoveryAbstractMessage> msgs) Sets pending messages to send to new node.
List<Object>	newNodeDiscoveryData()
GridTcpDiscoveryNode	node() Gets newly added node.
Collection<List<Object>>	oldNodesDiscoveryData()
boolean	processPendingMessages()
void	processPendingMessages(boolean procPendingMsgs)
void	readExternal(ObjectInput in)
Collection<GridTcpDiscoveryNode>	topology() Gets topology.
void	topology(Collection<GridTcpDiscoveryNode> top) Sets topology.
Map<Long,Collection<GridNode>>	topologyHistory() Gets topology snapshots history.
void	topologyHistory(Map<Long,Collection<GridNode>> topHist) Sets topology snapshots history.
String	toString()
void	writeExternal(ObjectOutput out)

Methods inherited from class org.gridgain.grid.spi.discovery.tcp.messages.GridTcpDiscoveryAbstractMessage

creatorNodeId, equals, hashCode, id, senderNodeId, senderNodeId, topologyVersion, topologyVersion, verified, verifierNodeId, verify

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

GridTcpDiscoveryNodeAddedMessage

public GridTcpDiscoveryNodeAddedMessage()

Public default no-arg constructor for Externalizable interface.

GridTcpDiscoveryNodeAddedMessage

public GridTcpDiscoveryNodeAddedMessage(UUID creatorNodeId,
                                GridTcpDiscoveryNode node,
                                List<Object> newNodeDiscoData,
                                long gridStartTime)

Constructor.

Parameters:

creatorNodeId - Creator node ID.

node - Node to add to topology.

newNodeDiscoData - New Node discovery data.

gridStartTime - Start time of the first grid node.

Method Detail

node

public GridTcpDiscoveryNode node()

Gets newly added node.

Returns:

New node.

messages

@Nullable
public Collection<GridTcpDiscoveryAbstractMessage> messages()

Gets pending messages sent to new node by its previous.

Returns:

Pending messages from previous node.

messages

public void messages(@Nullable
            Collection<GridTcpDiscoveryAbstractMessage> msgs)

Sets pending messages to send to new node.

Parameters:

msgs - Pending messages to send to new node.

topology

@Nullable
public Collection<GridTcpDiscoveryNode> topology()

Gets topology.

Returns:

Current topology.

topology

public void topology(@Nullable
            Collection<GridTcpDiscoveryNode> top)

Sets topology.

Parameters:

top - Current topology.

topologyHistory

@Nullable
public Map<Long,Collection<GridNode>> topologyHistory()

Gets topology snapshots history.

Returns:

Map with topology snapshots history.

topologyHistory

public void topologyHistory(@Nullable
                   Map<Long,Collection<GridNode>> topHist)

Sets topology snapshots history.

Parameters:

topHist - Map with topology snapshots history.

processPendingMessages

public boolean processPendingMessages()

Returns:

True if pending messages should be processed on receive.

processPendingMessages

public void processPendingMessages(boolean procPendingMsgs)

Parameters:

procPendingMsgs - True if pending messages should be processed on receive.

newNodeDiscoveryData

public List<Object> newNodeDiscoveryData()

Returns:

Discovery data from new node.

oldNodesDiscoveryData

public Collection<List<Object>> oldNodesDiscoveryData()

Returns:

Discovery data from old nodes.

addDiscoveryData

public void addDiscoveryData(List<Object> discoData)

Parameters:

discoData - Discovery data to add.

clearDiscoveryData

public void clearDiscoveryData()

Clears discovery data to minimize message size.

gridStartTime

public long gridStartTime()

Returns:

First grid node start time.

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Overrides:

writeExternal in class GridTcpDiscoveryAbstractMessage

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Overrides:

readExternal in class GridTcpDiscoveryAbstractMessage

Throws:

IOException

ClassNotFoundException

toString

public String toString()

Overrides:

toString in class GridTcpDiscoveryAbstractMessage