You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@felix.apache.org by gu...@apache.org on 2013/10/02 16:56:39 UTC
svn commit: r1528507 -
/felix/trunk/ipojo/runtime/core/src/main/java/org/apache/felix/ipojo/extender/internal/queue/JobInfoCallable.java
Author: guillaume
Date: Wed Oct 2 14:56:38 2013
New Revision: 1528507
URL: http://svn.apache.org/r1528507
Log:
Quick fix: executionTime counter was still running after exception
Modified:
felix/trunk/ipojo/runtime/core/src/main/java/org/apache/felix/ipojo/extender/internal/queue/JobInfoCallable.java
Modified: felix/trunk/ipojo/runtime/core/src/main/java/org/apache/felix/ipojo/extender/internal/queue/JobInfoCallable.java
URL: http://svn.apache.org/viewvc/felix/trunk/ipojo/runtime/core/src/main/java/org/apache/felix/ipojo/extender/internal/queue/JobInfoCallable.java?rev=1528507&r1=1528506&r2=1528507&view=diff
==============================================================================
--- felix/trunk/ipojo/runtime/core/src/main/java/org/apache/felix/ipojo/extender/internal/queue/JobInfoCallable.java (original)
+++ felix/trunk/ipojo/runtime/core/src/main/java/org/apache/felix/ipojo/extender/internal/queue/JobInfoCallable.java Wed Oct 2 14:56:38 2013
@@ -112,8 +112,10 @@ public class JobInfoCallable<T> implemen
try {
m_queueNotifier.fireStartedJobInfo(this);
result = m_delegate.call();
+ endTime = System.currentTimeMillis();
return result;
} catch (Exception e) {
+ endTime = System.currentTimeMillis();
m_queueNotifier.fireFailedJobInfo(this, e);
if (m_callback != null) {
m_callback.error(this, e);
@@ -123,7 +125,6 @@ public class JobInfoCallable<T> implemen
} finally {
m_statistic.getCurrentsCounter().decrementAndGet();
m_statistic.getFinishedCounter().incrementAndGet();
- endTime = System.currentTimeMillis();
// Only exec success callbacks when no error occurred
if (exception == null) {