org.jboss.cache.interceptors
Class PessimisticLockInterceptor

java.lang.Object
  org.jboss.cache.interceptors.Interceptor
      org.jboss.cache.interceptors.MethodDispacherInterceptor
          org.jboss.cache.interceptors.PessimisticLockInterceptor

All Implemented Interfaces:

InterceptorMBean

public class PessimisticLockInterceptor
extends MethodDispacherInterceptor

An interceptor that handles locking. When a TX is associated, we register for TX completion and unlock the locks acquired within the scope of the TX. When no TX is present, we keep track of the locks acquired during the current method and unlock when the method returns.

Version:

$Id: PessimisticLockInterceptor.java 5394 2008-03-07 02:43:26Z mircea.markus $

Author:

Bela Ban

Field Summary

Fields inherited from class org.jboss.cache.interceptors.Interceptor

cache, configuration, last, log, next, trace

Constructor Summary

PessimisticLockInterceptor()

Method Summary

protected Object	handleAddChildMethod(InvocationContext ctx, GlobalTransaction tx, Fqn parentFqn, Object childName, Node cn, boolean createUndoOps) Handles CacheImpl._addChild(org.jboss.cache.transaction.GlobalTransaction, org.jboss.cache.Fqn, Object, org.jboss.cache.Node, boolean)
protected Object	handleCommitMethod(InvocationContext ctx, GlobalTransaction globalTransaction) Handles CacheImpl.commit(org.jboss.cache.transaction.GlobalTransaction)
protected Object	handleEvictMethod(InvocationContext ctx, Fqn fqn) Handles evict()
protected Object	handleGetChildrenNamesMethod(InvocationContext ctx, Fqn fqn) Handles CacheImpl._getChildrenNames(org.jboss.cache.Fqn)
protected Object	handleGetKeysMethod(InvocationContext ctx, Fqn fqn) Handles Cache.getKeys(Fqn)
protected Object	handleGetKeyValueMethod(InvocationContext ctx, Fqn fqn, Object key, boolean sendNodeEvent) Handles CacheImpl._get(org.jboss.cache.Fqn, Object, boolean)
protected Object	handleGetNodeMethod(InvocationContext ctx, Fqn fqn) Handles CacheImpl._get(org.jboss.cache.Fqn)
protected Object	handleLockMethod(InvocationContext ctx, Fqn fqn, NodeLock.LockType lockType, boolean recursive) Handles CacheImpl._lock(org.jboss.cache.Fqn, org.jboss.cache.lock.NodeLock.LockType, boolean)
protected Object	handleMoveMethod(InvocationContext ctx, Fqn from, Fqn to) Handles CacheImpl._move(org.jboss.cache.Fqn, org.jboss.cache.Fqn)
protected Object	handleOptimisticPrepareMethod(InvocationContext ctx, GlobalTransaction gtx, List modifications, Map data, org.jgroups.Address address, boolean onePhaseCommit) Handles CacheImpl.optimisticPrepare(org.jboss.cache.transaction.GlobalTransaction, java.util.List, java.util.Map, org.jgroups.Address, boolean)
protected Object	handlePrepareMethod(InvocationContext ctx, GlobalTransaction gtx, List modification, org.jgroups.Address coordinator, boolean onePhaseCommit) Handles CacheImpl.prepare(org.jboss.cache.transaction.GlobalTransaction, java.util.List, org.jgroups.Address, boolean)
protected Object	handlePrintMethod(InvocationContext ctx, Fqn fqn) Handles CacheImpl._print(org.jboss.cache.Fqn)
protected Object	handlePutDataEraseMethod(InvocationContext ctx, GlobalTransaction gt, Fqn fqn, Map newData, boolean createUndoOps, boolean eraseContents) Handles CacheImpl._put(org.jboss.cache.transaction.GlobalTransaction, org.jboss.cache.Fqn, java.util.Map, boolean, boolean)
protected Object	handlePutDataMethod(InvocationContext ctx, GlobalTransaction tx, Fqn fqn, Map data, boolean createUndoOps) Handles CacheImpl._put(org.jboss.cache.transaction.GlobalTransaction, String, java.util.Map, boolean)
protected Object	handlePutForExternalReadMethod(InvocationContext ctx, GlobalTransaction tx, Fqn fqn, Object key, Object value) Handles CacheImpl._putForExternalRead(org.jboss.cache.transaction.GlobalTransaction, org.jboss.cache.Fqn, Object, Object)
protected Object	handlePutKeyValueMethod(InvocationContext ctx, GlobalTransaction gtx, Fqn fqn, Object key, Object value, boolean createUndoOps) Handles CacheImpl._put(org.jboss.cache.transaction.GlobalTransaction, String, Object, Object, boolean)
protected Object	handleReleaseAllLocksMethod(InvocationContext ctx, Fqn fqn) Handles CacheImpl._releaseAllLocks(org.jboss.cache.Fqn)
protected Object	handleRemoveDataMethod(InvocationContext ctx, GlobalTransaction tx, Fqn fqn, boolean createUndoOps) Handles CacheImpl._removeData(org.jboss.cache.transaction.GlobalTransaction, Fqn, boolean)
protected Object	handleRemoveKeyMethod(InvocationContext ctx, GlobalTransaction tx, Fqn fqn, Object key, boolean createUndoOps) Handles CacheImpl._remove(org.jboss.cache.transaction.GlobalTransaction, String, Object, boolean)
protected Object	handleRemoveNodeMethod(InvocationContext ctx, GlobalTransaction tx, Fqn fqn, boolean createUndoOps) Handles CacheImpl._remove(org.jboss.cache.transaction.GlobalTransaction, String, boolean)
protected Object	handleRollbackMethod(InvocationContext ctx, GlobalTransaction globalTransaction) Handles CacheImpl.rollback(org.jboss.cache.transaction.GlobalTransaction)
void	injectDependencies(Configuration configuration, CacheImpl cacheImpl, TransactionTable txTable)
Object	invoke(InvocationContext ctx) Acts like a 'switch case' that delegates the call to the appropriate method.
protected boolean	skipMethodCall(InvocationContext ctx) Each interceptor should extend this if it does not need any processing for current call.

