com.hazelcast.nio.tcp.spinning

Class SpinningSocketReader

java.lang.Object

com.hazelcast.nio.tcp.spinning.AbstractHandler

com.hazelcast.nio.tcp.spinning.SpinningSocketReader

All Implemented Interfaces:

SocketReader

public class SpinningSocketReader
extends AbstractHandler
implements SocketReader

Field Summary

Fields inherited from class com.hazelcast.nio.tcp.spinning.AbstractHandler

connection, connectionManager, ioService, logger

Constructor Summary

Constructors

Constructor and Description
SpinningSocketReader(TcpIpConnection connection, MetricsRegistry metricsRegistry, ILogger logger)

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.
void	read()

Methods inherited from class com.hazelcast.nio.tcp.spinning.AbstractHandler

onFailure

Methods inherited from class java.lang.Object

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

Constructor Detail

SpinningSocketReader

public SpinningSocketReader(TcpIpConnection connection,
                    MetricsRegistry metricsRegistry,
                    ILogger logger)

Method Detail

getLastReadTimeMillis

public long getLastReadTimeMillis()

Description copied from interface: SocketReader

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

Specified by:

getLastReadTimeMillis in interface SocketReader

Returns:

the last time a read from the socket was done.

getNormalFramesReadCounter

public Counter getNormalFramesReadCounter()

Description copied from interface: SocketReader

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

Specified by:

getNormalFramesReadCounter in interface SocketReader

Returns:

the normal packets counter.

getPriorityFramesReadCounter

public Counter getPriorityFramesReadCounter()

Description copied from interface: SocketReader

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

Specified by:

getPriorityFramesReadCounter in interface SocketReader

Returns:

the priority packets counter.

init

public void init()

Description copied from interface: SocketReader

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

Specified by:

init in interface SocketReader

close

public void close()

Description copied from interface: SocketReader

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.

Specified by:

close in interface SocketReader

read

public void read()
          throws Exception

Throws:

Exception