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/12/06 20:05:53 UTC
svn commit: r1548666 -
/uima/sandbox/uima-ducc/trunk/uima-ducc-orchestrator/src/main/java/org/apache/uima/ducc/orchestrator/ProcessAccounting.java
Author: degenaro
Date: Fri Dec 6 19:05:52 2013
New Revision: 1548666
URL: http://svn.apache.org/r1548666
Log:
UIMA-3489 DUCC failed service instance Reason should not be EOJ
Modified:
uima/sandbox/uima-ducc/trunk/uima-ducc-orchestrator/src/main/java/org/apache/uima/ducc/orchestrator/ProcessAccounting.java
Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-orchestrator/src/main/java/org/apache/uima/ducc/orchestrator/ProcessAccounting.java
URL: http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-orchestrator/src/main/java/org/apache/uima/ducc/orchestrator/ProcessAccounting.java?rev=1548666&r1=1548665&r2=1548666&view=diff
==============================================================================
--- uima/sandbox/uima-ducc/trunk/uima-ducc-orchestrator/src/main/java/org/apache/uima/ducc/orchestrator/ProcessAccounting.java (original)
+++ uima/sandbox/uima-ducc/trunk/uima-ducc-orchestrator/src/main/java/org/apache/uima/ducc/orchestrator/ProcessAccounting.java Fri Dec 6 19:05:52 2013
@@ -389,8 +389,8 @@ public class ProcessAccounting {
switch(process.getResourceState()) {
case Allocated:
process.setResourceState(ResourceState.Deallocated);
- logger.info(methodName, job.getDuccId(), process.getDuccId(), messages.fetchLabel("process state")+inventoryProcess.getProcessState()+" => "+messages.fetchLabel("resource state")+process.getResourceState());
String reason = inventoryProcess.getReasonForStoppingProcess();
+ logger.info(methodName, job.getDuccId(), process.getDuccId(), messages.fetchLabel("process state")+inventoryProcess.getProcessState()+" => "+messages.fetchLabel("resource state")+process.getResourceState()+" : "+messages.fetchLabel("reason")+reason);
switch(inventoryProcess.getProcessState()) {
case Stopped:
if(reason != null) {
@@ -404,6 +404,20 @@ public class ProcessAccounting {
}
process.setProcessDeallocationType(ProcessDeallocationType.Failed);
break;
+ /*
+ case FailedInitialization:
+ if(reason != null) {
+ process.setReasonForStoppingProcess(reason);
+ }
+ process.setProcessDeallocationType(ProcessDeallocationType.FailedInitialization);
+ break;
+ case InitializationTimeout:
+ if(reason != null) {
+ process.setReasonForStoppingProcess(reason);
+ }
+ process.setProcessDeallocationType(ProcessDeallocationType.InitializationTimeout);
+ break;
+ */
case Killed:
if(reason != null) {
process.setReasonForStoppingProcess(reason);