org.jgroups.blocks
Class TCPConnectionMap.Mapper

java.lang.Object
  org.jgroups.blocks.AbstractConnectionMap<TCPConnectionMap.TCPConnection>
      org.jgroups.blocks.TCPConnectionMap.Mapper

All Implemented Interfaces:

ConnectionMap<TCPConnectionMap.TCPConnection>

Enclosing class:

TCPConnectionMap

protected class TCPConnectionMap.Mapper
extends AbstractConnectionMap<TCPConnectionMap.TCPConnection>

Nested Class Summary

Nested classes/interfaces inherited from class org.jgroups.blocks.AbstractConnectionMap

AbstractConnectionMap.ConnectionMapListener<V>

Field Summary

Fields inherited from class org.jgroups.blocks.AbstractConnectionMap

conn_listeners, conns, factory, lock, log, reaper, reaperInterval, sock_creation_lock

Constructor Summary

TCPConnectionMap.Mapper(ThreadFactory factory)

TCPConnectionMap.Mapper(ThreadFactory factory, long reaper_interval)

Method Summary

boolean	connectionEstablishedTo(Address address)
TCPConnectionMap.TCPConnection	getConnection(Address dest)
protected TCPConnectionMap.TCPConnection	getConnectionUnderLock(Address dest)
int	size()
java.lang.String	toString()

Methods inherited from class org.jgroups.blocks.AbstractConnectionMap

addConnection, addConnectionMapListener, clear, getLock, getNumConnections, getThreadFactory, hasConnection, hasOpenConnection, notifyConnectionClosed, notifyConnectionOpened, printConnections, removeConnection, removeConnectionMapListener, retainAll, start, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

TCPConnectionMap.Mapper

public TCPConnectionMap.Mapper(ThreadFactory factory)

TCPConnectionMap.Mapper

public TCPConnectionMap.Mapper(ThreadFactory factory,
                               long reaper_interval)

Method Detail

getConnectionUnderLock

protected TCPConnectionMap.TCPConnection getConnectionUnderLock(Address dest)
                                                         throws java.lang.Exception

Throws:

java.lang.Exception

getConnection

public TCPConnectionMap.TCPConnection getConnection(Address dest)
                                             throws java.lang.Exception

Throws:

java.lang.Exception

connectionEstablishedTo

public boolean connectionEstablishedTo(Address address)

size

public int size()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object