You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ode.apache.org by mr...@apache.org on 2007/03/30 01:26:14 UTC

svn commit: r523872 - /incubator/ode/trunk/bpel-runtime/src/main/java/org/apache/ode/bpel/memdao/ProcessDaoImpl.java

Author: mriou
Date: Thu Mar 29 16:26:13 2007
New Revision: 523872

URL: http://svn.apache.org/viewvc?view=rev&rev=523872
Log:
In-memory instances are cleaned up after execution now so instance count doesn't produce anything meaningful anymore. Using a counter instead, fixes some tests.

Modified:
    incubator/ode/trunk/bpel-runtime/src/main/java/org/apache/ode/bpel/memdao/ProcessDaoImpl.java

Modified: incubator/ode/trunk/bpel-runtime/src/main/java/org/apache/ode/bpel/memdao/ProcessDaoImpl.java
URL: http://svn.apache.org/viewvc/incubator/ode/trunk/bpel-runtime/src/main/java/org/apache/ode/bpel/memdao/ProcessDaoImpl.java?view=diff&rev=523872&r1=523871&r2=523872
==============================================================================
--- incubator/ode/trunk/bpel-runtime/src/main/java/org/apache/ode/bpel/memdao/ProcessDaoImpl.java (original)
+++ incubator/ode/trunk/bpel-runtime/src/main/java/org/apache/ode/bpel/memdao/ProcessDaoImpl.java Thu Mar 29 16:26:13 2007
@@ -49,6 +49,7 @@
     protected final Map<Integer, PartnerLinkDAO> _plinks = new ConcurrentHashMap<Integer, PartnerLinkDAO>();
     private Map<QName, ProcessDaoImpl> _store;
     private BpelDAOConnectionImpl _conn;
+    private int _executionCount = 0;
 
     private String _guid;
 
@@ -100,6 +101,7 @@
     public ProcessInstanceDAO createInstance(CorrelatorDAO correlator) {
         ProcessInstanceDaoImpl newInstance = new ProcessInstanceDaoImpl(_conn, this, correlator);
         _instances.put(newInstance.getInstanceId(), newInstance);
+        _executionCount++;
         return newInstance;
     }
 
@@ -155,7 +157,8 @@
     }
 
     public int getNumInstances() {
-        return _instances.size();
+        // Instances are removed after execution, using a counter instead
+        return _executionCount;
     }
 
     public ProcessInstanceDAO getInstanceWithLock(Long iid) {