org.jgroups.blocks.cs

Class TcpConnection

java.lang.Object

org.jgroups.blocks.cs.Connection

org.jgroups.blocks.cs.TcpConnection

All Implemented Interfaces:

Closeable, AutoCloseable

public class TcpConnection
extends Connection

Blocking IO (BIO) connection. Starts 1 reader thread for the peer socket and blocks until data is available. Calls BaseServer.receive(Address,byte[],int,int) when data has been received.

Since:

3.6.5

Author:

Bela Ban

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	TcpConnection.Receiver
protected class	TcpConnection.Sender

Field Summary

Fields

Modifier and Type	Field and Description
protected DataInputStream	in
protected DataOutputStream	out
protected TcpConnection.Receiver	receiver
protected ReentrantLock	send_lock
protected TcpConnection.Sender	sender
protected TcpBaseServer	server
protected Socket	sock
protected static Buffer	termination

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

cookie, last_access, peer_addr

Constructor Summary

Constructors

Constructor and Description
TcpConnection(Address peer_addr, TcpBaseServer server) Creates a connection stub and binds it, use connect(Address) to connect
TcpConnection(Socket s, TcpServer server)

Method Summary

Modifier and Type	Method and Description
protected void	_send(byte[] data, int offset, int length, boolean acquire_lock, boolean flush) Sends data using the 'out' output stream of the socket
void	close()
void	connect(Address dest)
protected void	connect(Address dest, boolean send_local_addr)
protected void	doSend(byte[] data, int offset, int length, boolean acquire_lock, boolean flush)
protected void	flush()
protected String	getSockAddress()
protected long	getTimestamp()
boolean	isConnected()
boolean	isExpired(long now)
boolean	isOpen()
protected boolean	isSenderUsed()
Address	localAddress()
Address	peerAddress()
protected Address	readPeerAddress(Socket client_sock) Reads the peer's address.
void	send(byte[] data, int offset, int length)
void	send(ByteBuffer buf)
protected void	sendLocalAddress(Address local_addr) Send the cookie first, then the our port number.
protected void	setSocketParameters(Socket client_sock)
void	start()
protected String	status()
String	toString()
protected void	updateLastAccessed()

Methods inherited from class java.lang.Object

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

Field Detail

sock

protected final Socket sock

send_lock

protected final ReentrantLock send_lock

termination

protected static final Buffer termination

out

protected DataOutputStream out

in

protected DataInputStream in

sender

protected volatile TcpConnection.Sender sender

receiver

protected volatile TcpConnection.Receiver receiver

server

protected final TcpBaseServer server

Constructor Detail

TcpConnection

public TcpConnection(Address peer_addr,
                     TcpBaseServer server)
              throws Exception

Creates a connection stub and binds it, use connect(Address) to connect

Throws:

Exception

TcpConnection

public TcpConnection(Socket s,
                     TcpServer server)
              throws Exception

Throws:

Exception

Method Detail

localAddress

public Address localAddress()

Specified by:

localAddress in class Connection

peerAddress

public Address peerAddress()

Specified by:

peerAddress in class Connection

getTimestamp

protected long getTimestamp()

isSenderUsed

protected boolean isSenderUsed()

getSockAddress

protected String getSockAddress()

updateLastAccessed

protected void updateLastAccessed()

connect

public void connect(Address dest)
             throws Exception

Specified by:

connect in class Connection

Throws:

Exception

connect

protected void connect(Address dest,
                       boolean send_local_addr)
                throws Exception

Throws:

Exception

start

public void start()

Specified by:

start in class Connection

send

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

Specified by:

send in class Connection

Parameters:

data - Guaranteed to be non null

offset -

length -

Throws:

Exception

send

public void send(ByteBuffer buf)
          throws Exception

Specified by:

send in class Connection

Throws:

Exception

_send

protected void _send(byte[] data,
                     int offset,
                     int length,
                     boolean acquire_lock,
                     boolean flush)
              throws Exception

Sends data using the 'out' output stream of the socket

Parameters:

data -

offset -

length -

acquire_lock -

Throws:

Exception

doSend

protected void doSend(byte[] data,
                      int offset,
                      int length,
                      boolean acquire_lock,
                      boolean flush)
               throws Exception

Throws:

Exception

flush

protected void flush()
              throws Exception

Throws:

Exception

setSocketParameters

protected void setSocketParameters(Socket client_sock)
                            throws SocketException

Throws:

SocketException

sendLocalAddress

protected void sendLocalAddress(Address local_addr)
                         throws Exception

Send the cookie first, then the our port number. If the cookie doesn't match the receiver's cookie, the receiver will reject the connection and close it.

Throws:

Exception

readPeerAddress

protected Address readPeerAddress(Socket client_sock)
                           throws Exception

Reads the peer's address. First a cookie has to be sent which has to match my own cookie, otherwise the connection will be refused

Throws:

Exception

toString

public String toString()

Overrides:

toString in class Object

status

protected String status()

isExpired

public boolean isExpired(long now)

Specified by:

isExpired in class Connection

isConnected

public boolean isConnected()

Specified by:

isConnected in class Connection

isOpen

public boolean isOpen()

Specified by:

isOpen in class Connection

close

public void close()
           throws IOException

Throws:

IOException