org.jgroups.blocks

Class TCPConnectionMap.TCPConnection

java.lang.Object

org.jgroups.blocks.TCPConnectionMap.TCPConnection

All Implemented Interfaces:

Connection

Enclosing class:

TCPConnectionMap

public class TCPConnectionMap.TCPConnection
extends 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 DataInputStream	in
protected long	last_access
protected DataOutputStream	out
protected Address	peer_addr
protected TCPConnectionMap.TCPConnection.Receiver	receiver
protected Lock	send_lock
protected TCPConnectionMap.TCPConnection.Sender	sender
protected 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(Socket s)

Method Summary

Modifier and Type	Method and Description
protected void	_send(byte[] data, int offset, int length, boolean acquire_lock) Sends data using the 'out' output stream of the socket
void	close()
protected void	connect(SocketAddress destAddr) Called after TCPConnection#TCPConnection(org.jgroups.Address)
protected void	doSend(byte[] data, int offset, int length)
protected Address	getPeerAddress()
protected String	getSockAddress()
boolean	isConnected()
boolean	isExpired(long now)
boolean	isOpen()
protected boolean	isSenderUsed()
protected boolean	matchCookie(byte[] input)
protected Address	readPeerAddress(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)
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 Lock send_lock

cookie

protected final byte[] cookie

out

protected DataOutputStream out

in

protected 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 Exception

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

Throws:

Exception

TCPConnection

public TCPConnection(Socket s)
              throws Exception

Throws:

Exception

Method Detail

getPeerAddress

protected Address getPeerAddress()

isSenderUsed

protected boolean isSenderUsed()

getSockAddress

protected String getSockAddress()

updateLastAccessed

protected void updateLastAccessed()

connect

protected void connect(SocketAddress destAddr)
                throws Exception

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

Throws:

Exception

start

protected TCPConnectionMap.TCPConnection start(ThreadFactory f)

send

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

Parameters:

data - Guaranteed to be non null

offset -

length -

Throws:

Exception

_send

protected void _send(byte[] data,
                     int offset,
                     int length,
                     boolean acquire_lock)
              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)
               throws Exception

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

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

matchCookie

protected boolean matchCookie(byte[] input)

toString

public String toString()

Overrides:

toString in class 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 IOException

Specified by:

close in interface Connection

Throws:

IOException