org.glassfish.web.ha.session.management
Class ReplicationManagerBase

java.lang.Object
  org.apache.catalina.session.ManagerBase
      org.apache.catalina.session.PersistentManagerBase
          org.glassfish.web.ha.session.management.ReplicationManagerBase

All Implemented Interfaces:

java.beans.PropertyChangeListener, java.util.EventListener, javax.management.MBeanRegistration, Lifecycle, Manager

Direct Known Subclasses:

ReplicationWebEventPersistentManager

public abstract class ReplicationManagerBase
extends PersistentManagerBase

Author:

Rajiv Mordani

Field Summary

protected org.glassfish.ha.store.api.BackingStore	backingStore
protected boolean	disableJreplica
protected java.util.logging.Logger	logger
protected static java.lang.String	name
protected boolean	relaxCacheVersionSemantics
protected java.util.concurrent.locks.ReentrantReadWriteLock	rwl
protected SessionFactory	sessionFactory

Fields inherited from class org.apache.catalina.session.PersistentManagerBase

invalidatedSessions, lifecycle

Fields inherited from class org.apache.catalina.session.ManagerBase

container, debug, defaultContext, devRandomSource, distributable, domain, duplicates, entropy, expiredSessions, initialized, maxActive, maxActiveUpdateLock, maxInactiveInterval, mserver, oname, random, randomClass, randomIS, rejectedSessions, sessionAverageAliveTime, sessionCounter, sessionIdLength, sessionLocker, sessionMaxAliveTime, sessions, sm, support, uuidGenerator

Fields inherited from interface org.apache.catalina.Lifecycle

AFTER_START_EVENT, AFTER_STOP_EVENT, BEFORE_START_EVENT, BEFORE_STOP_EVENT, INIT_EVENT, START_EVENT, STOP_EVENT

Constructor Summary

ReplicationManagerBase()

Method Summary

void	acquireReadLock()
void	acquireWriteLock()
abstract <T extends java.io.Serializable> void	createBackingStore(java.lang.String persistenceType, java.lang.String storeName, java.lang.Class<T> metadataClass, java.util.HashMap vendorMap)
Session	createEmptySession()
Session	createNewSession()
void	doRemove(java.lang.String id)
abstract void	doValveSave(Session session)
Session	findSession(java.lang.String id, java.lang.String version)
org.glassfish.ha.store.api.BackingStore	getBackingStore()
abstract java.lang.String	getReplicaFromPredictor(java.lang.String sessionId, java.lang.String oldJreplicaValue)
boolean	isDisableJreplica()
boolean	isRelaxCacheVersionSemantics() should relax cache version semantics be applied
boolean	isSessionVersioningSupported()
void	releaseReadLock()
void	releaseWriteLock()
void	removeSessionFromManagerCache(Session session)
void	setBackingStore(org.glassfish.ha.store.api.BackingStore backingStore)
void	setDisableJreplica(boolean disableJreplica)
void	setRelaxCacheVersionSemantics(boolean value) set the relaxCacheVersionSemantics
void	setSessionFactory(SessionFactory sessionFactory)
void	stop()

Methods inherited from class org.apache.catalina.session.PersistentManagerBase

addLifecycleListener, addToInvalidatedSessions, backgroundProcess, clearStore, createSession, createSession, findLifecycleListeners, findSession, findSession, getInfo, getMaxActiveSessions, getMaxIdleBackup, getMaxIdleSwap, getMinIdleSwap, getMonitorAttributeValues, getName, getSaveOnRestart, getStore, isLoaded, isSessionIdValid, isStarted, load, processExpires, processInvalidatedSessions, processMaxActiveSwaps, processMaxIdleBackups, processMaxIdleSwaps, processPersistenceChecks, propertyChange, release, remove, remove, removeFromInvalidatedSessions, removeLifecycleListener, removeSuper, setContainer, setMaxActiveSessions, setMaxIdleBackup, setMaxIdleSwap, setMinIdleSwap, setSaveOnRestart, setStarted, setStore, start, superFindSession, swapIn, swapIn, swapOut, unload, writeSession

Methods inherited from class org.apache.catalina.session.ManagerBase

