org.codehaus.wadi.impl
Class ClusteredManager

java.lang.Object
  org.codehaus.wadi.impl.StandardManager
      org.codehaus.wadi.impl.DistributableManager
          org.codehaus.wadi.impl.ClusteredManager

All Implemented Interfaces:

ClusteredContextualiserConfig, Config, ContextualiserConfig, DispatcherConfig, DistributableContextualiserConfig, DistributableSessionConfig, Lifecycle, PartitionManagerConfig, ReplicableSessionConfig, RouterConfig, SessionConfig, StreamerConfig

public class ClusteredManager

extends DistributableManager

implements ClusteredContextualiserConfig, DispatcherConfig, PartitionManagerConfig

Field Summary

protected Collapser	_collapser
protected DIndex	_dindex
protected Dispatcher	_dispatcher
protected Map	_distributedState
protected ProxiedLocation	_location
protected PartitionManager	_partitionManager
protected InvocationProxy	_proxy

Fields inherited from class org.codehaus.wadi.impl.DistributableManager

_accessOnLoad, _classLoader, _helpers, _replicaterFactory, _shuttingDown, _streamer

Fields inherited from class org.codehaus.wadi.impl.StandardManager

_acceptingSessions, _attributeListeners, _attributesFactory, _config, _contextualiser, _errorCounter, _errorIfSessionNotAcquired, _filter, _log, _map, _maxInactiveInterval, _router, _sessionIdFactory, _sessionListeners, _sessionPool, _sessionWrapperFactory, _started, _timer, _valuePool

Constructor Summary

ClusteredManager(SessionPool sessionPool, AttributesFactory attributesFactory, ValuePool valuePool, SessionWrapperFactory sessionWrapperFactory, SessionIdFactory sessionIdFactory, Contextualiser contextualiser, Map sessionMap, Router router, boolean errorIfSessionNotAcquired, Streamer streamer, boolean accessOnLoad, ReplicaterFactory replicaterFactory, ProxiedLocation location, InvocationProxy proxy, Dispatcher dispatcher, PartitionManager partitionManager, Collapser collapser)

Method Summary

void	aboutToStop()
boolean	contextualise(InvocationContext invocationContext, String id, Immoter immoter, Sync motionLock, boolean exclusiveOnly)
void	destroy(Session session)
void	destroy(String key)
void	distributeState()
void	findRelevantSessionNames(int numPartitions, Collection[] resultSet)
String	getContextPath()
Node	getCoordinatorNode()
DIndex	getDIndex()
Dispatcher	getDispatcher()
Map	getDistributedState()
Object	getDistributedState(Object key)
Immoter	getImmoter(String name, Motable immotable)
long	getInactiveTime()
Sync	getInvocationLock(String name)
InvocationProxy	getInvocationProxy()
String	getNodeName()
String	getNodeName(Destination destination)
int	getNumPartitions()
ProxiedLocation	getProxiedLocation()
void	init(ManagerConfig config)
void	notifySessionDeletion(String name)
void	notifySessionInsertion(String name)
void	notifySessionRelocation(String name)
Object	putDistributedState(Object key, Object newValue)
Object	removeDistributedState(Object key)
void	start()
void	stop()
protected boolean	validateSessionName(String name)

Methods inherited from class org.codehaus.wadi.impl.DistributableManager

deregisterHelper, findHelper, getAccessOnLoad, getClassLoader, getDistributable, getHttpSessionAttributeListenersRegistered, getReplicater, getShuttingDown, getStreamer, registerHelper

Methods inherited from class org.codehaus.wadi.impl.StandardManager

create, destroy, expire, getAcceptingSessions, getAttributeListeners, getAttributesFactory, getContextualiser, getErrorCount, getErrorIfSessionNotAcquired, getEvictionImmoter, getHttpPort, getManager, getMaxInactiveInterval, getRouter, getServletContext, getSessionCookieDomain, getSessionCookieName, getSessionCookiePath, getSessionIdFactory, getSessionListeners, getSessionPool, getSessionUrlParamName, getSessionWrapperFactory, getTimer, getValuePool, incrementErrorCounter, isStarted, notifySessionCreation, notifySessionDestruction, setAttributelisteners, setFilter, setLastAccessedTime, setMaxInactiveInterval, setMaxInactiveInterval, setSessionListeners

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.codehaus.wadi.DistributableContextualiserConfig

getAccessOnLoad, getContextualiser, getShuttingDown

Methods inherited from interface org.codehaus.wadi.ContextualiserConfig

expire, getEvictionImmoter, getMaxInactiveInterval, getRouter, getSessionPool, getTimer

Methods inherited from interface org.codehaus.wadi.SessionConfig

getAttributeListeners, getAttributesFactory, getMaxInactiveInterval, getRouter, getServletContext, getSessionIdFactory, getSessionListeners, getSessionWrapperFactory, getValuePool, setLastAccessedTime, setMaxInactiveInterval

Field Detail

_dispatcher

protected final Dispatcher _dispatcher

