Author: cwiklik Date: Thu Oct 17 13:48:50 2013 New Revision: 1533082 URL: http://svn.apache.org/r1533082 Log: UIMA-3319 Modified to set reasonForFailure to KilledByDucc when AP or JP is killed by an agent
Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-agent/src/main/java/org/apache/uima/ducc/agent/NodeAgent.java Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-agent/src/main/java/org/apache/uima/ducc/agent/NodeAgent.java URL: http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-agent/src/main/java/org/apache/uima/ducc/agent/NodeAgent.java?rev=1533082&r1=1533081&r2=1533082&view=diff ============================================================================== --- uima/sandbox/uima-ducc/trunk/uima-ducc-agent/src/main/java/org/apache/uima/ducc/agent/NodeAgent.java (original) +++ uima/sandbox/uima-ducc/trunk/uima-ducc-agent/src/main/java/org/apache/uima/ducc/agent/NodeAgent.java Thu Oct 17 13:48:50 2013 @@ -75,6 +75,7 @@ import org.apache.uima.ducc.transport.ev import org.apache.uima.ducc.transport.event.common.IDuccJobDeployment; import org.apache.uima.ducc.transport.event.common.IDuccProcess; import org.apache.uima.ducc.transport.event.common.IDuccProcess.ReasonForStoppingProcess; +import org.apache.uima.ducc.transport.event.common.IDuccReasonForProcessNotRunning.ReasonForStopping; import org.apache.uima.ducc.transport.event.common.IDuccReservation; import org.apache.uima.ducc.transport.event.common.IDuccReservationMap; import org.apache.uima.ducc.transport.event.common.IDuccStandardInfo; @@ -924,8 +925,10 @@ public class NodeAgent extends AbstractD + processEntry.getValue().getDuccId() + " Was Previously Tagged for Kill While It Was Starting"); undeployProcess(processEntry.getValue()); + } else if ( deployedProcess != null && deployedProcess.doKill() && + deployedProcess.getDuccProcess().getProcessState().equals(ProcessState.Stopped) ) { + deployedProcess.getDuccProcess().setReasonForStoppingProcess(ReasonForStoppingProcess.KilledByDucc.toString()); } else if ( deployedProcess != null && ( deployedProcess.doKill() - || deployedProcess.getDuccProcess().getProcessState().equals(ProcessState.Stopped) || deployedProcess.getDuccProcess().getProcessState().equals(ProcessState.Failed) || deployedProcess.getDuccProcess().getProcessState().equals(ProcessState.Killed)) ) { // The process has already stopped, but managed to send