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 2015/02/23 15:58:59 UTC

svn commit: r1661694 - /uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jd/JobDriverComponent.java

Author: degenaro
Date: Mon Feb 23 14:58:58 2015
New Revision: 1661694

URL: http://svn.apache.org/r1661694
Log:
UIMA-4069 DUCC Job Driver (JD) system classpath

Add process deallocate reason to JD logging (e.g. Purged)

Modified:
    uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jd/JobDriverComponent.java

Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jd/JobDriverComponent.java
URL: http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jd/JobDriverComponent.java?rev=1661694&r1=1661693&r2=1661694&view=diff
==============================================================================
--- uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jd/JobDriverComponent.java (original)
+++ uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jd/JobDriverComponent.java Mon Feb 23 14:58:58 2015
@@ -46,6 +46,7 @@ import org.apache.uima.ducc.transport.ev
 import org.apache.uima.ducc.transport.event.common.IDuccProcess;
 import org.apache.uima.ducc.transport.event.common.IDuccProcessMap;
 import org.apache.uima.ducc.transport.event.common.IProcessState.ProcessState;
+import org.apache.uima.ducc.transport.event.common.IResourceState.ProcessDeallocationType;
 import org.apache.uima.ducc.transport.event.jd.IDriverStatusReport;
 import org.apache.uima.ducc.transport.event.jd.JobDriverReport;
 
@@ -187,9 +188,16 @@ implements IJobDriverComponent {
 						sb.append(" ");
 						sb.append("state:"+state.name());
 						sb.append(" ");
-						String reason = p.getReasonForStoppingProcess();
-						if(reason != null) {
-							sb.append("reason:"+reason);
+						String reasonStopped = p.getReasonForStoppingProcess();
+						if(reasonStopped != null) {
+							sb.append("reason[stopped]:"+reasonStopped);
+							sb.append(" ");
+						}
+						String reasonDeallocated = null;
+						ProcessDeallocationType processDeallocationType = p.getProcessDeallocationType();
+						if(processDeallocationType != null) {
+							reasonDeallocated = processDeallocationType.name();
+							sb.append("reason[deallocated]:"+reasonDeallocated);
 							sb.append(" ");
 						}
 						logger.debug(location, jobid, sb.toString());
@@ -202,7 +210,7 @@ implements IJobDriverComponent {
 							try {
 								if(pid != null) {
 									int iPid = Integer.parseInt(pid.trim());
-									IProcessInfo processInfo = new ProcessInfo(node, ip, pidName, iPid);
+									IProcessInfo processInfo = new ProcessInfo(node, ip, pidName, iPid, reasonStopped, reasonDeallocated);
 									if(p.isFailedInitialization()) {
 										mh.handleProcessFailedInitialization(processInfo);
 									}