[infinispan-commits] Infinispan SVN: r297 - trunk/core/src/main/java/org/infinispan/interceptors.

[infinispan-commits at lists.jboss.org]

Author: manik.surtani at jboss.com
Date: 2009-05-14 09:36:13 -0400 (Thu, 14 May 2009)
New Revision: 297

Modified:
   trunk/core/src/main/java/org/infinispan/interceptors/LockingInterceptor.java
Log:
Lock command

Modified: trunk/core/src/main/java/org/infinispan/interceptors/LockingInterceptor.java
===================================================================
--- trunk/core/src/main/java/org/infinispan/interceptors/LockingInterceptor.java	2009-05-14 12:32:29 UTC (rev 296)
+++ trunk/core/src/main/java/org/infinispan/interceptors/LockingInterceptor.java	2009-05-14 13:36:13 UTC (rev 297)
@@ -135,16 +135,16 @@
          doAfterCall(ctx);
       }
    }
-   
+
    @Override
    public Object visitLockControlCommand(InvocationContext ctx, LockControlCommand c) throws Throwable {
       try {
-         if(ctx.isOriginLocal() && ctx.isInTxScope()){
+         if (ctx.isOriginLocal() && ctx.isInTxScope()) {
             c.attachGlobalTransaction((GlobalTransaction) ctx.getLockOwner());
          }
          if (c.isLock()) {
             for (Object key : c.getKeys()) {
-               entryFactory.wrapEntryForWriting(ctx, key, false, false, false, false);
+               entryFactory.wrapEntryForWriting(ctx, key, true, false, false, false);
             }
          } else if (c.isUnlock()) {
             for (Object key : c.getKeys()) {
@@ -241,7 +241,7 @@
    private void doAfterCall(InvocationContext ctx) {
       // for non-transactional stuff.
       if (!ctx.isInTxScope()) {
-            cleanupLocks(ctx, ctx.getLockOwner(), true);
+         cleanupLocks(ctx, ctx.getLockOwner(), true);
       } else {
          if (trace) log.trace("Transactional.  Not cleaning up locks till the transaction ends.");
          if (useReadCommitted) {