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

Class TcpDiscoveryAbstractMessage

java.lang.Object

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

All Implemented Interfaces:

Externalizable, Serializable

Direct Known Subclasses:

TcpDiscoveryAuthFailedMessage, TcpDiscoveryCheckFailedMessage, TcpDiscoveryClientReconnectMessage, TcpDiscoveryCustomEventMessage, TcpDiscoveryDiscardMessage, TcpDiscoveryDuplicateIdMessage, TcpDiscoveryHandshakeRequest, TcpDiscoveryHandshakeResponse, TcpDiscoveryHeartbeatMessage, TcpDiscoveryJoinRequestMessage, TcpDiscoveryLoopbackProblemMessage, TcpDiscoveryNodeAddedMessage, TcpDiscoveryNodeAddFinishedMessage, TcpDiscoveryNodeFailedMessage, TcpDiscoveryNodeLeftMessage, TcpDiscoveryPingRequest, TcpDiscoveryPingResponse, TcpDiscoveryStatusCheckMessage

public abstract class TcpDiscoveryAbstractMessage
extends Object
implements Externalizable

Base class to implement discovery messages.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected static int	CLIENT_FLAG_POS
protected static int	CLIENT_RECON_SUCCESS_FLAG_POS
protected static int	RESPONDED_FLAG_POS

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	TcpDiscoveryAbstractMessage() Default no-arg constructor for Externalizable interface.
protected	TcpDiscoveryAbstractMessage(UUID creatorNodeId) Constructor.

Method Summary

Methods

Modifier and Type	Method and Description
boolean	client() Get client node flag.
void	client(boolean client) Sets client node flag.
UUID	creatorNodeId() Gets creator node.
UUID	destinationClientNodeId()
void	destinationClientNodeId(UUID destClientNodeId)
boolean	equals(Object obj)
protected boolean	getFlag(int pos)
int	hashCode()
IgniteUuid	id() Gets message ID.
short	pendingIndex()
void	pendingIndex(short pendingIdx)
void	readExternal(ObjectInput in)
UUID	senderNodeId() Gets sender node ID.
void	senderNodeId(UUID senderNodeId) Sets sender node ID.
protected void	setFlag(int pos, boolean val)
long	topologyVersion() Gets topology version.
void	topologyVersion(long topVer) Sets topology version.
String	toString()
boolean	verified() Checks whether message is verified.
UUID	verifierNodeId() Gets verifier node ID.
void	verify(UUID verifierNodeId) Verifies the message and stores verifier ID.
void	writeExternal(ObjectOutput out)

Methods inherited from class java.lang.Object

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

Field Detail

CLIENT_FLAG_POS

protected static final int CLIENT_FLAG_POS

See Also:

Constant Field Values

RESPONDED_FLAG_POS

protected static final int RESPONDED_FLAG_POS

See Also:

Constant Field Values

CLIENT_RECON_SUCCESS_FLAG_POS

protected static final int CLIENT_RECON_SUCCESS_FLAG_POS

See Also:

Constant Field Values

Constructor Detail

TcpDiscoveryAbstractMessage

protected TcpDiscoveryAbstractMessage()

Default no-arg constructor for Externalizable interface.

TcpDiscoveryAbstractMessage

protected TcpDiscoveryAbstractMessage(UUID creatorNodeId)

Constructor.

Parameters:

creatorNodeId - Creator node ID.

Method Detail

creatorNodeId

public UUID creatorNodeId()

Gets creator node.

Returns:

Creator node ID.

id

public IgniteUuid id()

Gets message ID.

Returns:

Message ID.

senderNodeId

public UUID senderNodeId()

Gets sender node ID.

Returns:

Sender node ID.

senderNodeId

public void senderNodeId(UUID senderNodeId)

Sets sender node ID.

Parameters:

senderNodeId - Sender node ID.

verified

public boolean verified()

Checks whether message is verified.

Returns:

true if message was verified.

verifierNodeId

public UUID verifierNodeId()

Gets verifier node ID.

Returns:

verifier node ID.

verify

public void verify(UUID verifierNodeId)

Verifies the message and stores verifier ID.

Parameters:

verifierNodeId - Verifier node ID.

topologyVersion

public long topologyVersion()

Gets topology version.

Returns:

Topology version.

topologyVersion

public void topologyVersion(long topVer)

Sets topology version.

Parameters:

topVer - Topology version.

client

public boolean client()

Get client node flag.

Returns:

Client node flag.

client

public void client(boolean client)

Sets client node flag.

Parameters:

client - Client node flag.

destinationClientNodeId

public UUID destinationClientNodeId()

Returns:

Destination client node ID.

destinationClientNodeId

public void destinationClientNodeId(UUID destClientNodeId)

Parameters:

destClientNodeId - Destination client node ID.

pendingIndex

public short pendingIndex()

Returns:

Pending message index.

pendingIndex

public void pendingIndex(short pendingIdx)

Parameters:

pendingIdx - Pending message index.

getFlag

protected boolean getFlag(int pos)

Parameters:

pos - Flag position.

Returns:

Flag value.

setFlag

protected void setFlag(int pos,
           boolean val)

Parameters:

pos - Flag position.

val - Flag value.

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Throws:

IOException

ClassNotFoundException

equals

public final boolean equals(Object obj)

Overrides:

equals in class Object

hashCode

public final int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object