Methods inherited from class org.jboss.cache.interceptors.MethodDispacherInterceptor

handleBlockChannelMethod, handleDataGravitationCleanupMethod, handleEvictVersionedNodeMethod, handleExistsMethod, handleGetDataMapMethod, handlePutDataEraseVersionedMethod, handlePutDataVersionedMethod, handlePutForExternalReadVersionedMethod, handlePutKeyValueVersionedMethod, handleRemoveDataVersionedMethod, handleRemoveKeyVersionedMethod, handleRemoveNodeVersionedMethod, handleUnblockChannelMethod

Methods inherited from class org.jboss.cache.interceptors.Interceptor

assertTransactionValid, dumpStatistics, getLast, getNext, getStatisticsEnabled, initLogger, isActive, isPreparing, isValid, nextInterceptor, peekNode, resetStatistics, setCache, setLast, setNext, setStatisticsEnabled, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

PessimisticLockInterceptor

public PessimisticLockInterceptor()

Method Detail

injectDependencies

public void injectDependencies(Configuration configuration,
                               CacheImpl cacheImpl,
                               TransactionTable txTable)

invoke

public Object invoke(InvocationContext ctx)
              throws Throwable

Description copied from class: MethodDispacherInterceptor

Acts like a 'switch case' that delegates the call to the appropriate method.

Overrides:

invoke in class MethodDispacherInterceptor

Throws:

Throwable

handlePutDataMethod

protected Object handlePutDataMethod(InvocationContext ctx,
                                     GlobalTransaction tx,
                                     Fqn fqn,
                                     Map data,
                                     boolean createUndoOps)
                              throws Throwable

Description copied from class: MethodDispacherInterceptor

Handles CacheImpl._put(org.jboss.cache.transaction.GlobalTransaction, String, java.util.Map, boolean)

Overrides:

handlePutDataMethod in class MethodDispacherInterceptor

Throws:

Throwable

handlePutDataEraseMethod

protected Object handlePutDataEraseMethod(InvocationContext ctx,
                                          GlobalTransaction gt,
                                          Fqn fqn,
                                          Map newData,
                                          boolean createUndoOps,
                                          boolean eraseContents)
                                   throws Throwable

Description copied from class: MethodDispacherInterceptor

Handles CacheImpl._put(org.jboss.cache.transaction.GlobalTransaction, org.jboss.cache.Fqn, java.util.Map, boolean, boolean)

Overrides:

handlePutDataEraseMethod in class MethodDispacherInterceptor

Throws:

Throwable

handlePutKeyValueMethod

protected Object handlePutKeyValueMethod(InvocationContext ctx,
                                         GlobalTransaction gtx,
                                         Fqn fqn,
                                         Object key,
                                         Object value,
                                         boolean createUndoOps)
                                  throws Throwable

