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:04:53 UTC
svn commit: r1548665 -
/uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/common/DuccProcessMap.java
Author: degenaro
Date: Fri Dec 6 19:04:52 2013
New Revision: 1548665
URL: http://svn.apache.org/r1548665
Log:
UIMA-3489 DUCC failed service instance Reason should not be EOJ
Modified:
uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/common/DuccProcessMap.java
Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/common/DuccProcessMap.java
URL: http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/common/DuccProcessMap.java?rev=1548665&r1=1548664&r2=1548665&view=diff
==============================================================================
--- uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/common/DuccProcessMap.java (original)
+++ uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/common/DuccProcessMap.java Fri Dec 6 19:04:52 2013
@@ -252,6 +252,21 @@ public class DuccProcessMap extends Tree
return retVal;
}
+ // <UIMA-3489>
+ private boolean isFailedInitialization(IDuccProcess process) {
+ boolean retVal = false;
+ try {
+ String reason = process.getReasonForStoppingProcess();
+ if(ProcessState.FailedInitialization.name().equals(reason)) {
+ retVal = true;
+ }
+ }
+ catch(Exception e) {
+ }
+ return retVal;
+ }
+ // </UIMA-3489>
+
public ArrayList<DuccId> getFailedInitialization() {
ArrayList<DuccId> list = new ArrayList<DuccId>();
synchronized(this) {
@@ -262,7 +277,10 @@ public class DuccProcessMap extends Tree
// Nevermind
}
else {
- if(isFailedProcess(process)) {
+ if(isFailedInitialization(process)) {
+ list.add(process.getDuccId());
+ }
+ else if(isFailedProcess(process)) {
list.add(process.getDuccId());
}
}