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:

Closeable, AutoCloseable

public class TcpConnectionNonBlocking
extends TcpConnection

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

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	TcpConnectionNonBlocking.Sender

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

TcpConnection.Receiver

Field Summary

Fields

Modifier and Type	Field	Description
protected final LongAdder	dropped_msgs
protected int	max_size
protected final BlockingQueue<ByteArray>	queue
protected TcpConnectionNonBlocking.Sender	sender

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

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

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

cookie, last_access, peer_addr, server

Constructor Summary

Constructors

Constructor	Description
TcpConnectionNonBlocking(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 String	name()
int	queueSize()
void	send(byte[] data, int offset, int length)
protected boolean	senderRunning()
void	start()
String	toString()

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

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

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 Details

queue

protected final BlockingQueue<ByteArray> queue

max_size

protected int max_size

sender

protected volatile TcpConnectionNonBlocking.Sender sender

dropped_msgs

protected final LongAdder dropped_msgs

Constructor Details

TcpConnectionNonBlocking

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

Throws:

Exception

TcpConnectionNonBlocking

public TcpConnectionNonBlocking(Socket s,
 TcpServer server,
 int max_size)
                         throws Exception

Throws:

Exception

Method Details

maxSize

public int maxSize()

droppedMessages

public long droppedMessages()

queueSize

public int queueSize()

start

public void start()

Overrides:

start in class TcpConnection

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class TcpConnection

Throws:

IOException

send

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

Overrides:

send in class TcpConnection

Throws:

Exception

toString

public String toString()

Overrides:

toString in class TcpConnection

name

protected String name()

senderRunning

protected boolean senderRunning()