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/02/11 21:57:48 UTC
svn commit: r1567390 - in
/uima/sandbox/uima-ducc/trunk/uima-ducc-jd/src/main/java/org/apache/uima/ducc/jd:
JobDriver.java client/DynamicThreadPoolExecutor.java
Author: degenaro
Date: Tue Feb 11 20:57:47 2014
New Revision: 1567390
URL: http://svn.apache.org/r1567390
Log:
UIMA-3610 DUCC Job Driver (JD) should unambiguously record to log UIMA-AS client sendAndReceive interactions
Modified:
uima/sandbox/uima-ducc/trunk/uima-ducc-jd/src/main/java/org/apache/uima/ducc/jd/JobDriver.java
uima/sandbox/uima-ducc/trunk/uima-ducc-jd/src/main/java/org/apache/uima/ducc/jd/client/DynamicThreadPoolExecutor.java
Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-jd/src/main/java/org/apache/uima/ducc/jd/JobDriver.java
URL: http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-jd/src/main/java/org/apache/uima/ducc/jd/JobDriver.java?rev=1567390&r1=1567389&r2=1567390&view=diff
==============================================================================
--- uima/sandbox/uima-ducc/trunk/uima-ducc-jd/src/main/java/org/apache/uima/ducc/jd/JobDriver.java (original)
+++ uima/sandbox/uima-ducc/trunk/uima-ducc-jd/src/main/java/org/apache/uima/ducc/jd/JobDriver.java Tue Feb 11 20:57:47 2014
@@ -157,7 +157,7 @@ public class JobDriver extends Thread im
// Prepare UIMA-AS client instance and multiple threads
ClientThreadFactory factory = new ClientThreadFactory("UimaASClientThread");
queue = new LinkedBlockingQueue<Runnable>();
- executor = new DynamicThreadPoolExecutor(1, 1, 10, TimeUnit.MICROSECONDS, queue, factory, null);
+ executor = new DynamicThreadPoolExecutor(1, 1, 10, TimeUnit.MICROSECONDS, queue, factory, job.getDuccId());
client = new BaseUIMAAsynchronousEngine_impl();
workItemListener = new WorkItemListener(this);
client.addStatusCallbackListener(workItemListener);
Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-jd/src/main/java/org/apache/uima/ducc/jd/client/DynamicThreadPoolExecutor.java
URL: http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-jd/src/main/java/org/apache/uima/ducc/jd/client/DynamicThreadPoolExecutor.java?rev=1567390&r1=1567389&r2=1567390&view=diff
==============================================================================
--- uima/sandbox/uima-ducc/trunk/uima-ducc-jd/src/main/java/org/apache/uima/ducc/jd/client/DynamicThreadPoolExecutor.java (original)
+++ uima/sandbox/uima-ducc/trunk/uima-ducc-jd/src/main/java/org/apache/uima/ducc/jd/client/DynamicThreadPoolExecutor.java Tue Feb 11 20:57:47 2014
@@ -103,7 +103,7 @@ public class DynamicThreadPoolExecutor e
int delta = getMaximumPoolSize() - size;
if(delta != 0) {
String message = duccMsg.fetch("changing core pool size to")+" "+size+" "+duccMsg.fetch("from")+" "+getMaximumPoolSize();
- duccOut.debug(methodName, duccId, message);
+ duccOut.info(methodName, duccId, message);
super.setCorePoolSize(size);
super.setMaximumPoolSize(size);
}