Description copied from class: MethodDispacherInterceptor

Handles CacheImpl._put(org.jboss.cache.transaction.GlobalTransaction, String, Object, Object, boolean)

Overrides:

handlePutKeyValueMethod in class MethodDispacherInterceptor

Throws:

Throwable

skipMethodCall

protected boolean skipMethodCall(InvocationContext ctx)

Description copied from class: MethodDispacherInterceptor

Each interceptor should extend this if it does not need any processing for current call. An sample usage would be: this interceptor is only interested if thre is one transaction going on. If so all handleXYZ would know that we have a transaction going and would not check its state.

Overrides:

skipMethodCall in class MethodDispacherInterceptor

handleLockMethod

protected Object handleLockMethod(InvocationContext ctx,
                                  Fqn fqn,
                                  NodeLock.LockType lockType,
                                  boolean recursive)
                           throws Throwable

Description copied from class: MethodDispacherInterceptor

Handles CacheImpl._lock(org.jboss.cache.Fqn, org.jboss.cache.lock.NodeLock.LockType, boolean)

Overrides:

handleLockMethod in class MethodDispacherInterceptor

Throws:

Throwable

handlePrepareMethod

protected Object handlePrepareMethod(InvocationContext ctx,
                                     GlobalTransaction gtx,
                                     List modification,
                                     org.jgroups.Address coordinator,
                                     boolean onePhaseCommit)
                              throws Throwable

Description copied from class: MethodDispacherInterceptor

Handles CacheImpl.prepare(org.jboss.cache.transaction.GlobalTransaction, java.util.List, org.jgroups.Address, boolean)

Overrides:

handlePrepareMethod in class MethodDispacherInterceptor

Throws:

Throwable

handleOptimisticPrepareMethod

protected Object handleOptimisticPrepareMethod(InvocationContext ctx,
                                               GlobalTransaction gtx,
                                               List modifications,
                                               Map data,
                                               org.jgroups.Address address,
                                               boolean onePhaseCommit)
                                        throws Throwable

Description copied from class: MethodDispacherInterceptor

Handles CacheImpl.optimisticPrepare(org.jboss.cache.transaction.GlobalTransaction, java.util.List, java.util.Map, org.jgroups.Address, boolean)

Overrides:

handleOptimisticPrepareMethod in class MethodDispacherInterceptor

Throws:

Throwable

handleCommitMethod

protected Object handleCommitMethod(InvocationContext ctx,
                                    GlobalTransaction globalTransaction)
                             throws Throwable

Description copied from class: MethodDispacherInterceptor

Handles CacheImpl.commit(org.jboss.cache.transaction.GlobalTransaction)

Overrides:

handleCommitMethod in class MethodDispacherInterceptor

Throws:

Throwable

handleRollbackMethod

protected Object handleRollbackMethod(InvocationContext ctx,
                                      GlobalTransaction globalTransaction)
                               throws Throwable

Description copied from class: MethodDispacherInterceptor

Handles CacheImpl.rollback(org.jboss.cache.transaction.GlobalTransaction)

Overrides:

handleRollbackMethod in class MethodDispacherInterceptor

Throws:

Throwable

handleMoveMethod

protected Object handleMoveMethod(InvocationContext ctx,
                                  Fqn from,
                                  Fqn to)
                           throws Throwable

Description copied from class: MethodDispacherInterceptor

Handles CacheImpl._move(org.jboss.cache.Fqn, org.jboss.cache.Fqn)

Overrides:

handleMoveMethod in class MethodDispacherInterceptor

Throws:

Throwable

handleRemoveNodeMethod

protected Object handleRemoveNodeMethod(InvocationContext ctx,
                                        GlobalTransaction tx,
                                        Fqn fqn,
                                        boolean createUndoOps)
                                 throws Throwable

Description copied from class: MethodDispacherInterceptor

Handles CacheImpl._remove(org.jboss.cache.transaction.GlobalTransaction, String, boolean)

Overrides:

handleRemoveNodeMethod in class MethodDispacherInterceptor

Throws:

Throwable

handlePutForExternalReadMethod

protected Object handlePutForExternalReadMethod(InvocationContext ctx,
                                                GlobalTransaction tx,
                                                Fqn fqn,
                                                Object key,
                                                Object value)
                                         throws Throwable

Description copied from class: MethodDispacherInterceptor

