org.jgroups.blocks

Class TCPConnectionMap.TCPConnection

java.lang.Object

org.jgroups.blocks.TCPConnectionMap.TCPConnection

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, Connection

Enclosing class:

TCPConnectionMap

public class TCPConnectionMap.TCPConnection
extends java.lang.Object
implements Connection

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	TCPConnectionMap.TCPConnection.Receiver
protected class	TCPConnectionMap.TCPConnection.Sender

Field Summary

Fields

Modifier and Type	Field and Description
protected byte[]	cookie
protected java.io.DataInputStream	in
protected long	last_access
protected java.io.DataOutputStream	out
protected Address	peer_addr
protected TCPConnectionMap.TCPConnection.Receiver	receiver
protected java.util.concurrent.locks.ReentrantLock	send_lock
protected TCPConnectionMap.TCPConnection.Sender	sender
protected java.net.Socket	sock

Constructor Summary

Constructors

Constructor and Description
TCPConnection(Address peer_addr) Creates a connection stub and binds it, use connect(java.net.SocketAddress) to connect
TCPConnection(java.net.Socket s)

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()
protected void	connect(java.net.SocketAddress destAddr) Called after TCPConnection#TCPConnection(org.jgroups.Address)
protected void	doSend(byte[] data, int offset, int length, boolean acquire_lock, boolean flush)
protected void	flush()
protected Address	getPeerAddress()
protected java.lang.String	getSockAddress()
protected long	getTimestamp()
boolean	isConnected()
boolean	isExpired(long now)
boolean	isOpen()
protected boolean	isSenderUsed()
protected boolean	matchCookie(byte[] input)
protected Address	readPeerAddress(java.net.Socket client_sock) Reads the peer's address.
protected void	send(byte[] data, int offset, int length)
protected void	sendLocalAddress(Address local_addr) Send the cookie first, then the our port number.
protected TCPConnectionMap.TCPConnection	start(ThreadFactory f)
java.lang.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 java.net.Socket sock

send_lock

protected final java.util.concurrent.locks.ReentrantLock send_lock

cookie

protected final byte[] cookie

out

protected java.io.DataOutputStream out

in

protected java.io.DataInputStream in

peer_addr

protected Address peer_addr

last_access

protected long last_access

sender

protected TCPConnectionMap.TCPConnection.Sender sender

receiver

protected TCPConnectionMap.TCPConnection.Receiver receiver

Constructor Detail

TCPConnection

public TCPConnection(Address peer_addr)
              throws java.lang.Exception

Creates a connection stub and binds it, use connect(java.net.SocketAddress) to connect

Throws:

java.lang.Exception

TCPConnection

public TCPConnection(java.net.Socket s)
              throws java.lang.Exception

Throws:

java.lang.Exception

Method Detail

getTimestamp

protected long getTimestamp()

getPeerAddress

protected Address getPeerAddress()

isSenderUsed

protected boolean isSenderUsed()

getSockAddress

protected java.lang.String getSockAddress()

updateLastAccessed

protected void updateLastAccessed()

connect

protected void connect(java.net.SocketAddress destAddr)
                throws java.lang.Exception

Called after TCPConnection#TCPConnection(org.jgroups.Address)

Throws:

java.lang.Exception

start

protected TCPConnectionMap.TCPConnection start(ThreadFactory f)

send

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

Parameters:

data - Guaranteed to be non null

offset -

length -

Throws:

java.lang.Exception

_send

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

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

Parameters:

data -

offset -

length -

acquire_lock -

Throws:

java.lang.Exception

doSend

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

Throws:

java.lang.Exception

flush

protected void flush()
              throws java.lang.Exception

Throws:

java.lang.Exception

readPeerAddress

protected Address readPeerAddress(java.net.Socket client_sock)
                           throws java.lang.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:

java.lang.Exception

sendLocalAddress

protected void sendLocalAddress(Address local_addr)
                         throws java.lang.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:

java.lang.Exception

matchCookie

protected boolean matchCookie(byte[] input)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

isExpired

public boolean isExpired(long now)

Specified by:

isExpired in interface Connection

isConnected

public boolean isConnected()

isOpen

public boolean isOpen()

Specified by:

isOpen in interface Connection

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface Connection

Throws:

java.io.IOException