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/10 17:00:26 UTC
svn commit: r1658744 - in
/uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/common:
DuccProcessMap.java DuccWorkJob.java IDuccProcessMap.java IDuccWorkJob.java
Author: degenaro
Date: Tue Feb 10 16:00:25 2015
New Revision: 1658744
URL: http://svn.apache.org/r1658744
Log:
UIMA-4069 DUCC Job Driver (JD) system classpath
support ducc_submit --driver_exception_handler_agurments max_job_errors=<int> in default error handler
Modified:
uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/common/DuccProcessMap.java
uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/common/DuccWorkJob.java
uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/common/IDuccProcessMap.java
uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/common/IDuccWorkJob.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=1658744&r1=1658743&r2=1658744&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 Tue Feb 10 16:00:25 2015
@@ -195,6 +195,19 @@ public class DuccProcessMap extends Tree
return retVal;
}
+ public int getNoPidProcessCount() {
+ int retVal = 0;
+ synchronized(this) {
+ Iterator<IDuccProcess> iterator = this.values().iterator();
+ while(iterator.hasNext()) {
+ IDuccProcess process = iterator.next();
+ if(process.getPID() == null) {
+ retVal++;
+ }
+ }
+ }
+ return retVal;
+ }
public int getAliveProcessCount() {
int retVal = 0;
Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/common/DuccWorkJob.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/DuccWorkJob.java?rev=1658744&r1=1658743&r2=1658744&view=diff
==============================================================================
--- uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/common/DuccWorkJob.java (original)
+++ uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/common/DuccWorkJob.java Tue Feb 10 16:00:25 2015
@@ -61,6 +61,8 @@ public class DuccWorkJob extends ADuccWo
private long wiMillisOperatingLeast = 0;
private long wiMillisCompletedMost = 0;
+ private long completingTOD = 0;
+
public DuccWorkJob() {
init(null);
}
@@ -420,6 +422,19 @@ public class DuccWorkJob extends ADuccWo
debugPortProcess.set(port);
}
+ public long getNoPidProcessCount() {
+ long retVal = 0;
+ IDuccProcessMap processMap = this.getProcessMap();
+ if(processMap != null) {
+ int count = processMap.getNoPidProcessCount();
+ retVal = count;
+ }
+ return retVal;
+ }
+
+ public boolean hasNoPidProcess() {
+ return (getNoPidProcessCount() > 0);
+ }
public long getAliveProcessCount() {
long retVal = 0;
@@ -593,4 +608,16 @@ public class DuccWorkJob extends ADuccWo
jdDdSpecified = true;
}
+ @Override
+ public long getCompletingTOD() {
+ return completingTOD;
+ }
+
+ @Override
+ public void setCompletingTOD() {
+ if(completingTOD == 0) {
+ completingTOD = System.currentTimeMillis();
+ }
+ }
+
}
Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/common/IDuccProcessMap.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/IDuccProcessMap.java?rev=1658744&r1=1658743&r2=1658744&view=diff
==============================================================================
--- uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/common/IDuccProcessMap.java (original)
+++ uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/common/IDuccProcessMap.java Tue Feb 10 16:00:25 2015
@@ -37,6 +37,7 @@ public interface IDuccProcessMap extends
public int getFailedUnexpectedProcessCount();
public int getAliveProcessCount();
public int getUsableProcessCount();
+ public int getNoPidProcessCount();
public ArrayList<DuccId> getFailedInitialization();
public ArrayList<DuccId> getFailedNotInitialization();
Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/common/IDuccWorkJob.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/IDuccWorkJob.java?rev=1658744&r1=1658743&r2=1658744&view=diff
==============================================================================
--- uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/common/IDuccWorkJob.java (original)
+++ uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/common/IDuccWorkJob.java Tue Feb 10 16:00:25 2015
@@ -37,6 +37,9 @@ public interface IDuccWorkJob extends Id
public JobState getJobState();
public void setJobState(JobState jobState);
+ public long getCompletingTOD();
+ public void setCompletingTOD();
+
public void setCompletion(JobCompletionType completionType, IRationale completionRationale);
public JobCompletionType getCompletionType();