com.hazelcast.nio.tcp

Interface SocketReader

All Known Implementing Classes:

NonBlockingSocketReader, SpinningSocketReader

public interface SocketReader

The SocketReader is responsible for reading data from the socket, on behalf of a connection, into a ByteBuffer. Once the data is read into the ByteBuffer, this ByteBuffer is passed to the ReadHandler that takes care of the actual processing of the incoming data. Each TcpIpConnection has its own SocketReader instance. There are many different flavors of SocketReader:

1. reader for member to member communication
2. reader for (old and new) client to member communication
3. reader for encrypted member to member communication
4. reader for REST/Memcached

A SocketReader is tightly coupled to the threading model; so a SocketReader instance is created using IOThreadingModel.newSocketReader(TcpIpConnection). Before Hazelcast 3.6 the name of this interface was ReadHandler.

See Also:

ReadHandler, SocketWriter, IOThreadingModel

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Closes this SocketReader.
long	getLastReadTimeMillis() Returns the last Clock.currentTimeMillis() a read of the socket was done.
Counter	getNormalFramesReadCounter() Gets the Counter that counts the number of normal packets that have been read.
Counter	getPriorityFramesReadCounter() Gets the Counter that counts the number of priority packets that have been read.
void	init() Initializes this SocketReader.

Method Detail

getLastReadTimeMillis

long getLastReadTimeMillis()

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

Returns:

the last time a read from the socket was done.

getNormalFramesReadCounter

Counter getNormalFramesReadCounter()

Gets the Counter that counts the number of normal packets that have been read.

Returns:

the normal packets counter.

getPriorityFramesReadCounter

Counter getPriorityFramesReadCounter()

Gets the Counter that counts the number of priority packets that have been read.

Returns:

the priority packets counter.

init

void init()

Initializes this SocketReader. This method is called from an arbitrary thread and is only called once.

close

void close()

Closes this SocketReader. This method can be called from an arbitrary thread, and should only be called once. This should be coordinated through the TcpIpConnection#close() method.