public class SpinningSocketReader extends AbstractHandler implements SocketReader
connection, connectionManager, ioService, logger
Constructor and Description |
---|
SpinningSocketReader(TcpIpConnection connection,
MetricsRegistry metricsRegistry,
ILogger logger) |
Modifier and Type | Method and Description |
---|---|
void |
destroy()
Destroys 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() |
onFailure
public SpinningSocketReader(TcpIpConnection connection, MetricsRegistry metricsRegistry, ILogger logger)
public long getLastReadTimeMillis()
SocketReader
Clock.currentTimeMillis()
a read of the socket was done.getLastReadTimeMillis
in interface SocketReader
public Counter getNormalFramesReadCounter()
SocketReader
getNormalFramesReadCounter
in interface SocketReader
public Counter getPriorityFramesReadCounter()
SocketReader
getPriorityFramesReadCounter
in interface SocketReader
public void init()
SocketReader
init
in interface SocketReader
public void destroy()
SocketReader
destroy
in interface SocketReader
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.