_partitionManager

protected final PartitionManager _partitionManager

_distributedState

protected final Map _distributedState

_collapser

protected final Collapser _collapser

_dindex

protected DIndex _dindex

_proxy

protected final InvocationProxy _proxy

_location

protected final ProxiedLocation _location

Constructor Detail

ClusteredManager

public ClusteredManager(SessionPool sessionPool,
                        AttributesFactory attributesFactory,
                        ValuePool valuePool,
                        SessionWrapperFactory sessionWrapperFactory,
                        SessionIdFactory sessionIdFactory,
                        Contextualiser contextualiser,
                        Map sessionMap,
                        Router router,
                        boolean errorIfSessionNotAcquired,
                        Streamer streamer,
                        boolean accessOnLoad,
                        ReplicaterFactory replicaterFactory,
                        ProxiedLocation location,
                        InvocationProxy proxy,
                        Dispatcher dispatcher,
                        PartitionManager partitionManager,
                        Collapser collapser)

Method Detail

getContextPath

public String getContextPath()

Specified by:

getContextPath in interface DispatcherConfig

init

public void init(ManagerConfig config)

Overrides:

init in class DistributableManager

start

public void start()
           throws Exception

Specified by:

start in interface Lifecycle

Overrides:

start in class StandardManager

Throws:

Exception

aboutToStop

public void aboutToStop()
                 throws Exception

Overrides:

aboutToStop in class StandardManager

Throws:

Exception

stop

public void stop()
          throws Exception

Specified by:

stop in interface Lifecycle

Overrides:

stop in class StandardManager

Throws:

Exception

destroy

public void destroy(String key)

destroy

public void destroy(Session session)

Specified by:

destroy in interface SessionConfig

Overrides:

destroy in class StandardManager

getNodeName

public String getNodeName()

Specified by:

getNodeName in interface ClusteredContextualiserConfig

getDistributedState

public Object getDistributedState(Object key)

Specified by:

getDistributedState in interface ClusteredContextualiserConfig

putDistributedState

public Object putDistributedState(Object key,
                                  Object newValue)

Specified by:

putDistributedState in interface ClusteredContextualiserConfig

removeDistributedState

public Object removeDistributedState(Object key)

Specified by:

removeDistributedState in interface ClusteredContextualiserConfig

distributeState

public void distributeState()
                     throws Exception

Specified by:

distributeState in interface ClusteredContextualiserConfig

Throws:

Exception

getDistributedState

public Map getDistributedState()

Specified by:

getDistributedState in interface ClusteredContextualiserConfig

getInactiveTime

public long getInactiveTime()

Specified by:

getInactiveTime in interface ClusteredContextualiserConfig

getNumPartitions

public int getNumPartitions()

Specified by:

getNumPartitions in interface ClusteredContextualiserConfig

getDispatcher

public Dispatcher getDispatcher()

Specified by:

getDispatcher in interface ClusteredContextualiserConfig

getDIndex

public DIndex getDIndex()

Specified by:

getDIndex in interface ClusteredContextualiserConfig

notifySessionInsertion

public void notifySessionInsertion(String name)

Specified by:

notifySessionInsertion in interface ContextualiserConfig

Overrides:

notifySessionInsertion in class StandardManager

notifySessionDeletion

public void notifySessionDeletion(String name)

Specified by:

notifySessionDeletion in interface ContextualiserConfig

Overrides:

notifySessionDeletion in class StandardManager

notifySessionRelocation

public void notifySessionRelocation(String name)

Specified by:

notifySessionRelocation in interface ContextualiserConfig

Overrides:

notifySessionRelocation in class StandardManager

validateSessionName

protected boolean validateSessionName(String name)

Overrides:

validateSessionName in class StandardManager

findRelevantSessionNames

public void findRelevantSessionNames(int numPartitions,
                                     Collection[] resultSet)

Specified by:

findRelevantSessionNames in interface PartitionManagerConfig

getInvocationProxy

public InvocationProxy getInvocationProxy()

Specified by:

getInvocationProxy in interface ClusteredContextualiserConfig

getProxiedLocation

public ProxiedLocation getProxiedLocation()

Specified by:

getProxiedLocation in interface ClusteredContextualiserConfig

getCoordinatorNode

public Node getCoordinatorNode()

Specified by:

getCoordinatorNode in interface PartitionManagerConfig

contextualise

public boolean contextualise(InvocationContext invocationContext,
                             String id,
                             Immoter immoter,
                             Sync motionLock,
                             boolean exclusiveOnly)
                      throws InvocationException

Specified by:

contextualise in interface PartitionManagerConfig

Throws:

InvocationException

getImmoter

public Immoter getImmoter(String name,
                          Motable immotable)

Specified by:

getImmoter in interface PartitionManagerConfig

getNodeName

public String getNodeName(Destination destination)

Specified by:

getNodeName in interface PartitionManagerConfig

getInvocationLock

public Sync getInvocationLock(String name)

Specified by:

getInvocationLock in interface PartitionManagerConfig