Author: manik.surtani(a)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");
Show replies by date