[jbosscache-commits] JBoss Cache SVN: r6030 - core/trunk/src/main/java/org/jboss/cache/interceptors.

[jbosscache-commits at lists.jboss.org]

Author: manik.surtani at jboss.com
Date: 2008-06-25 09:25:40 -0400 (Wed, 25 Jun 2008)
New Revision: 6030

Modified:
   core/trunk/src/main/java/org/jboss/cache/interceptors/OptimisticInterceptor.java
Log:
Catch interruptedException

Modified: core/trunk/src/main/java/org/jboss/cache/interceptors/OptimisticInterceptor.java
===================================================================
--- core/trunk/src/main/java/org/jboss/cache/interceptors/OptimisticInterceptor.java	2008-06-25 13:24:47 UTC (rev 6029)
+++ core/trunk/src/main/java/org/jboss/cache/interceptors/OptimisticInterceptor.java	2008-06-25 13:25:40 UTC (rev 6030)
@@ -111,7 +111,16 @@
    @SuppressWarnings("unchecked")
    protected WorkspaceNode lockAndCreateWorkspaceNode(NodeFactory nodeFactory, NodeSPI node, TransactionWorkspace workspace, GlobalTransaction gtx, long timeout)
    {
-      boolean locked = lockManager.lock(node, READ, gtx, timeout);
+      boolean locked = false;
+      try
+      {
+         locked = lockManager.lock(node, READ, gtx, timeout);
+      }
+      catch (InterruptedException e)
+      {
+         // test if we acquired the lock
+         locked = lockManager.getReadOwners(node).contains(gtx);
+      }
 
       if (!locked)
          throw new TimeoutException("Unable to lock node " + node.getFqn() + " after timeout " + timeout + " for copying into workspace");