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 2011/01/25 13:56:35 UTC
svn commit: r1063261 - in
/sling/trunk/bundles/extensions/event/src/test/java/org/apache/sling/event/impl/jobs:
OrderedJobQueueTest.java RoundRobinQueueTest.java
Author: cziegeler
Date: Tue Jan 25 12:56:35 2011
New Revision: 1063261
URL: http://svn.apache.org/viewvc?rev=1063261&view=rev
Log:
SLING-1955 : Event Support Unit Tests stall in full trunk build
Modified:
sling/trunk/bundles/extensions/event/src/test/java/org/apache/sling/event/impl/jobs/OrderedJobQueueTest.java
sling/trunk/bundles/extensions/event/src/test/java/org/apache/sling/event/impl/jobs/RoundRobinQueueTest.java
Modified: sling/trunk/bundles/extensions/event/src/test/java/org/apache/sling/event/impl/jobs/OrderedJobQueueTest.java
URL: http://svn.apache.org/viewvc/sling/trunk/bundles/extensions/event/src/test/java/org/apache/sling/event/impl/jobs/OrderedJobQueueTest.java?rev=1063261&r1=1063260&r2=1063261&view=diff
==============================================================================
--- sling/trunk/bundles/extensions/event/src/test/java/org/apache/sling/event/impl/jobs/OrderedJobQueueTest.java (original)
+++ sling/trunk/bundles/extensions/event/src/test/java/org/apache/sling/event/impl/jobs/OrderedJobQueueTest.java Tue Jan 25 12:56:35 2011
@@ -145,6 +145,7 @@ public class OrderedJobQueueTest extends
public boolean process(Event job) {
if ( parallelCount.incrementAndGet() > 1 ) {
+ parallelCount.decrementAndGet();
return false;
}
final String topic = (String)job.getProperty(JobUtil.PROPERTY_JOB_TOPIC);
Modified: sling/trunk/bundles/extensions/event/src/test/java/org/apache/sling/event/impl/jobs/RoundRobinQueueTest.java
URL: http://svn.apache.org/viewvc/sling/trunk/bundles/extensions/event/src/test/java/org/apache/sling/event/impl/jobs/RoundRobinQueueTest.java?rev=1063261&r1=1063260&r2=1063261&view=diff
==============================================================================
--- sling/trunk/bundles/extensions/event/src/test/java/org/apache/sling/event/impl/jobs/RoundRobinQueueTest.java (original)
+++ sling/trunk/bundles/extensions/event/src/test/java/org/apache/sling/event/impl/jobs/RoundRobinQueueTest.java Tue Jan 25 12:56:35 2011
@@ -147,6 +147,7 @@ public class RoundRobinQueueTest extends
public boolean process(Event job) {
if ( parallelCount.incrementAndGet() > MAX_PAR ) {
+ parallelCount.decrementAndGet();
return false;
}
try {