ClusterContextualiser (WADI :: Core 2.0-SNAPSHOT API)

Overview

Package

Class

Use

Tree

Deprecated

Index

Help

PREV CLASS NEXT CLASS

FRAMES NO FRAMES

SUMMARY: NESTED | FIELD | CONSTR | METHOD

DETAIL: FIELD | CONSTR | METHOD

org.codehaus.wadi.impl
Class ClusterContextualiser

java.lang.Object
  org.codehaus.wadi.impl.AbstractContextualiser
      org.codehaus.wadi.impl.AbstractChainedContextualiser
          org.codehaus.wadi.impl.AbstractMotingContextualiser
              org.codehaus.wadi.impl.AbstractSharedContextualiser
                  org.codehaus.wadi.impl.ClusterContextualiser

All Implemented Interfaces:: ClusterListener, Config, Contextualiser, EventListener, Lifecycle, RelocaterConfig, StateManager.ImmigrationListener

public class ClusterContextualiser
extends AbstractSharedContextualiser
implements RelocaterConfig, ClusterListener, StateManager.ImmigrationListener

A cache of Locations. If the Location of a Context is not known, the Cluster may be queried for it. If it is forthcoming, we can proxy to it. After a given number of successful proxies, the Context will be migrated to this Contextualiser which should promote it so that future requests for it can be run straight off the top of the stack. Node N1 sends LocationRequest to Cluster Node N2 contextualises this request with a FilterChain that will send a LocationResponse and wait a specified handover period. Node N1 receives the response, updates its cache and then proxies through the Location to the required resource. The promotion mutex is held correctly during the initial Location lookup, so that searches for the same Context are correctly collapsed. Proxy should be applied before Migration- if it succeeds, we don't migrate... This class is getting out of hand !

Version:: $Revision: 1430 $
Author:: Jules Gosnell

Field Summary
`protected Cluster`	`_cluster`
`protected Collapser`	`_collapser`
`protected DIndex`	`_dindex`
`protected ActiveClusterDispatcher`	`_dispatcher`
`protected Emoter`	`_emoter`
`protected boolean`	`_evacuating`
`protected static String`	`_evacuatingKey`
`protected SynchronizedInt`	`_evacuationPartnerCount`
`protected Immoter`	`_immoter`
`protected HttpProxyLocation`	`_location`
`protected int`	`_locationMaxInactiveInterval`
`protected Log`	`_lockLog`
`protected String`	`_nodeName`
`protected static String`	`_nodeNameKey`
`protected ProxiedLocation`	`_proxiedLocation`
`protected Relocater`	`_relocater`
`protected int`	`_resTimeout`
`protected SynchronizedBoolean`	`_shuttingDown`
`protected static String`	`_shuttingDownKey`
`protected Contextualiser`	`_top`

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

_clean, _config, _locker

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

_next

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

_log

Constructor Summary
`ClusterContextualiser(Contextualiser next, Collapser collapser, Relocater relocater)`

Method Summary
`protected void`	`createEvacuationQueue()`
`void`	`destroy()`
`protected void`	`destroyEvacuationQueue()`
`protected void`	`ensureEvacuationJoined(String nodeName)`
`protected void`	`ensureEvacuationLeft(String nodeName)`
`protected void`	`ensureEvacuationQueue()`
`Motable`	`get(String name)`
`Collapser`	`getCollapser()`
`Contextualiser`	`getContextualiser()`
`Immoter`	`getDemoter(String name, Motable motable)` Return a Demoter to the first Contextualiser which would be happy to accept this Motable - in other words - would not evict() it.
`DIndex`	`getDIndex()`
`Dispatcher`	`getDispatcher()`
`Emoter`	`getEmoter()`
`protected int`	`getEvacuationPartnersCount()`
`Immoter`	`getImmoter()`
`InvocationProxy`	`getInvocationProxy()`
`Location`	`getLocation()`
`String`	`getNodeName()`
`ProxiedLocation`	`getProxiedLocation()`
`Immoter`	`getSharedDemoter()`
`SynchronizedBoolean`	`getShuttingDown()`
`String`	`getStartInfo()`
`boolean`	`handle(InvocationContext invocationContext, String id, Immoter immoter, Sync motionLock)`
`void`	`init(ContextualiserConfig config)`
`void`	`load(Emoter emoter, Immoter immoter)`
`void`	`notifySessionRelocation(String name)`
`void`	`onCoordinatorChanged(ClusterEvent event)`
`void`	`onImmigration(ObjectMessage message, Motable emotable)`
`void`	`onNodeAdd(ClusterEvent event)`
`void`	`onNodeFailed(ClusterEvent event)`
`void`	`onNodeRemoved(ClusterEvent event)`
`void`	`onNodeStateChange(ClusterEvent event)`
`void`	`onNodeUpdate(ClusterEvent event)`
`protected void`	`refreshEvacuationPartnersCount()`
`void`	`stop()`

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

getLocalSessionCount, isExclusive

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

contextualise, getPromoter, promote, promoteToExclusive

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

findRelevantSessionNames, setLastAccessedTime, setMaxInactiveInterval, start

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

getStopInfo

Methods inherited from class java.lang.Object

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

Field Detail

_nodeNameKey

protected static final String _nodeNameKey

See Also:: Constant Field Values

_shuttingDownKey

protected static final String _shuttingDownKey

See Also:: Constant Field Values

_evacuatingKey

protected static final String _evacuatingKey

See Also:: Constant Field Values

_evacuationPartnerCount

protected final SynchronizedInt _evacuationPartnerCount

_collapser

protected final Collapser _collapser

_relocater

protected final Relocater _relocater

_immoter

protected final Immoter _immoter

_emoter

protected final Emoter _emoter

_resTimeout

protected final int _resTimeout

See Also:: Constant Field Values

_lockLog

protected final Log _lockLog

_shuttingDown

protected SynchronizedBoolean _shuttingDown

_nodeName

protected String _nodeName

_evacuating

protected boolean _evacuating

_dispatcher

protected ActiveClusterDispatcher _dispatcher

_cluster

protected Cluster _cluster

_location

protected HttpProxyLocation _location

_proxiedLocation

protected ProxiedLocation _proxiedLocation

_dindex

protected DIndex _dindex

_top

protected Contextualiser _top

_locationMaxInactiveInterval

protected int _locationMaxInactiveInterval

Constructor Detail