Package org.apache.ignite.spi.communication.tcp.internal

Class TcpHandshakeExecutor

java.lang.Object

org.apache.ignite.spi.communication.tcp.internal.TcpHandshakeExecutor

public class TcpHandshakeExecutor
extends Object

Executor for synchronously establishing a connection with a node.

Constructor Summary

Constructors

Constructor	Description
TcpHandshakeExecutor(IgniteLogger log, ClusterStateProvider stateProvider, boolean directBuffer)

Method Summary

Modifier and Type	Method	Description
long	tcpHandshake(SocketChannel ch, UUID rmtNodeId, GridSslMeta sslMeta, HandshakeMessage msg)	Establish the first connection to the node and receive connection recovery information.

Methods inherited from class java.lang.Object

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

Constructor Detail

TcpHandshakeExecutor

public TcpHandshakeExecutor(IgniteLogger log,
                            ClusterStateProvider stateProvider,
                            boolean directBuffer)

Parameters:

log - Logger.

stateProvider - State provider.

directBuffer - true if direct buffer for ssl handler is required.

Method Detail

tcpHandshake

public long tcpHandshake(SocketChannel ch,
                         UUID rmtNodeId,
                         GridSslMeta sslMeta,
                         HandshakeMessage msg)
                  throws IgniteCheckedException

Establish the first connection to the node and receive connection recovery information.

Parameters:

ch - Socket channel which using for handshake.

rmtNodeId - Expected remote node.

sslMeta - Required data for ssl.

msg - Handshake message which should be sent during handshake.

Returns:

Handshake response from predefined variants from RecoveryLastReceivedMessage.

Throws:

IgniteCheckedException - If handshake failed.