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/12/11 16:10:31 UTC
svn commit: r603265 - in
/ode/branches/APACHE_ODE_1.1/bpel-runtime/src/main/java/org/apache/ode/bpel/memdao:
BpelDAOConnectionImpl.java ProcessDaoImpl.java
Author: mriou
Date: Tue Dec 11 07:10:29 2007
New Revision: 603265
URL: http://svn.apache.org/viewvc?rev=603265&view=rev
Log:
Fixing my little oversight.
Modified:
ode/branches/APACHE_ODE_1.1/bpel-runtime/src/main/java/org/apache/ode/bpel/memdao/BpelDAOConnectionImpl.java
ode/branches/APACHE_ODE_1.1/bpel-runtime/src/main/java/org/apache/ode/bpel/memdao/ProcessDaoImpl.java
Modified: ode/branches/APACHE_ODE_1.1/bpel-runtime/src/main/java/org/apache/ode/bpel/memdao/BpelDAOConnectionImpl.java
URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.1/bpel-runtime/src/main/java/org/apache/ode/bpel/memdao/BpelDAOConnectionImpl.java?rev=603265&r1=603264&r2=603265&view=diff
==============================================================================
--- ode/branches/APACHE_ODE_1.1/bpel-runtime/src/main/java/org/apache/ode/bpel/memdao/BpelDAOConnectionImpl.java (original)
+++ ode/branches/APACHE_ODE_1.1/bpel-runtime/src/main/java/org/apache/ode/bpel/memdao/BpelDAOConnectionImpl.java Tue Dec 11 07:10:29 2007
@@ -58,7 +58,7 @@
private Scheduler _scheduler;
private Map<QName, ProcessDaoImpl> _store;
private List<BpelEvent> _events = new LinkedList<BpelEvent>();
- private long _mexTtl;
+ long _mexTtl;
private static Map<String,MessageExchangeDAO> _mexStore = Collections.synchronizedMap(new HashMap<String,MessageExchangeDAO>());
protected static Map<String, Long> _mexAge = new ConcurrentHashMap<String, Long>();
Modified: ode/branches/APACHE_ODE_1.1/bpel-runtime/src/main/java/org/apache/ode/bpel/memdao/ProcessDaoImpl.java
URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.1/bpel-runtime/src/main/java/org/apache/ode/bpel/memdao/ProcessDaoImpl.java?rev=603265&r1=603264&r2=603265&view=diff
==============================================================================
--- ode/branches/APACHE_ODE_1.1/bpel-runtime/src/main/java/org/apache/ode/bpel/memdao/ProcessDaoImpl.java (original)
+++ ode/branches/APACHE_ODE_1.1/bpel-runtime/src/main/java/org/apache/ode/bpel/memdao/ProcessDaoImpl.java Tue Dec 11 07:10:29 2007
@@ -220,13 +220,13 @@
*/
void discardOldInstances() {
long now = System.currentTimeMillis();
- if (now > _lastRemoval + (BpelDAOConnectionImpl.TIME_TO_LIVE/10)) {
+ if (now > _lastRemoval + (_conn._mexTtl/10)) {
_lastRemoval = now;
Object[] oldInstances = _instancesAge.keySet().toArray();
for (int i=oldInstances.length-1; i>=0; i--) {
Long id = (Long) oldInstances[i];
Long age = _instancesAge.get(id);
- if (age != null && now-age > BpelDAOConnectionImpl.TIME_TO_LIVE) {
+ if (age != null && now-age > _conn._mexTtl) {
__log.warn("Discarding in-memory instance "+id+" because it exceeded its time-to-live: "+_instances.get(id));
_instances.remove(id);
_instancesAge.remove(id);