org.apache.ignite.internal.util.nio

Class GridShmemCommunicationClient

java.lang.Object

org.apache.ignite.internal.util.nio.GridAbstractCommunicationClient

org.apache.ignite.internal.util.nio.GridShmemCommunicationClient

All Implemented Interfaces:

GridCommunicationClient

public class GridShmemCommunicationClient
extends GridAbstractCommunicationClient

Field Summary

Fields

Modifier and Type	Field and Description
protected @Nullable AtomicLongMetric	sentBytesCntMetric Sent bytes count metric.

Constructor Summary

Constructors

Constructor and Description
GridShmemCommunicationClient(int connIdx, MetricRegistry mreg, int port, long connTimeout, IgniteLogger log, MessageFormatter formatter)

Method Summary

Modifier and Type	Method and Description
boolean	close()
void	doHandshake(IgniteInClosure2X<InputStream,OutputStream> handshakeC) Executes the given handshake closure on opened client passing underlying IO streams.
void	forceClose() Forces client close.
void	sendMessage(byte[] data, int len)
void	sendMessage(ByteBuffer data)
boolean	sendMessage(UUID nodeId, Message msg, IgniteInClosure<IgniteException> c)
String	toString()

Methods inherited from class org.apache.ignite.internal.util.nio.GridAbstractCommunicationClient

async, closed, connectionIndex, getIdleTime, markUsed, release, reserve

Methods inherited from class java.lang.Object

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

Field Detail

sentBytesCntMetric

@Nullable
protected final @Nullable AtomicLongMetric sentBytesCntMetric

Sent bytes count metric.

Constructor Detail

GridShmemCommunicationClient

public GridShmemCommunicationClient(int connIdx,
                                    MetricRegistry mreg,
                                    int port,
                                    long connTimeout,
                                    IgniteLogger log,
                                    MessageFormatter formatter)
                             throws IgniteCheckedException

Parameters:

connIdx - Connection index.

mreg - Metrics registry.

port - Shared memory IPC server port.

connTimeout - Connection timeout.

log - Logger.

formatter - Message formatter.

Throws:

IgniteCheckedException - If failed.

Method Detail

doHandshake

public void doHandshake(IgniteInClosure2X<InputStream,OutputStream> handshakeC)
                 throws IgniteCheckedException

Executes the given handshake closure on opened client passing underlying IO streams. This method pulled to client interface a handshake is only operation requiring access to both output and input streams.

Parameters:

handshakeC - Handshake.

Throws:

IgniteCheckedException - If handshake failed.

close

public boolean close()

Specified by:

close in interface GridCommunicationClient

Overrides:

close in class GridAbstractCommunicationClient

Returns:

True if client has been closed by this call, false if failed to close client (due to concurrent reservation or concurrent close).

forceClose

public void forceClose()

Forces client close.

Specified by:

forceClose in interface GridCommunicationClient

Overrides:

forceClose in class GridAbstractCommunicationClient

sendMessage

public void sendMessage(byte[] data,
                        int len)
                 throws IgniteCheckedException

Parameters:

data - Data to send.

len - Length.

Throws:

IgniteCheckedException - If failed.

sendMessage

public boolean sendMessage(UUID nodeId,
                           Message msg,
                           IgniteInClosure<IgniteException> c)
                    throws IgniteCheckedException

Parameters:

nodeId - Remote node ID. Provided only for sync clients.

msg - Message to send.

c - Ack closure.

Returns:

True if should try to resend message.

Throws:

IgniteCheckedException - If failed.

sendMessage

public void sendMessage(ByteBuffer data)
                 throws IgniteCheckedException

Parameters:

data - Data to send.

Throws:

IgniteCheckedException - If failed.

toString

public String toString()

Overrides:

toString in class GridAbstractCommunicationClient