com.hazelcast.internal.networking

Interface SocketWriter

All Known Implementing Classes:

NonBlockingSocketWriter, SpinningSocketWriter

public interface SocketWriter

Each TcpIpConnection has a SocketWriter and it writes OutboundFrame instances to the socket. Copying the Frame instances to the byte-buffer is done using the WriteHandler. Each TcpIpConnection has its own SocketWriter instance. Before Hazelcast 3.6 the name of this interface was WriteHandler.

See Also:

SocketReader, ReadHandler, IOThreadingModel

Method Summary

Modifier and Type	Method and Description
void	close() Closes this SocketWriter.
WriteHandler	getWriteHandler() Gets the WriteHandler that belongs to this SocketWriter.
void	initOutputBuffer(ByteBuffer outputBuffer)
void	initWriteHandler(WriteHandler writeHandler)
long	lastWriteTimeMillis() Returns the last Clock.currentTimeMillis() that a write to the socket completed.
void	setProtocol(String protocol) Sets the protocol this SocketWriter should use.
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.

Method Detail

totalFramesPending

int totalFramesPending()

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

Returns:

total number of pending packets.

lastWriteTimeMillis

long lastWriteTimeMillis()

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.

Returns:

the last time something was written to the socket.

write

void write(OutboundFrame frame)

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.

Parameters:

frame - the Frame to write.

getWriteHandler

WriteHandler getWriteHandler()

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

Returns:

the WriteHandler

setProtocol

void setProtocol(String protocol)

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

Parameters:

protocol - the protocol

close

void close()

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.

initOutputBuffer

void initOutputBuffer(ByteBuffer outputBuffer)

initWriteHandler

void initWriteHandler(WriteHandler writeHandler)