Class SendBuffer

java.lang.Object

services.moleculer.transporter.tcp.SendBuffer

public class SendBuffer
extends Object

Attachment of TcpWriter's SelectionKeys.

Field Summary

Fields

Modifier and Type	Field	Description
protected AtomicReference<ByteBuffer>	blockerBuffer
protected static final ByteBuffer	BUFFER_IS_CLOSED
protected SocketChannel	channel
protected final boolean	debug	Debug mode
final String	host
protected SelectionKey	key
protected static final org.slf4j.Logger	logger
final String	nodeID
final int	port
protected final ConcurrentLinkedQueue<ByteBuffer>	queue

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	SendBuffer(String nodeID, String host, int port, boolean debug)

Method Summary

Modifier and Type	Method	Description
protected boolean	append(byte[] packet)	Adds a packet to the buffer's queue.
protected void	close()
protected void	closeResources()
protected void	connected(SelectionKey key, SocketChannel channel)
LinkedList<byte[]>	getUnsentPackets()
protected boolean	tryToClose()	Tries to close this buffer.
protected void	write()	Writes N bytes to the target channel.

Methods inherited from class Object

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

Field Details

logger

protected static final org.slf4j.Logger logger

queue

protected final ConcurrentLinkedQueue<ByteBuffer> queue

BUFFER_IS_CLOSED

protected static final ByteBuffer BUFFER_IS_CLOSED

blockerBuffer

protected AtomicReference<ByteBuffer> blockerBuffer

nodeID

public final String nodeID

host

public final String host

port

public final int port

debug

protected final boolean debug

Debug mode

channel

protected SocketChannel channel

key

protected SelectionKey key

Constructor Details

SendBuffer

protected SendBuffer(String nodeID,
 String host,
 int port,
 boolean debug)

Method Details

connected

protected void connected(SelectionKey key,
 SocketChannel channel)

append

protected boolean append(byte[] packet)

Adds a packet to the buffer's queue.

Parameters:

packet - packet to write

Returns:

true, if success (false = buffer is closed)

tryToClose

protected boolean tryToClose()

Tries to close this buffer.

Returns:

true, is closed (false = buffer is not empty)

close

protected void close()

closeResources

protected void closeResources()

write

protected void write()
              throws Exception

Writes N bytes to the target channel.

Throws:

Exception - any I/O exception

getUnsentPackets

public LinkedList<byte[]> getUnsentPackets()