com.fr.third.jgroups.blocks

类 TCPConnectionMap.TCPConnection

java.lang.Object

com.fr.third.jgroups.blocks.TCPConnectionMap.TCPConnection

所有已实现的接口:

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

封闭类:

TCPConnectionMap

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

嵌套类概要

嵌套类

限定符和类型	类和说明
protected class	TCPConnectionMap.TCPConnection.Receiver
protected class	TCPConnectionMap.TCPConnection.Sender

字段概要

字段

限定符和类型	字段和说明
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

构造器概要

构造器

构造器和说明
TCPConnectionMap.TCPConnection(Address peer_addr) Creates a connection stub and binds it, use connect(java.net.SocketAddress) to connect
TCPConnectionMap.TCPConnection(java.net.Socket s)

方法概要

方法

限定符和类型	方法和说明
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(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()

从类继承的方法 java.lang.Object

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

字段详细资料

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

构造器详细资料

TCPConnectionMap.TCPConnection

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

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

抛出:

java.lang.Exception

TCPConnectionMap.TCPConnection

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

抛出:

java.lang.Exception

方法详细资料

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(Address)

抛出:

java.lang.Exception

start

protected TCPConnectionMap.TCPConnection start(ThreadFactory f)

send

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

参数:

data - Guaranteed to be non null

offset -

length -

抛出:

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

参数:

data -

offset -

length -

acquire_lock -

抛出:

java.lang.Exception

doSend

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

抛出:

java.lang.Exception

flush

protected void flush()
              throws java.lang.Exception

抛出:

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

抛出:

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.

抛出:

java.lang.Exception

matchCookie

protected boolean matchCookie(byte[] input)

toString

public java.lang.String toString()

覆盖:

toString 在类中 java.lang.Object

isExpired

public boolean isExpired(long now)

指定者:

isExpired 在接口中 Connection

isConnected

public boolean isConnected()

isOpen

public boolean isOpen()

指定者:

isOpen 在接口中 Connection

close

public void close()
           throws java.io.IOException

指定者:

close 在接口中 Connection

指定者:

close 在接口中 java.io.Closeable

指定者:

close 在接口中 java.lang.AutoCloseable

抛出:

java.io.IOException