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

Class SHMemHandshakeClosure

java.lang.Object

org.apache.ignite.internal.util.lang.IgniteInClosure2X<InputStream,OutputStream>

org.apache.ignite.spi.communication.tcp.internal.shmem.SHMemHandshakeClosure

All Implemented Interfaces:

Serializable, IgniteBiInClosure<InputStream,OutputStream>

public class SHMemHandshakeClosure
extends IgniteInClosure2X<InputStream,OutputStream>

Does handshake for a shmem mode.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SHMemHandshakeClosure(IgniteLogger log, UUID rmtNodeId, ClusterStateProvider stateProvider, Supplier<ClusterNode> locNodeSupplier)

Method Summary

Modifier and Type	Method and Description
void	applyx(InputStream in, OutputStream out) In-closure body that can throw IgniteCheckedException.

Methods inherited from class org.apache.ignite.internal.util.lang.IgniteInClosure2X

apply

Methods inherited from class java.lang.Object

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

Constructor Detail

SHMemHandshakeClosure

public SHMemHandshakeClosure(IgniteLogger log,
                             UUID rmtNodeId,
                             ClusterStateProvider stateProvider,
                             Supplier<ClusterNode> locNodeSupplier)

Parameters:

log - Logger.

rmtNodeId - Remote node ID.

stateProvider - Cluster state provider.

locNodeSupplier - Local node getter.

Method Detail

applyx

public void applyx(InputStream in,
                   OutputStream out)
            throws IgniteCheckedException

In-closure body that can throw IgniteCheckedException.

Specified by:

applyx in class IgniteInClosure2X<InputStream,OutputStream>

Parameters:

in - First variable the closure is called or closed on.

out - Second variable the closure is called or closed on.

Throws:

IgniteCheckedException - Thrown in case of any error condition inside of the closure.