You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@sling.apache.org by cz...@apache.org on 2015/11/23 14:25:56 UTC

svn commit: r1715803 - in /sling/trunk/bundles/extensions/event/src: main/java/org/apache/sling/event/impl/jobs/stats/StatisticsImpl.java test/java/org/apache/sling/event/impl/jobs/StatisticsImplTest.java

Author: cziegeler
Date: Mon Nov 23 13:25:56 2015
New Revision: 1715803

URL: http://svn.apache.org/viewvc?rev=1715803&view=rev
Log:
SLING-5315 : rescheduled failed jobs increment queued jobs counter

Modified:
    sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/jobs/stats/StatisticsImpl.java
    sling/trunk/bundles/extensions/event/src/test/java/org/apache/sling/event/impl/jobs/StatisticsImplTest.java

Modified: sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/jobs/stats/StatisticsImpl.java
URL: http://svn.apache.org/viewvc/sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/jobs/stats/StatisticsImpl.java?rev=1715803&r1=1715802&r2=1715803&view=diff
==============================================================================
--- sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/jobs/stats/StatisticsImpl.java (original)
+++ sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/jobs/stats/StatisticsImpl.java Mon Nov 23 13:25:56 2015
@@ -176,7 +176,6 @@ public class StatisticsImpl implements S
     public synchronized void failedJob() {
         this.failedJobs++;
         this.activeJobs--;
-        this.queuedJobs++;
     }
 
     /**

Modified: sling/trunk/bundles/extensions/event/src/test/java/org/apache/sling/event/impl/jobs/StatisticsImplTest.java
URL: http://svn.apache.org/viewvc/sling/trunk/bundles/extensions/event/src/test/java/org/apache/sling/event/impl/jobs/StatisticsImplTest.java?rev=1715803&r1=1715802&r2=1715803&view=diff
==============================================================================
--- sling/trunk/bundles/extensions/event/src/test/java/org/apache/sling/event/impl/jobs/StatisticsImplTest.java (original)
+++ sling/trunk/bundles/extensions/event/src/test/java/org/apache/sling/event/impl/jobs/StatisticsImplTest.java Mon Nov 23 13:25:56 2015
@@ -154,6 +154,7 @@ public class StatisticsImplTest {
         this.stat.incQueued();
         this.stat.addActive(200);
         this.stat.failedJob();
+        this.stat.incQueued();
         assertTrue(this.stat.getStartTime() >= START_TIME);
         assertEquals(400, this.stat.getAverageProcessingTime());
         assertEquals(200, this.stat.getAverageWaitingTime());