Package org.jgroups.blocks.cs

Class TcpConnectionNonBlocking

java.lang.Object

org.jgroups.blocks.cs.Connection

org.jgroups.blocks.cs.TcpConnection

org.jgroups.blocks.cs.TcpConnectionNonBlocking

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, java.lang.Runnable

public class TcpConnectionNonBlocking
extends TcpConnection
implements java.lang.Runnable

TCP connection which (despite the fancy name) blocks only a single thread at most. Uses a bounded queue, to which senders add their messages, and a single consumer sending the messages. When the queue is full, messages will get dropped. Therefore, at most one thread is blocked on TCP write when the send-window is full.
Link: https://issues.redhat.com/browse/JGRP-2759

Since:

5.3.3

Author:

Bela Ban

Nested Class Summary

Nested classes/interfaces inherited from class org.jgroups.blocks.cs.TcpConnection

TcpConnection.Receiver

Field Summary

Fields

Modifier and Type	Field	Description
protected java.util.concurrent.atomic.LongAdder	dropped_msgs
protected int	max_size
protected java.util.concurrent.BlockingQueue<ByteArray>	queue
protected FastArray<ByteArray>	remove_queue
protected int	rq_capacity
protected Runner	sender

Fields inherited from class org.jgroups.blocks.cs.TcpConnection

connected, in, length_buf, out, receiver, sock, use_lock_to_send, writers

Fields inherited from class org.jgroups.blocks.cs.Connection

cookie, last_access, peer_addr, send_lock, server

Constructor Summary

Constructors

Constructor	Description
TcpConnectionNonBlocking(java.net.Socket s, TcpServer server, int max_size)
TcpConnectionNonBlocking(Address peer_addr, TcpBaseServer server, int max_size)

Method Summary

Modifier and Type	Method	Description
void	close()
long	droppedMessages()
int	maxSize()
protected java.lang.String	name()
int	queueSize()
void	run()
void	send(byte[] data, int offset, int length)
boolean	senderRunning()
void	start()
java.lang.String	toString()

Methods inherited from class org.jgroups.blocks.cs.TcpConnection

connect, connect, createDataInputStream, createDataOutputStream, doSend, flush, getSockAddress, isClosed, isConnected, isConnectionPending, localAddress, locklessSend, readPeerAddress, send, sendLocalAddress, setSocketParameters, status, useLockToSend, useLockToSend

Methods inherited from class org.jgroups.blocks.cs.Connection

getTimestamp, isExpired, peerAddress, updateLastAccessed

Methods inherited from class java.lang.Object

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

Field Detail

queue

protected final java.util.concurrent.BlockingQueue<ByteArray> queue

max_size

protected int max_size

sender

protected final Runner sender

dropped_msgs

protected final java.util.concurrent.atomic.LongAdder dropped_msgs

remove_queue

protected final FastArray<ByteArray> remove_queue

rq_capacity

protected int rq_capacity

Constructor Detail

TcpConnectionNonBlocking

public TcpConnectionNonBlocking(Address peer_addr,
                                TcpBaseServer server,
                                int max_size)
                         throws java.lang.Exception

Throws:

java.lang.Exception

TcpConnectionNonBlocking

public TcpConnectionNonBlocking(java.net.Socket s,
                                TcpServer server,
                                int max_size)
                         throws java.lang.Exception

Throws:

java.lang.Exception

Method Detail

maxSize

public int maxSize()

droppedMessages

public long droppedMessages()

queueSize

public int queueSize()

senderRunning

public boolean senderRunning()

start

public void start()

Overrides:

start in class TcpConnection

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable

Overrides:

close in class TcpConnection

Throws:

java.io.IOException

send

public void send(byte[] data,
                 int offset,
                 int length)
          throws java.lang.Exception

Overrides:

send in class TcpConnection

Throws:

java.lang.Exception

run

public void run()

Specified by:

run in interface java.lang.Runnable

toString

public java.lang.String toString()

Overrides:

toString in class TcpConnection

name

protected java.lang.String name()