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

Class HadoopAbstractCommunicationClient

java.lang.Object

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

All Implemented Interfaces:

HadoopCommunicationClient

Direct Known Subclasses:

HadoopTcpNioCommunicationClient

public abstract class HadoopAbstractCommunicationClient
extends Object
implements HadoopCommunicationClient

Implements basic lifecycle for communication clients.

Constructor Summary

Constructors

Constructor and Description
HadoopAbstractCommunicationClient()

Method Summary

Modifier and Type	Method and Description
boolean	close()
boolean	closed()
void	forceClose() Forces client close.
long	getIdleTime() Gets idle time of this client.
protected void	markUsed() Updates used time.
void	release() Releases this client by decreasing reservations.
boolean	reserve()
boolean	reserved()
String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopCommunicationClient

sendMessage

Constructor Detail

HadoopAbstractCommunicationClient

public HadoopAbstractCommunicationClient()

Method Detail

close

public boolean close()

Specified by:

close in interface HadoopCommunicationClient

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

closed

public boolean closed()

Specified by:

closed in interface HadoopCommunicationClient

Returns:

True if client is closed;

reserve

public boolean reserve()

Specified by:

reserve in interface HadoopCommunicationClient

Returns:

True if client was reserved, false otherwise.

release

public void release()

Releases this client by decreasing reservations.

Specified by:

release in interface HadoopCommunicationClient

reserved

public boolean reserved()

Specified by:

reserved in interface HadoopCommunicationClient

Returns:

True if client was reserved.

getIdleTime

public long getIdleTime()

Gets idle time of this client.

Specified by:

getIdleTime in interface HadoopCommunicationClient

Returns:

Idle time of this client.

markUsed

protected void markUsed()

Updates used time.

toString

public String toString()

Overrides:

toString in class Object