com.hazelcast.internal.networking.spinning

Class SpinningChannel

java.lang.Object

com.hazelcast.internal.networking.AbstractChannel

com.hazelcast.internal.networking.spinning.SpinningChannel

All Implemented Interfaces:

Channel, Closeable, AutoCloseable

public class SpinningChannel
extends AbstractChannel

Field Summary

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

socketChannel

Constructor Summary

Constructors

Constructor and Description
SpinningChannel(SocketChannel socketChannel, boolean clientMode)

Method Summary

Modifier and Type	Method and Description
void	flush() Flushes whatever needs to be written.
SpinningChannelReader	getReader()
SpinningChannelWriter	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.
void	setReader(SpinningChannelReader reader)
void	setWriter(SpinningChannelWriter 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, onClose, read, socket, socketChannel, write

Methods inherited from class java.lang.Object

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

Constructor Detail

SpinningChannel

public SpinningChannel(SocketChannel socketChannel,
                       boolean clientMode)

Method Detail

setReader

public void setReader(SpinningChannelReader reader)

setWriter

public void setWriter(SpinningChannelWriter writer)

getReader

public SpinningChannelReader getReader()

getWriter

public SpinningChannelWriter 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.

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.

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.

toString

public String toString()

Overrides:

toString in class Object