org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication

Class HadoopTcpNioCommunicationClient

java.lang.Object

org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopAbstractCommunicationClient

org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopTcpNioCommunicationClient

All Implemented Interfaces:

HadoopCommunicationClient

public class HadoopTcpNioCommunicationClient
extends HadoopAbstractCommunicationClient

Grid client for NIO server.

Constructor Summary

Constructors

Constructor and Description
HadoopTcpNioCommunicationClient() Constructor for test purposes only.
HadoopTcpNioCommunicationClient(GridNioSession ses)

Method Summary

Modifier and Type	Method and Description
boolean	close()
void	forceClose() Forces client close.
long	getIdleTime() Gets idle time of this client.
void	sendMessage(HadoopProcessDescriptor desc, HadoopMessage msg)
String	toString()

Methods inherited from class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopAbstractCommunicationClient

closed, markUsed, release, reserve, reserved

Methods inherited from class java.lang.Object

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

Constructor Detail

HadoopTcpNioCommunicationClient

public HadoopTcpNioCommunicationClient()

Constructor for test purposes only.

HadoopTcpNioCommunicationClient

public HadoopTcpNioCommunicationClient(GridNioSession ses)

Parameters:

ses - Session.

Method Detail

close

public boolean close()

Specified by:

close in interface HadoopCommunicationClient

Overrides:

close in class HadoopAbstractCommunicationClient

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 HadoopCommunicationClient

Overrides:

forceClose in class HadoopAbstractCommunicationClient

sendMessage

public void sendMessage(HadoopProcessDescriptor desc,
                        HadoopMessage msg)
                 throws IgniteCheckedException

Parameters:

desc - Process descriptor.

msg - Message to send.

Throws:

IgniteCheckedException - If failed.

getIdleTime

public long getIdleTime()

Gets idle time of this client.

Specified by:

getIdleTime in interface HadoopCommunicationClient

Overrides:

getIdleTime in class HadoopAbstractCommunicationClient

Returns:

Idle time of this client.

toString

public String toString()

Overrides:

toString in class HadoopAbstractCommunicationClient