Handles CacheImpl._putForExternalRead(org.jboss.cache.transaction.GlobalTransaction, org.jboss.cache.Fqn, Object, Object)

Overrides:

handlePutForExternalReadMethod in class MethodDispacherInterceptor

Throws:

Throwable

handleRemoveKeyMethod

protected Object handleRemoveKeyMethod(InvocationContext ctx,
                                       GlobalTransaction tx,
                                       Fqn fqn,
                                       Object key,
                                       boolean createUndoOps)
                                throws Throwable

Description copied from class: MethodDispacherInterceptor

Handles CacheImpl._remove(org.jboss.cache.transaction.GlobalTransaction, String, Object, boolean)

Overrides:

handleRemoveKeyMethod in class MethodDispacherInterceptor

Throws:

Throwable

handleRemoveDataMethod

protected Object handleRemoveDataMethod(InvocationContext ctx,
                                        GlobalTransaction tx,
                                        Fqn fqn,
                                        boolean createUndoOps)
                                 throws Throwable

Description copied from class: MethodDispacherInterceptor

Handles CacheImpl._removeData(org.jboss.cache.transaction.GlobalTransaction, Fqn, boolean)

Overrides:

handleRemoveDataMethod in class MethodDispacherInterceptor

Throws:

Throwable

handleAddChildMethod

protected Object handleAddChildMethod(InvocationContext ctx,
                                      GlobalTransaction tx,
                                      Fqn parentFqn,
                                      Object childName,
                                      Node cn,
                                      boolean createUndoOps)
                               throws Throwable

Description copied from class: MethodDispacherInterceptor

Handles CacheImpl._addChild(org.jboss.cache.transaction.GlobalTransaction, org.jboss.cache.Fqn, Object, org.jboss.cache.Node, boolean)

Overrides:

handleAddChildMethod in class MethodDispacherInterceptor

Throws:

Throwable

handleEvictMethod

protected Object handleEvictMethod(InvocationContext ctx,
                                   Fqn fqn)
                            throws Throwable

Description copied from class: MethodDispacherInterceptor

Handles evict()

Overrides:

handleEvictMethod in class MethodDispacherInterceptor

Throws:

Throwable

handleGetKeyValueMethod

protected Object handleGetKeyValueMethod(InvocationContext ctx,
                                         Fqn fqn,
                                         Object key,
                                         boolean sendNodeEvent)
                                  throws Throwable

Description copied from class: MethodDispacherInterceptor

Handles CacheImpl._get(org.jboss.cache.Fqn, Object, boolean)

Overrides:

handleGetKeyValueMethod in class MethodDispacherInterceptor

Throws:

Throwable

handleGetNodeMethod

protected Object handleGetNodeMethod(InvocationContext ctx,
                                     Fqn fqn)
                              throws Throwable

Description copied from class: MethodDispacherInterceptor

Handles CacheImpl._get(org.jboss.cache.Fqn)

Overrides:

handleGetNodeMethod in class MethodDispacherInterceptor

Throws:

Throwable

handleGetKeysMethod

protected Object handleGetKeysMethod(InvocationContext ctx,
                                     Fqn fqn)
                              throws Throwable

Description copied from class: MethodDispacherInterceptor

Handles Cache.getKeys(Fqn)

Overrides:

handleGetKeysMethod in class MethodDispacherInterceptor

Throws:

Throwable

handleGetChildrenNamesMethod

protected Object handleGetChildrenNamesMethod(InvocationContext ctx,
                                              Fqn fqn)
                                       throws Throwable

Description copied from class: MethodDispacherInterceptor

Handles CacheImpl._getChildrenNames(org.jboss.cache.Fqn)

Overrides:

handleGetChildrenNamesMethod in class MethodDispacherInterceptor

Throws:

Throwable

handlePrintMethod

protected Object handlePrintMethod(InvocationContext ctx,
                                   Fqn fqn)
                            throws Throwable

Description copied from class: MethodDispacherInterceptor

Handles CacheImpl._print(org.jboss.cache.Fqn)

Overrides:

handlePrintMethod in class MethodDispacherInterceptor

Throws:

Throwable

handleReleaseAllLocksMethod

protected Object handleReleaseAllLocksMethod(InvocationContext ctx,
                                             Fqn fqn)
                                      throws Throwable

Description copied from class: MethodDispacherInterceptor

Handles CacheImpl._releaseAllLocks(org.jboss.cache.Fqn)

Overrides:

handleReleaseAllLocksMethod in class MethodDispacherInterceptor

Throws:

Throwable