com.hazelcast.client.connection.nio

Class ClientConnection

java.lang.Object

com.hazelcast.client.connection.nio.ClientConnection

All Implemented Interfaces:

Connection, Closeable, AutoCloseable

public class ClientConnection
extends Object
implements Connection, Closeable

Field Summary

Fields

Modifier and Type	Field and Description
protected int	connectionId

Constructor Summary

Constructors

Constructor and Description
ClientConnection(HazelcastClientInstanceImpl client, int connectionId)
ClientConnection(HazelcastClientInstanceImpl client, IOSelector in, IOSelector out, int connectionId, SocketChannelWrapper socketChannelWrapper)

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Closes this connection.
void	close(Throwable t)
void	decrementPendingPacketCount()
boolean	equals(Object o)
ClientConnectionManager	getConnectionManager()
Address	getEndPoint() Gets the Address of the other side of this Connection.
InetAddress	getInetAddress() Returns remote address of this Connection.
InetSocketAddress	getLocalSocketAddress()
int	getPendingPacketCount()
int	getPort() The remote port.
ClientReadHandler	getReadHandler()
Address	getRemoteEndpoint()
InetSocketAddress	getRemoteSocketAddress() Returns the address of the endpoint this Connection is connected to, or null if it is unconnected.
SerializationService	getSerializationService()
SocketChannelWrapper	getSocketChannelWrapper()
ConnectionType	getType() Returns the ConnectionType of this Connection.
int	hashCode()
void	incrementPendingPacketCount()
void	init()
protected void	innerClose()
boolean	isAlive() Checks if the Connection is still alive.
boolean	isClient() Checks if it is a client connection.
boolean	isHeartBeating()
long	lastReadTime() Returns the clock time of the most recent read using this connection.
long	lastWriteTime() Returns the clock time of the most recent write using this connection.
void	setRemoteEndpoint(Address remoteEndpoint)
String	toString()
boolean	write(SocketWritable packet) Writes a SocketWritable packet to the other side.

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

connectionId

protected final int connectionId

Constructor Detail

ClientConnection

public ClientConnection(HazelcastClientInstanceImpl client,
                IOSelector in,
                IOSelector out,
                int connectionId,
                SocketChannelWrapper socketChannelWrapper)
                 throws IOException

Throws:

IOException

ClientConnection

public ClientConnection(HazelcastClientInstanceImpl client,
                int connectionId)
                 throws IOException

Throws:

IOException

Method Detail

incrementPendingPacketCount

public void incrementPendingPacketCount()

decrementPendingPacketCount

public void decrementPendingPacketCount()

getPendingPacketCount

public int getPendingPacketCount()

getSerializationService

public SerializationService getSerializationService()

write

public boolean write(SocketWritable packet)

Description copied from interface: Connection

Writes a SocketWritable packet to the other side.

The packet could be stored in an internal queue before it actually is written, so this call doesn't need to be a synchronous call.

Specified by:

write in interface Connection

Parameters:

packet - the packet to write.

Returns:

false if the packet was not accepted to be written, e.g. because the Connection was not alive.

init

public void init()
          throws IOException

Throws:

IOException

getEndPoint

public Address getEndPoint()

Description copied from interface: Connection

Gets the Address of the other side of this Connection.

todo: rename to get remoteAddress?

Specified by:

getEndPoint in interface Connection

Returns:

the Address.

isAlive

public boolean isAlive()

Description copied from interface: Connection

Checks if the Connection is still alive.

Specified by:

isAlive in interface Connection

Returns:

true if alive, false otherwise.

lastReadTime

public long lastReadTime()

Description copied from interface: Connection

Returns the clock time of the most recent read using this connection.

Specified by:

lastReadTime in interface Connection

Returns:

the clock time of the most recent read

lastWriteTime

public long lastWriteTime()

Description copied from interface: Connection

Returns the clock time of the most recent write using this connection.

Specified by:

lastWriteTime in interface Connection

Returns:

the clock time of the most recent write.

close

public void close()

Description copied from interface: Connection

Closes this connection.

Pending packets on this connection are discarded

If the Connection already is closed, the call is ignored. So it can safely be called multiple times.

Specified by:

close in interface Connection

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

getType

public ConnectionType getType()

Description copied from interface: Connection

Returns the ConnectionType of this Connection.

Specified by:

getType in interface Connection

Returns:

the ConnectionType. It could be that null is returned.

isClient

public boolean isClient()

Description copied from interface: Connection

Checks if it is a client connection.

Specified by:

isClient in interface Connection

Returns:

true if client connection, false otherwise.

getInetAddress

public InetAddress getInetAddress()

Description copied from interface: Connection

Returns remote address of this Connection.

Specified by:

getInetAddress in interface Connection

Returns:

the remote address. The returned value could be null if the connection is not alive.

getRemoteSocketAddress

public InetSocketAddress getRemoteSocketAddress()

Description copied from interface: Connection

Returns the address of the endpoint this Connection is connected to, or null if it is unconnected.

Specified by:

getRemoteSocketAddress in interface Connection

Returns:

address of the endpoint.

todo: do we really need this method because we have getInetAddress, InetSocketAddress and getEndPoint.

getPort

public int getPort()

Description copied from interface: Connection

The remote port.

todo: rename to getRemotePort? And do we need it because we already have getEndPoint which returns an address which includes port. It is only used in testing

Specified by:

getPort in interface Connection

Returns:

the remote port number to which this Connection is connected, or 0 if the socket is not connected yet.

getSocketChannelWrapper

public SocketChannelWrapper getSocketChannelWrapper()

getConnectionManager

public ClientConnectionManager getConnectionManager()

getReadHandler

public ClientReadHandler getReadHandler()

setRemoteEndpoint

public void setRemoteEndpoint(Address remoteEndpoint)

getRemoteEndpoint

public Address getRemoteEndpoint()

getLocalSocketAddress

public InetSocketAddress getLocalSocketAddress()

innerClose

protected void innerClose()
                   throws IOException

Throws:

IOException

close

public void close(Throwable t)

isHeartBeating

public boolean isHeartBeating()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object