Package 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	Description
static interface	AbstractConnectionMap.ConnectionMapListener<V>

Field Summary

Fields

Modifier and Type	Field	Description
protected final Vector<AbstractConnectionMap.ConnectionMapListener<V>>	conn_listeners
protected final Map<Address,V>	conns
protected final ThreadFactory	factory
protected final Lock	lock
protected final Log	log
protected final AbstractConnectionMap<V>.org.jgroups.blocks.AbstractConnectionMap.Reaper	reaper
protected final long	reaperInterval

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	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 Details

conn_listeners

protected final Vector<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 AbstractConnectionMap<V extends Connection>.org.jgroups.blocks.AbstractConnectionMap.Reaper reaper

log

protected final Log log

Constructor Details

AbstractConnectionMap

public AbstractConnectionMap(ThreadFactory factory)

AbstractConnectionMap

public AbstractConnectionMap(ThreadFactory factory,
 long reaperInterval)

Method Details

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)