com.hazelcast.internal.networking.nio

Class NioChannel

java.lang.Object

com.hazelcast.internal.networking.AbstractChannel

com.hazelcast.internal.networking.nio.NioChannel

All Implemented Interfaces:

Channel, Closeable, AutoCloseable

public class NioChannel
extends AbstractChannel

A Channel implementation tailored for non blocking IO using Selector in combination with a non blocking SocketChannel.

Field Summary

Fields inherited from class com.hazelcast.internal.networking.AbstractChannel

socketChannel

Constructor Summary

Constructors

Constructor and Description
NioChannel(SocketChannel socketChannel, boolean clientMode)

Method Summary

Modifier and Type	Method and Description
void	flush() Flushes whatever needs to be written.
NioChannelReader	getReader()
NioChannelWriter	getWriter()
long	lastReadTimeMillis() Returns the last Clock.currentTimeMillis() a read of the socket was done.
long	lastWriteTimeMillis() Returns the last Clock.currentTimeMillis() that a write to the socket completed.
protected void	onClose() Template method that is called when the socket channel closed.
void	setReader(NioChannelReader reader)
void	setWriter(NioChannelWriter writer)
String	toString()
boolean	write(OutboundFrame frame) Queues the OutboundFrame to be written at some point in the future.

Methods inherited from class com.hazelcast.internal.networking.AbstractChannel

addCloseListener, attributeMap, close, closeInbound, closeOutbound, getLocalSocketAddress, getRemoteSocketAddress, isClientMode, isClosed, read, socket, socketChannel, write

Methods inherited from class java.lang.Object

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

Constructor Detail

NioChannel

public NioChannel(SocketChannel socketChannel,
                  boolean clientMode)

Method Detail

setReader

public void setReader(NioChannelReader reader)

setWriter

public void setWriter(NioChannelWriter writer)

getReader

public NioChannelReader getReader()

getWriter

public NioChannelWriter getWriter()

write

public boolean write(OutboundFrame frame)

Description copied from interface: Channel

Queues the OutboundFrame to be written at some point in the future. No guarantee is made that the frame actually is going to be written or received.

Parameters:

frame - the frame to write.

Returns:

true if the frame was queued; false if rejected.

lastReadTimeMillis

public long lastReadTimeMillis()

Description copied from interface: Channel

Returns the last Clock.currentTimeMillis() a read of the socket was done.

Returns:

the last time a read from the socket was done.

lastWriteTimeMillis

public long lastWriteTimeMillis()

Description copied from interface: Channel

Returns the last Clock.currentTimeMillis() that a write to the socket completed. Writing to the socket doesn't mean that data has been send or received; it means that data was written to the SocketChannel. It could very well be that this data is stuck somewhere in an io-buffer.

Returns:

the last time something was written to the socket.

flush

public void flush()

Description copied from interface: Channel

Flushes whatever needs to be written. Normally this call doesn't need to be made since Channel.write(OutboundFrame) write the content; but in case of protocol and TLS handshaking, such triggers are needed.

onClose

protected void onClose()

Description copied from class: AbstractChannel

Template method that is called when the socket channel closed. It is called before the socketChannel is closed.

It will be called only once.

Overrides:

onClose in class AbstractChannel

toString

public String toString()

Overrides:

toString in class Object