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 2013/04/25 18:56:16 UTC
svn commit: r1475854 -
/uima/sandbox/uima-ducc/trunk/uima-ducc-jd/src/main/java/org/apache/uima/ducc/jd/JobDriverComponent.java
Author: degenaro
Date: Thu Apr 25 16:56:15 2013
New Revision: 1475854
URL: http://svn.apache.org/r1475854
Log:
UIMA-2825 DUCC webserver (WS) Job Details Processes tab revisions
Modified:
uima/sandbox/uima-ducc/trunk/uima-ducc-jd/src/main/java/org/apache/uima/ducc/jd/JobDriverComponent.java
Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-jd/src/main/java/org/apache/uima/ducc/jd/JobDriverComponent.java
URL: http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-jd/src/main/java/org/apache/uima/ducc/jd/JobDriverComponent.java?rev=1475854&r1=1475853&r2=1475854&view=diff
==============================================================================
--- uima/sandbox/uima-ducc/trunk/uima-ducc-jd/src/main/java/org/apache/uima/ducc/jd/JobDriverComponent.java (original)
+++ uima/sandbox/uima-ducc/trunk/uima-ducc-jd/src/main/java/org/apache/uima/ducc/jd/JobDriverComponent.java Thu Apr 25 16:56:15 2013
@@ -20,6 +20,7 @@ package org.apache.uima.ducc.jd;
import java.util.Map;
import java.util.Map.Entry;
+import java.util.concurrent.ConcurrentSkipListMap;
import java.util.concurrent.atomic.AtomicInteger;
import org.apache.camel.CamelContext;
@@ -40,6 +41,8 @@ import org.apache.uima.ducc.transport.ev
import org.apache.uima.ducc.transport.event.common.IDuccTypes.DuccType;
import org.apache.uima.ducc.transport.event.jd.DriverStatusReport;
import org.apache.uima.ducc.transport.event.jd.PerformanceSummaryWriter;
+import org.apache.uima.ducc.transport.json.jp.JobProcessCollection;
+import org.apache.uima.ducc.transport.json.jp.JobProcessData;
public class JobDriverComponent extends AbstractDuccComponent
@@ -64,6 +67,8 @@ implements IJobDriverComponent {
private AtomicInteger publicationCounter = new AtomicInteger(0);
+ private JobProcessCollection jpc = null;
+
// private int retryCount = 0;
// private int retryLimit = 2;
@@ -161,6 +166,7 @@ implements IJobDriverComponent {
synchronized(jobId) {
if(thread != null) {
thread.setJob(job);
+ jpc = new JobProcessCollection(job);
}
if(thread == null) {
duccOut.debug(methodName, job.getDuccId(), job.getJobState());
@@ -174,6 +180,13 @@ implements IJobDriverComponent {
duccOut.error(methodName, job.getDuccId(), e.getMessage(), e);
}
}
+ try {
+ ConcurrentSkipListMap<Long, JobProcessData> map = jpc.transform(job);
+ jpc.exportData(map);
+ }
+ catch(Exception e) {
+ duccOut.error(methodName, job.getDuccId(), e.getMessage(), e);
+ }
}
/*
if(job.isCompleted()) {