You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@uima.apache.org by de...@apache.org on 2014/12/30 21:05:31 UTC
svn commit: r1648592 - in
/uima/sandbox/uima-ducc/trunk/uima-ducc-container/src:
main/java/org/apache/uima/ducc/container/jd/mh/MessageHandler.java
test/java/org/apache/uima/ducc/container/jd/test/ATest.java
Author: degenaro
Date: Tue Dec 30 20:05:30 2014
New Revision: 1648592
URL: http://svn.apache.org/r1648592
Log:
UIMA-4069 DUCC Job Driver (JD) system classpath
Job Details Performance tab + supporting file + accounting + modest code re-org.
Modified:
uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/jd/mh/MessageHandler.java
uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/test/java/org/apache/uima/ducc/container/jd/test/ATest.java
Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/jd/mh/MessageHandler.java
URL: http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/jd/mh/MessageHandler.java?rev=1648592&r1=1648591&r2=1648592&view=diff
==============================================================================
--- uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/jd/mh/MessageHandler.java (original)
+++ uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/jd/mh/MessageHandler.java Tue Dec 30 20:05:30 2014
@@ -21,6 +21,7 @@ package org.apache.uima.ducc.container.j
import java.util.Map.Entry;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentLinkedQueue;
+import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicInteger;
import org.apache.uima.ducc.container.common.MessageBuffer;
@@ -75,15 +76,31 @@ public class MessageHandler implements I
acks.incrementAndGet();
}
+ //
+
+ private static AtomicBoolean piggybacking = new AtomicBoolean(false);
+
+ public static void piggybackingDisable() {
+ piggybacking.set(false);
+ }
+
+ public static void piggybackingEnable() {
+ piggybacking.set(false);
+ }
+
+ //
+
private void piggyback() {
String location = "piggyback";
- try {
- JobDriver jd = JobDriver.getInstance();
- IWorkItemPerformanceKeeper wipk = jd.getWorkItemPerformanceKeeper();
- wipk.publish();
- }
- catch(Exception e) {
- logger.error(location, ILogger.null_id, e);
+ if(piggybacking.get()) {
+ try {
+ JobDriver jd = JobDriver.getInstance();
+ IWorkItemPerformanceKeeper wipk = jd.getWorkItemPerformanceKeeper();
+ wipk.publish();
+ }
+ catch(Exception e) {
+ logger.error(location, ILogger.null_id, e);
+ }
}
}
Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/test/java/org/apache/uima/ducc/container/jd/test/ATest.java
URL: http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/test/java/org/apache/uima/ducc/container/jd/test/ATest.java?rev=1648592&r1=1648591&r2=1648592&view=diff
==============================================================================
--- uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/test/java/org/apache/uima/ducc/container/jd/test/ATest.java (original)
+++ uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/test/java/org/apache/uima/ducc/container/jd/test/ATest.java Tue Dec 30 20:05:30 2014
@@ -23,6 +23,7 @@ import java.util.Map;
import org.apache.uima.ducc.common.container.FlagsHelper;
import org.apache.uima.ducc.common.container.FlagsHelper.Name;
import org.apache.uima.ducc.container.jd.JobDriver;
+import org.apache.uima.ducc.container.jd.mh.MessageHandler;
import org.junit.After;
import org.junit.AfterClass;
import org.junit.Before;
@@ -83,6 +84,7 @@ public abstract class ATest {
@BeforeClass
public static void setUpBeforeClass() throws Exception {
+ MessageHandler.piggybackingDisable();
}
@AfterClass