com.hazelcast.internal.networking.spinning

Class SpinningSocketReader

java.lang.Object

com.hazelcast.internal.networking.spinning.AbstractHandler

com.hazelcast.internal.networking.spinning.SpinningSocketReader

All Implemented Interfaces:

SocketReader

public class SpinningSocketReader
extends AbstractHandler
implements SocketReader

Field Summary

Fields inherited from class com.hazelcast.internal.networking.spinning.AbstractHandler

connection, logger, socketChannel

Constructor Summary

Constructors

Constructor and Description
SpinningSocketReader(SocketConnection connection, ILogger logger, IOOutOfMemoryHandler oomeHandler, SocketReaderInitializer initializer)

Method Summary

Modifier and Type	Method and Description
void	close() Closes this SocketReader.
SwCounter	getNormalFramesReadCounter() Gets the SwCounter that counts the number of normal packets that have been read.
SwCounter	getPriorityFramesReadCounter() Gets the SwCounter that counts the number of priority packets that have been read.
ByteBuffer	getProtocolBuffer()
void	init() Initializes this SocketReader.
void	initInputBuffer(ByteBuffer inputBuffer)
void	initReadHandler(ReadHandler readHandler)
long	lastReadTimeMillis() Returns the last Clock.currentTimeMillis() a read of the socket was done.
void	read()

Methods inherited from class com.hazelcast.internal.networking.spinning.AbstractHandler

getSocketChannel, onFailure

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.hazelcast.internal.networking.SocketReader

getSocketChannel

Constructor Detail

SpinningSocketReader

public SpinningSocketReader(SocketConnection connection,
                            ILogger logger,
                            IOOutOfMemoryHandler oomeHandler,
                            SocketReaderInitializer initializer)

Method Detail

getProtocolBuffer

public ByteBuffer getProtocolBuffer()

Specified by:

getProtocolBuffer in interface SocketReader

initInputBuffer

public void initInputBuffer(ByteBuffer inputBuffer)

Specified by:

initInputBuffer in interface SocketReader

initReadHandler

public void initReadHandler(ReadHandler readHandler)

Specified by:

initReadHandler in interface SocketReader

lastReadTimeMillis

public long lastReadTimeMillis()

Description copied from interface: SocketReader

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

Specified by:

lastReadTimeMillis in interface SocketReader

Returns:

the last time a read from the socket was done.

getNormalFramesReadCounter

public SwCounter getNormalFramesReadCounter()

Description copied from interface: SocketReader

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

Specified by:

getNormalFramesReadCounter in interface SocketReader

Returns:

the normal frame counter.

getPriorityFramesReadCounter

public SwCounter getPriorityFramesReadCounter()

Description copied from interface: SocketReader

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

Specified by:

getPriorityFramesReadCounter in interface SocketReader

Returns:

the priority frame 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 Connection.close(String, Throwable) method.

Specified by:

close in interface SocketReader

read

public void read()
          throws Exception

Throws:

Exception