services.moleculer.transporter.tcp

Class SendBuffer

java.lang.Object

services.moleculer.transporter.tcp.SendBuffer

public class SendBuffer
extends java.lang.Object

Attachment of TcpWriter's SelectionKeys.

Field Summary

Fields

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

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SendBuffer(java.lang.String nodeID, java.lang.String host, int port, boolean debug)

Method Summary

Modifier and Type	Method and Description
protected boolean	append(byte[] packet) Adds a packet to the buffer's queue.
protected void	close()
protected void	closeResources()
protected void	connected(java.nio.channels.SelectionKey key, java.nio.channels.SocketChannel channel)
java.util.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 java.lang.Object

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

Field Detail

logger

protected static final org.slf4j.Logger logger

queue

protected final java.util.concurrent.ConcurrentLinkedQueue<java.nio.ByteBuffer> queue

BUFFER_IS_CLOSED

protected static final java.nio.ByteBuffer BUFFER_IS_CLOSED

blockerBuffer

protected java.util.concurrent.atomic.AtomicReference<java.nio.ByteBuffer> blockerBuffer

nodeID

public final java.lang.String nodeID

host

public final java.lang.String host

port

public final int port

debug

protected final boolean debug

Debug mode

channel

protected java.nio.channels.SocketChannel channel

key

protected java.nio.channels.SelectionKey key

Constructor Detail

SendBuffer

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

Method Detail

connected

protected void connected(java.nio.channels.SelectionKey key,
                         java.nio.channels.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 java.lang.Exception

Writes N bytes to the target channel.

Throws:

java.lang.Exception - any I/O exception

getUnsentPackets

public java.util.LinkedList<byte[]> getUnsentPackets()