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);
}