com.hazelcast.internal.networking.nonblocking

Class NonBlockingSocketWriter

java.lang.Object

com.hazelcast.internal.networking.nonblocking.AbstractHandler

com.hazelcast.internal.networking.nonblocking.NonBlockingSocketWriter

All Implemented Interfaces:

MigratableHandler, SelectionHandler, SocketWriter, Runnable

public final class NonBlockingSocketWriter
extends AbstractHandler
implements Runnable, SocketWriter

The writing side of the TcpIpConnection.

Field Summary

Fields

Modifier and Type	Field and Description
Queue<OutboundFrame>	urgentWriteQueue
Queue<OutboundFrame>	writeQueue

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

connection, eventCount, ioThread, logger, selectionKey, socketChannel

Constructor Summary

Constructors

Constructor and Description
NonBlockingSocketWriter(SocketConnection connection, NonBlockingIOThread ioThread, ILogger logger, IOBalancer balancer, SocketWriterInitializer initializer)

Method Summary

Modifier and Type	Method and Description
long	bytesPending()
void	close() Closes this SocketWriter.
WriteHandler	getWriteHandler() Gets the WriteHandler that belongs to this SocketWriter.
void	handle() Called when there are bytes available for reading, or space available to write.
void	initOutputBuffer(ByteBuffer outputBuffer)
void	initWriteHandler(WriteHandler writeHandler)
long	lastWriteTimeMillis() Returns the last Clock.currentTimeMillis() that a write to the socket completed.
long	priorityBytesPending()
void	requestMigration(NonBlockingIOThread newOwner) Requests the MigratableHandler to move to the new NonBlockingIOThread.
void	run()
void	setProtocol(String protocol) Sets the protocol this SocketWriter should use.
String	toString()
int	totalFramesPending() Returns the total number of packets (urgent and non normal priority) pending to be written to the socket.
void	write(OutboundFrame frame) Offers a Frame to be written to the socket.

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

getEventCount, getOwner, getSelectionKey, getSocketChannel, onFailure

Methods inherited from class java.lang.Object

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

Field Detail

writeQueue

public final Queue<OutboundFrame> writeQueue

urgentWriteQueue

public final Queue<OutboundFrame> urgentWriteQueue

Constructor Detail

NonBlockingSocketWriter

public NonBlockingSocketWriter(SocketConnection connection,
                               NonBlockingIOThread ioThread,
                               ILogger logger,
                               IOBalancer balancer,
                               SocketWriterInitializer initializer)

Method Detail

totalFramesPending

public int totalFramesPending()

Description copied from interface: SocketWriter

Returns the total number of packets (urgent and non normal priority) pending to be written to the socket.

Specified by:

totalFramesPending in interface SocketWriter

Returns:

total number of pending packets.

lastWriteTimeMillis

public long lastWriteTimeMillis()

Description copied from interface: SocketWriter

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.

Specified by:

lastWriteTimeMillis in interface SocketWriter

Returns:

the last time something was written to the socket.

getWriteHandler

public WriteHandler getWriteHandler()

Description copied from interface: SocketWriter

Gets the WriteHandler that belongs to this SocketWriter. This method exists for the TextReadHandler, but probably should be deleted.

Specified by:

getWriteHandler in interface SocketWriter

Returns:

the WriteHandler

bytesPending

public long bytesPending()

priorityBytesPending

public long priorityBytesPending()

setProtocol

public void setProtocol(String protocol)

Description copied from interface: SocketWriter

Sets the protocol this SocketWriter should use. This should be called only once at the beginning of the connection. See Protocols

Specified by:

setProtocol in interface SocketWriter

Parameters:

protocol - the protocol

initOutputBuffer

public void initOutputBuffer(ByteBuffer outputBuffer)

Specified by:

initOutputBuffer in interface SocketWriter

write

public void write(OutboundFrame frame)

Description copied from interface: SocketWriter

Offers a Frame to be written to the socket. No guarantees are made that the frame is going to be written or received by the other side.

Specified by:

write in interface SocketWriter

Parameters:

frame - the Frame to write.

handle

public void handle()
            throws Exception

Description copied from interface: SelectionHandler

Called when there are bytes available for reading, or space available to write. Any exception that leads to a termination of the connection like an IOException should not be handled in the handle method but should be propagated. The reason behind this is that the handle logic already is complicated enough and by pulling it out the flow will be easier to understand.

Specified by:

handle in interface SelectionHandler

Throws:

Exception

initWriteHandler

public void initWriteHandler(WriteHandler writeHandler)

Specified by:

initWriteHandler in interface SocketWriter

run

public void run()

Specified by:

run in interface Runnable

close

public void close()

Description copied from interface: SocketWriter

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

Specified by:

close in interface SocketWriter

requestMigration

public void requestMigration(NonBlockingIOThread newOwner)

Description copied from interface: MigratableHandler

Requests the MigratableHandler to move to the new NonBlockingIOThread. This call will not wait for the migration to complete. This method can be called by any thread, and will probably be called by the IOBalancer. Call is ignored when handler is moving to the same NonBlockingIOThread.

Specified by:

requestMigration in interface MigratableHandler

Parameters:

newOwner - the NonBlockingIOThread that is going to own this MigratableHandler

toString

public String toString()

Overrides:

toString in class Object