add, addPropertyChangeListener, changeSessionId, checkSessionAttribute, clearSessions, destroy, expireSession, findSession, findSessions, generateSessionId, generateSessionId, getActiveSessions, getClassName, getContainer, getDebug, getDefaultContext, getDistributable, getDomain, getDuplicates, getEngine, getEntropy, getExpiredSessions, getJvmRoute, getLastAccessedTimeMillis, getMaxActive, getMaxInactiveInterval, getMaxInactiveIntervalSeconds, getNewSession, getObjectName, getRandom, getRandomBytes, getRandomClass, getRandomFile, getRejectedSessions, getSessionAttribute, getSessionAverageAliveTime, getSessionAverageAliveTimeSeconds, getSessionCount, getSessionCounter, getSessionIdLength, getSessionMaxAliveTime, getSessionMaxAliveTimeSeconds, getUuidGenerator, init, listSessionIds, lockSession, log, log, postDeregister, postRegister, postRequestDispatcherProcess, preDeregister, preRegister, preRequestDispatcherProcess, removePropertyChangeListener, setDebug, setDefaultContext, setDistributable, setDuplicates, setEntropy, setExpiredSessions, setMaxActive, setMaxInactiveInterval, setMaxInactiveIntervalSeconds, setRandomClass, setRandomFile, setRejectedSessions, setSessionAverageAliveTime, setSessionAverageAliveTimeSeconds, setSessionCount, setSessionCounter, setSessionIdLength, setSessionLocker, setSessionMaxAliveTime, setSessionMaxAliveTimeSeconds, setUuidGenerator, toCookie, unlockSession, update

Methods inherited from class java.lang.Object

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

Field Detail

backingStore

protected org.glassfish.ha.store.api.BackingStore backingStore

sessionFactory

protected SessionFactory sessionFactory

rwl

protected final java.util.concurrent.locks.ReentrantReadWriteLock rwl

name

protected static final java.lang.String name

See Also:

Constant Field Values

logger

protected java.util.logging.Logger logger

relaxCacheVersionSemantics

protected boolean relaxCacheVersionSemantics

disableJreplica

protected boolean disableJreplica

Constructor Detail

ReplicationManagerBase

public ReplicationManagerBase()

Method Detail

getBackingStore

public org.glassfish.ha.store.api.BackingStore getBackingStore()

createBackingStore

public abstract <T extends java.io.Serializable> void createBackingStore(java.lang.String persistenceType,
                                                                         java.lang.String storeName,
                                                                         java.lang.Class<T> metadataClass,
                                                                         java.util.HashMap vendorMap)

createNewSession

public Session createNewSession()

createEmptySession

public Session createEmptySession()

Specified by:

createEmptySession in interface Manager

Overrides:

createEmptySession in class ManagerBase

setSessionFactory

public void setSessionFactory(SessionFactory sessionFactory)

setBackingStore

public void setBackingStore(org.glassfish.ha.store.api.BackingStore backingStore)

doRemove

public void doRemove(java.lang.String id)

isSessionVersioningSupported

public boolean isSessionVersioningSupported()

Specified by:

isSessionVersioningSupported in interface Manager

Overrides:

isSessionVersioningSupported in class ManagerBase

findSession

public Session findSession(java.lang.String id,
                           java.lang.String version)
                    throws java.io.IOException

Specified by:

findSession in interface Manager

Overrides:

findSession in class ManagerBase

Throws:

java.io.IOException

isRelaxCacheVersionSemantics

public boolean isRelaxCacheVersionSemantics()

should relax cache version semantics be applied

setRelaxCacheVersionSemantics

public void setRelaxCacheVersionSemantics(boolean value)

set the relaxCacheVersionSemantics

Parameters:

value -

removeSessionFromManagerCache

public void removeSessionFromManagerCache(Session session)

setDisableJreplica

public void setDisableJreplica(boolean disableJreplica)

isDisableJreplica

public boolean isDisableJreplica()

acquireReadLock

public void acquireReadLock()
                     throws java.io.IOException

Throws:

java.io.IOException

releaseReadLock

public void releaseReadLock()

acquireWriteLock

public void acquireWriteLock()

releaseWriteLock

public void releaseWriteLock()

stop

public void stop()
          throws LifecycleException

Specified by:

stop in interface Lifecycle

Overrides:

stop in class PersistentManagerBase

Throws:

LifecycleException

doValveSave

public abstract void doValveSave(Session session)

getReplicaFromPredictor

public abstract java.lang.String getReplicaFromPredictor(java.lang.String sessionId,
                                                         java.lang.String oldJreplicaValue)