org.apache.catalina.tribes.transport.nio

Class NioSender

public class NioSender extends AbstractSender implements DataSender

This class is NOT thread safe and should never be used with more than one thread at a time This is a state machine, handled by the process method States are: - NOT_CONNECTED -> connect() -> CONNECTED - CONNECTED -> setMessage() -> READY TO WRITE - READY_TO_WRITE -> write() -> READY TO WRITE | READY TO READ - READY_TO_READ -> read() -> READY_TO_READ | TRANSFER_COMPLETE - TRANSFER_COMPLETE -> CONNECTED

Version: 1.0

Author: Filip Hanik

Field Summary
protected XByteBuffer	ackbuf
protected boolean	complete
protected boolean	connecting
protected byte[]	current
protected static Log	log
protected ByteBuffer	readbuf
protected int	remaining
protected Selector	selector
protected SocketChannel	socketChannel
protected ByteBuffer	writebuf

Constructor Summary
	NioSender()

Method Summary
void	connect() connect - blocking in this operation
void	disconnect() disconnect
byte[]	getMessage()
Selector	getSelector()
boolean	isComplete()
boolean	process(SelectionKey key, boolean waitForAck) State machine to send data
protected boolean	read(SelectionKey key)
void	reset()
void	setComplete(boolean complete)
void	setMessage(byte[] data) sendMessage
void	setMessage(byte[] data, int offset, int length)
void	setSelector(Selector selector)
protected boolean	write(SelectionKey key)