org.apache.ignite.spi.discovery.tcp.messages

Class TcpDiscoveryNodeAddedMessage

java.lang.Object

org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryAbstractMessage

org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryNodeAddedMessage

All Implemented Interfaces:

Externalizable, Serializable

@TcpDiscoveryEnsureDelivery
@TcpDiscoveryRedirectToClient
public class TcpDiscoveryNodeAddedMessage
extends TcpDiscoveryAbstractMessage

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

Field Summary

Fields inherited from class org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryAbstractMessage

CLIENT_FLAG_POS, CLIENT_RECON_SUCCESS_FLAG_POS, RESPONDED_FLAG_POS

Constructor Summary

Constructors

Constructor and Description
TcpDiscoveryNodeAddedMessage() Public default no-arg constructor for Externalizable interface.
TcpDiscoveryNodeAddedMessage(UUID creatorNodeId, TcpDiscoveryNode node, Map<Integer,Object> newNodeDiscoData, long gridStartTime) Constructor.

Method Summary

Methods

Modifier and Type	Method and Description
void	addDiscoveryData(UUID nodeId, Map<Integer,Object> discoData)
void	clearDiscoveryData() Clears discovery data to minimize message size.
IgniteUuid	discardedMessageId() Gets discarded message ID.
long	gridStartTime()
Collection<TcpDiscoveryAbstractMessage>	messages() Gets pending messages sent to new node by its previous.
void	messages(Collection<TcpDiscoveryAbstractMessage> msgs, IgniteUuid discardMsgId) Sets pending messages to send to new node.
Map<Integer,Object>	newNodeDiscoveryData()
TcpDiscoveryNode	node() Gets newly added node.
Map<UUID,Map<Integer,Object>>	oldNodesDiscoveryData()
void	readExternal(ObjectInput in)
Collection<TcpDiscoveryNode>	topology() Gets topology.
void	topology(Collection<TcpDiscoveryNode> top) Sets topology.
Map<Long,Collection<ClusterNode>>	topologyHistory() Gets topology snapshots history.
void	topologyHistory(Map<Long,Collection<ClusterNode>> topHist) Sets topology snapshots history.
String	toString()
void	writeExternal(ObjectOutput out)

Methods inherited from class org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryAbstractMessage

client, client, creatorNodeId, destinationClientNodeId, destinationClientNodeId, equals, getFlag, hashCode, id, pendingIndex, pendingIndex, senderNodeId, senderNodeId, setFlag, topologyVersion, topologyVersion, verified, verifierNodeId, verify

Methods inherited from class java.lang.Object

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

Constructor Detail

TcpDiscoveryNodeAddedMessage

public TcpDiscoveryNodeAddedMessage()

Public default no-arg constructor for Externalizable interface.

TcpDiscoveryNodeAddedMessage

public TcpDiscoveryNodeAddedMessage(UUID creatorNodeId,
                            TcpDiscoveryNode node,
                            Map<Integer,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 TcpDiscoveryNode node()

Gets newly added node.

Returns:

New node.

messages

@Nullable
public Collection<TcpDiscoveryAbstractMessage> messages()

Gets pending messages sent to new node by its previous.

Returns:

Pending messages from previous node.

discardedMessageId

@Nullable
public IgniteUuid discardedMessageId()

Gets discarded message ID.

Returns:

Discarded message ID.

messages

public void messages(@Nullable
            Collection<TcpDiscoveryAbstractMessage> msgs,
            @Nullable
            IgniteUuid discardMsgId)

Sets pending messages to send to new node.

Parameters:

msgs - Pending messages to send to new node.

discardMsgId - Discarded message ID.

topology

@Nullable
public Collection<TcpDiscoveryNode> topology()

Gets topology.

Returns:

Current topology.

topology

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

Sets topology.

Parameters:

top - Current topology.

topologyHistory

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

Gets topology snapshots history.

Returns:

Map with topology snapshots history.

topologyHistory

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

Sets topology snapshots history.

Parameters:

topHist - Map with topology snapshots history.

newNodeDiscoveryData

public Map<Integer,Object> newNodeDiscoveryData()

Returns:

Discovery data from new node.

oldNodesDiscoveryData

public Map<UUID,Map<Integer,Object>> oldNodesDiscoveryData()

Returns:

Discovery data from old nodes.

addDiscoveryData

public void addDiscoveryData(UUID nodeId,
                    Map<Integer,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 TcpDiscoveryAbstractMessage

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Overrides:

readExternal in class TcpDiscoveryAbstractMessage

Throws:

IOException

ClassNotFoundException

toString

public String toString()

Overrides:

toString in class TcpDiscoveryAbstractMessage