org.jgroups.blocks

Class AbstractConnectionMap<V extends Connection>

java.lang.Object

org.jgroups.blocks.AbstractConnectionMap<V>

All Implemented Interfaces:

ConnectionMap<V>

public abstract class AbstractConnectionMap<V extends Connection>
extends 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 List<AbstractConnectionMap.ConnectionMapListener<V>>	conn_listeners
protected Map<Address,V>	conns
protected ThreadFactory	factory
protected Lock	lock
protected Log	log
protected org.jgroups.blocks.AbstractConnectionMap.Reaper	reaper
protected long	reaperInterval

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
void	addConnection(Address address, V conn)
void	addConnectionMapListener(AbstractConnectionMap.ConnectionMapListener<V> cml)
protected void	clear()
Lock	getLock()
int	getNumConnections()
ThreadFactory	getThreadFactory()
boolean	hasConnection(Address address)
boolean	hasOpenConnection(Address address)
protected void	notifyConnectionClosed(Address address)
protected void	notifyConnectionOpened(Address address, V conn)
String	printConnections()
void	removeConnection(Address address)
void	removeConnectionMapListener(AbstractConnectionMap.ConnectionMapListener<V> cml)
void	retainAll(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 List<AbstractConnectionMap.ConnectionMapListener<V extends Connection>> conn_listeners

conns

protected final Map<Address,V extends Connection> conns

lock

protected final Lock lock

factory

protected final ThreadFactory factory

reaperInterval

protected final long reaperInterval

reaper

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

log

protected final Log log

Constructor Detail

AbstractConnectionMap

public AbstractConnectionMap(ThreadFactory factory)

AbstractConnectionMap

public AbstractConnectionMap(ThreadFactory factory,
                     long reaperInterval)

Method Detail

getLock

public Lock getLock()

hasOpenConnection

public boolean hasOpenConnection(Address address)

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

printConnections

public String printConnections()

getThreadFactory

public ThreadFactory getThreadFactory()

removeConnection

public void removeConnection(Address address)

removeConnectionMapListener

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

retainAll

public void retainAll(Collection<Address> current_mbrs)

Removes all connections which are not in current_mbrs

Parameters:

current_mbrs -

start

public void start()
           throws Exception

Throws:

Exception

stop

public void stop()

clear

protected void clear()

notifyConnectionClosed

protected void notifyConnectionClosed(Address address)

notifyConnectionOpened

protected void notifyConnectionOpened(Address address,
                          V conn)