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()) {