org.jgroups.blocks

Class AbstractConnectionMap<V extends Connection>

java.lang.Object

org.jgroups.blocks.AbstractConnectionMap<V>

All Implemented Interfaces:

ConnectionMap<V>

Direct Known Subclasses:

TCPConnectionMap.Mapper

public abstract class AbstractConnectionMap<V extends Connection>
extends java.lang.Object
implements ConnectionMap<V>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	AbstractConnectionMap.ConnectionMapListener<V>

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.List<AbstractConnectionMap.ConnectionMapListener<V>>	conn_listeners
protected java.util.Map<Address,V>	conns
protected ThreadFactory	factory
protected java.util.concurrent.locks.Lock	lock
protected org.jgroups.blocks.AbstractConnectionMap.Reaper	reaper
protected long	reaperInterval
protected java.util.concurrent.locks.Lock	sock_creation_lock

Constructor Summary

Constructors

Constructor and Description
AbstractConnectionMap(ThreadFactory factory)
AbstractConnectionMap(ThreadFactory factory, long reaperInterval)

Method Summary

Modifier and Type	Method and Description
void	addConnection(Address address, V conn)
void	addConnectionMapListener(AbstractConnectionMap.ConnectionMapListener<V> cml)
protected void	clear()
java.util.concurrent.locks.Lock	getLock()
int	getNumConnections()
int	getNumOpenConnections()
ThreadFactory	getThreadFactory()
boolean	hasConnection(Address address)
protected void	notifyConnectionClosed(Address address)
protected void	notifyConnectionOpened(Address address, V conn)
java.lang.String	printConnections()
void	removeConnectionIfPresent(Address address, V conn) Only removes the connection if conns.get(address) == conn
void	removeConnectionMapListener(AbstractConnectionMap.ConnectionMapListener<V> cml)
void	retainAll(java.util.Collection<Address> current_mbrs) Removes all connections which are not in current_mbrs
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jgroups.blocks.ConnectionMap

getConnection

Field Detail

conn_listeners

protected final java.util.List<AbstractConnectionMap.ConnectionMapListener<V extends Connection>> conn_listeners

conns

protected final java.util.Map<Address,V extends Connection> conns

lock

protected final java.util.concurrent.locks.Lock lock

sock_creation_lock

protected final java.util.concurrent.locks.Lock sock_creation_lock

factory

protected final ThreadFactory factory

reaperInterval

protected final long reaperInterval

reaper

protected final org.jgroups.blocks.AbstractConnectionMap.Reaper reaper

Constructor Detail

AbstractConnectionMap

public AbstractConnectionMap(ThreadFactory factory)

AbstractConnectionMap

public AbstractConnectionMap(ThreadFactory factory,
                             long reaperInterval)

Method Detail

getLock

public java.util.concurrent.locks.Lock getLock()

hasConnection

public boolean hasConnection(Address address)

addConnection

public void addConnection(Address address,
                          V conn)

addConnectionMapListener

public void addConnectionMapListener(AbstractConnectionMap.ConnectionMapListener<V> cml)

getNumConnections

public int getNumConnections()

getNumOpenConnections

public int getNumOpenConnections()

printConnections

public java.lang.String printConnections()

getThreadFactory

public ThreadFactory getThreadFactory()

removeConnectionIfPresent

public void removeConnectionIfPresent(Address address,
                                      V conn)

Only removes the connection if conns.get(address) == conn

removeConnectionMapListener

public void removeConnectionMapListener(AbstractConnectionMap.ConnectionMapListener<V> cml)

retainAll

public void retainAll(java.util.Collection<Address> current_mbrs)

Removes all connections which are not in current_mbrs

Parameters:

current_mbrs -

start

public void start()
           throws java.lang.Exception

Throws:

java.lang.Exception

stop

public void stop()

clear

protected void clear()

notifyConnectionClosed

protected void notifyConnectionClosed(Address address)

notifyConnectionOpened

protected void notifyConnectionOpened(Address address,
                                      V conn)