Package org.apache.ignite.internal.util.nio

Class GridAbstractCommunicationClient

java.lang.Object

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

All Implemented Interfaces:

GridCommunicationClient

Direct Known Subclasses:

GridTcpNioCommunicationClient

public abstract class GridAbstractCommunicationClient
extends Object
implements GridCommunicationClient

Implements basic lifecycle for communication clients.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	GridAbstractCommunicationClient(int connIdx)

Method Summary

Modifier and Type	Method	Description
boolean	async()
boolean	close()
boolean	closed()
int	connectionIndex()
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()
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.util.nio.GridCommunicationClient

doHandshake, sendMessage, sendMessage, sendMessage

Constructor Detail

GridAbstractCommunicationClient

protected GridAbstractCommunicationClient(int connIdx)

Parameters:

connIdx - Connection index.

Method Detail

connectionIndex

public int connectionIndex()

Specified by:

connectionIndex in interface GridCommunicationClient

Returns:

Connection index.

close

public boolean close()

Specified by:

close in interface GridCommunicationClient

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

closed

public boolean closed()

Specified by:

closed in interface GridCommunicationClient

Returns:

True if client is closed;

reserve

public boolean reserve()

Specified by:

reserve in interface GridCommunicationClient

Returns:

True if client was reserved, false otherwise.

release

public void release()

Releases this client by decreasing reservations.

Specified by:

release in interface GridCommunicationClient

getIdleTime

public long getIdleTime()

Gets idle time of this client.

Specified by:

getIdleTime in interface GridCommunicationClient

Returns:

Idle time of this client.

markUsed

protected void markUsed()

Updates used time.

async

public boolean async()

Specified by:

async in interface GridCommunicationClient

Returns:

True if send is asynchronous.

toString

public String toString()

Overrides:

toString in class Object