svn commit: r517792 - /incubator/ode/trunk/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/BpelServerImpl.java

[mriou]

Author: mriou
Date: Tue Mar 13 10:58:27 2007
New Revision: 517792

URL: http://svn.apache.org/viewvc?view=rev&rev=517792
Log:
Engine read lock should be released in the afterCompletion, the 
beforeCompletion doesn't get called on rollbacks.

Modified:
    
incubator/ode/trunk/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/BpelServerImpl.java

Modified: 
incubator/ode/trunk/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/BpelServerImpl.java
URL: 
http://svn.apache.org/viewvc/incubator/ode/trunk/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/BpelServerImpl.java?view=diff&rev=517792&r1=517791&r2=517792
==============================================================================
--- 
incubator/ode/trunk/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/BpelServerImpl.java
 (original)
+++ 
incubator/ode/trunk/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/BpelServerImpl.java
 Tue Mar 13 10:58:27 2007
@@ -18,14 +18,6 @@
  */
 package org.apache.ode.bpel.engine;
 
-import java.util.ArrayList;
-import java.util.Collections;
-import java.util.List;
-import java.util.concurrent.locks.ReadWriteLock;
-import java.util.concurrent.locks.ReentrantReadWriteLock;
-
-import javax.xml.namespace.QName;
-
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 import org.apache.ode.bpel.dao.BpelDAOConnection;
@@ -48,6 +40,13 @@
 import org.apache.ode.bpel.o.OProcess;
 import org.apache.ode.utils.msg.MessageBundle;
 
+import javax.xml.namespace.QName;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.List;
+import java.util.concurrent.locks.ReadWriteLock;
+import java.util.concurrent.locks.ReentrantReadWriteLock;
+
 /**
  * <p>
  * The BPEL server implementation.
@@ -209,10 +208,9 @@
         try {
             _contexts.scheduler.registerSynchronizer(new Synchronizer() {
                 public void afterCompletion(boolean success) {
+                    _mngmtLock.readLock().unlock();
                 }
-
                 public void beforeCompletion() {
-                    _mngmtLock.readLock().unlock();
                 }
             });
             registered = true;