You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@uima.apache.org by cw...@apache.org on 2015/07/17 17:51:38 UTC
svn commit: r1691593 -
/uima/sandbox/uima-ducc/trunk/uima-ducc-agent/src/main/java/org/apache/uima/ducc/agent/NodeAgent.java
Author: cwiklik
Date: Fri Jul 17 15:51:38 2015
New Revision: 1691593
URL: http://svn.apache.org/r1691593
Log:
UIMA-4516 Fixed Agent to kill JP on InitializationTimeout
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=1691593&r1=1691592&r2=1691593&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 Fri Jul 17 15:51:38 2015
@@ -1096,20 +1096,14 @@ public class NodeAgent extends AbstractD
deployedProcess.getDuccProcess().setProcessState(ProcessState.Stopping);
deployedProcess.setStopping();
- // Mark the process for death. Doesnt actually kill the
- // process
- /*
+ // Mark process for death. Doesnt actually kill the process
+
deployedProcess.kill();
logger.info(methodName, null, ">>>> Agent Handling Process InitializationTimeout. PID:"
+ duccEvent.getPid() + " Killing Process");
- logger.info(methodName, null,
- "----------- Agent Stopped ProcessMemoryUsagePollingRouter for Process:"
- + duccEvent.getPid()
- + ". Agent Timedout Waiting For Process to Initialize");
-
undeployProcess(processEntry.getValue());
- */
+
}
else if (duccEvent.getState().equals(ProcessState.Stopping)) {
if ( duccEvent.getMessage() != null && duccEvent.getMessage().equals(ReasonForStoppingProcess.ExceededErrorThreshold.toString())) {