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, Runnable

@Deprecated(since="5.6.0",
            forRemoval=true)
public class TcpConnectionNonBlocking
extends TcpConnection
implements Runnable

Deprecated, for removal: This API element is subject to removal in a future version.

Use PerDestinationBundler with use_single_sender_thread = false instead (https://redhat.atlassian.net/browse/JGRP-3028)

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 TcpConnection

TcpConnection.Receiver

Field Summary

Fields

Modifier and Type	Field	Description
protected final LongAdder	dropped_msgs	Deprecated, for removal: This API element is subject to removal in a future version.
protected int	max_size	Deprecated, for removal: This API element is subject to removal in a future version.
protected final BlockingQueue<ByteArray>	queue	Deprecated, for removal: This API element is subject to removal in a future version.
protected final FastArray<ByteArray>	remove_queue	Deprecated, for removal: This API element is subject to removal in a future version.
protected int	rq_capacity	Deprecated, for removal: This API element is subject to removal in a future version.
protected final Runner	sender	Deprecated, for removal: This API element is subject to removal in a future version.

Fields inherited from class TcpConnection

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

Fields inherited from class Connection

closed_gracefully, cookie, GRACEFUL_CLOSE, last_access, peer_addr, send_lock, server

Constructor Summary

Constructors

Constructor	Description
TcpConnectionNonBlocking(Socket s, TcpServer server, int max_size)	Deprecated, for removal: This API element is subject to removal in a future version.
TcpConnectionNonBlocking(Address peer_addr, TcpBaseServer server, int max_size)	Deprecated, for removal: This API element is subject to removal in a future version.

Method Summary

Modifier and Type	Method	Description
void	close()	Deprecated, for removal: This API element is subject to removal in a future version.
long	droppedMessages()	Deprecated, for removal: This API element is subject to removal in a future version.
int	maxSize()	Deprecated, for removal: This API element is subject to removal in a future version.
protected String	name()	Deprecated, for removal: This API element is subject to removal in a future version.
int	queueSize()	Deprecated, for removal: This API element is subject to removal in a future version.
void	run()	Deprecated, for removal: This API element is subject to removal in a future version.
void	send(byte[] data, int offset, int length)	Deprecated, for removal: This API element is subject to removal in a future version.
boolean	senderRunning()	Deprecated, for removal: This API element is subject to removal in a future version.
void	start()	Deprecated, for removal: This API element is subject to removal in a future version.
String	toString()	Deprecated, for removal: This API element is subject to removal in a future version.

Methods inherited from class TcpConnection

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

Methods inherited from class Connection

getTimestamp, isClosedGracefully, isExpired, peerAddress, setClosedGracefully, updateLastAccessed

Methods inherited from class Object

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

Field Details

queue

protected final BlockingQueue<ByteArray> queue

Deprecated, for removal: This API element is subject to removal in a future version.

max_size

protected int max_size

Deprecated, for removal: This API element is subject to removal in a future version.

sender

protected final Runner sender

Deprecated, for removal: This API element is subject to removal in a future version.

dropped_msgs

protected final LongAdder dropped_msgs

Deprecated, for removal: This API element is subject to removal in a future version.

remove_queue

protected final FastArray<ByteArray> remove_queue

Deprecated, for removal: This API element is subject to removal in a future version.

rq_capacity

protected int rq_capacity

Deprecated, for removal: This API element is subject to removal in a future version.

Constructor Details

TcpConnectionNonBlocking

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

Deprecated, for removal: This API element is subject to removal in a future version.

Throws:

Exception

TcpConnectionNonBlocking

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

Deprecated, for removal: This API element is subject to removal in a future version.

Throws:

Exception

Method Details

maxSize

public int maxSize()

Deprecated, for removal: This API element is subject to removal in a future version.

droppedMessages

public long droppedMessages()

Deprecated, for removal: This API element is subject to removal in a future version.

queueSize

public int queueSize()

Deprecated, for removal: This API element is subject to removal in a future version.

senderRunning

public boolean senderRunning()

Deprecated, for removal: This API element is subject to removal in a future version.

start

public void start()

Deprecated, for removal: This API element is subject to removal in a future version.

Overrides:

start in class TcpConnection

close

public void close()
           throws IOException

Deprecated, for removal: This API element is subject to removal in a future version.

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

Deprecated, for removal: This API element is subject to removal in a future version.

Overrides:

send in class TcpConnection

Throws:

Exception

run

public void run()

Deprecated, for removal: This API element is subject to removal in a future version.

Specified by:

run in interface Runnable

toString

public String toString()

Deprecated, for removal: This API element is subject to removal in a future version.

Overrides:

toString in class TcpConnection

name

protected String name()

Deprecated, for removal: This API element is subject to removal in a future version.