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/06/26 11:53:34 UTC
svn commit: r1496863 - in
/uima/sandbox/uima-ducc/trunk/uima-ducc-common/src/main/java/org/apache/uima/ducc/common:
jd/files/IWorkItemState.java jd/files/WorkItemState.java
jd/files/WorkItemStateManager.java json/MonitorInfo.java
Author: degenaro
Date: Wed Jun 26 09:53:34 2013
New Revision: 1496863
URL: http://svn.apache.org/r1496863
Log:
UIMA-2987 DUCC job driver (JD) should reap unprocessed work items
Modified:
uima/sandbox/uima-ducc/trunk/uima-ducc-common/src/main/java/org/apache/uima/ducc/common/jd/files/IWorkItemState.java
uima/sandbox/uima-ducc/trunk/uima-ducc-common/src/main/java/org/apache/uima/ducc/common/jd/files/WorkItemState.java
uima/sandbox/uima-ducc/trunk/uima-ducc-common/src/main/java/org/apache/uima/ducc/common/jd/files/WorkItemStateManager.java
uima/sandbox/uima-ducc/trunk/uima-ducc-common/src/main/java/org/apache/uima/ducc/common/json/MonitorInfo.java
Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-common/src/main/java/org/apache/uima/ducc/common/jd/files/IWorkItemState.java
URL: http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-common/src/main/java/org/apache/uima/ducc/common/jd/files/IWorkItemState.java?rev=1496863&r1=1496862&r2=1496863&view=diff
==============================================================================
--- uima/sandbox/uima-ducc/trunk/uima-ducc-common/src/main/java/org/apache/uima/ducc/common/jd/files/IWorkItemState.java (original)
+++ uima/sandbox/uima-ducc/trunk/uima-ducc-common/src/main/java/org/apache/uima/ducc/common/jd/files/IWorkItemState.java Wed Jun 26 09:53:34 2013
@@ -38,6 +38,7 @@ public interface IWorkItemState extends
ended,
error,
retry,
+ lost,
unknown
}
@@ -48,6 +49,7 @@ public interface IWorkItemState extends
public void stateEnded();
public void stateError();
public void stateRetry();
+ public void stateLost();
public long getMillisOverhead();
public long getMillisProcessing();
Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-common/src/main/java/org/apache/uima/ducc/common/jd/files/WorkItemState.java
URL: http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-common/src/main/java/org/apache/uima/ducc/common/jd/files/WorkItemState.java?rev=1496863&r1=1496862&r2=1496863&view=diff
==============================================================================
--- uima/sandbox/uima-ducc/trunk/uima-ducc-common/src/main/java/org/apache/uima/ducc/common/jd/files/WorkItemState.java (original)
+++ uima/sandbox/uima-ducc/trunk/uima-ducc-common/src/main/java/org/apache/uima/ducc/common/jd/files/WorkItemState.java Wed Jun 26 09:53:34 2013
@@ -145,6 +145,12 @@ public class WorkItemState implements IW
}
+ public void stateLost() {
+ state = State.lost;
+ millisAtFinish = System.currentTimeMillis();
+ }
+
+
public void stateRetry() {
state = State.retry;
}
Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-common/src/main/java/org/apache/uima/ducc/common/jd/files/WorkItemStateManager.java
URL: http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-common/src/main/java/org/apache/uima/ducc/common/jd/files/WorkItemStateManager.java?rev=1496863&r1=1496862&r2=1496863&view=diff
==============================================================================
--- uima/sandbox/uima-ducc/trunk/uima-ducc-common/src/main/java/org/apache/uima/ducc/common/jd/files/WorkItemStateManager.java (original)
+++ uima/sandbox/uima-ducc/trunk/uima-ducc-common/src/main/java/org/apache/uima/ducc/common/jd/files/WorkItemStateManager.java Wed Jun 26 09:53:34 2013
@@ -118,6 +118,12 @@ public class WorkItemStateManager {
wis.stateError();
}
+ public void lost(int seqNo) {
+ Long key = new Long(seqNo);
+ IWorkItemState wis = map.get(key);
+ wis.stateLost();
+ }
+
public void retry(int seqNo) {
Long key = new Long(seqNo);
IWorkItemState wis = map.get(key);
Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-common/src/main/java/org/apache/uima/ducc/common/json/MonitorInfo.java
URL: http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-common/src/main/java/org/apache/uima/ducc/common/json/MonitorInfo.java?rev=1496863&r1=1496862&r2=1496863&view=diff
==============================================================================
--- uima/sandbox/uima-ducc/trunk/uima-ducc-common/src/main/java/org/apache/uima/ducc/common/json/MonitorInfo.java (original)
+++ uima/sandbox/uima-ducc/trunk/uima-ducc-common/src/main/java/org/apache/uima/ducc/common/json/MonitorInfo.java Wed Jun 26 09:53:34 2013
@@ -29,6 +29,7 @@ public class MonitorInfo {
public String done = "0";
public String error = "0";
public String retry = "0";
+ public String lost = "0";
public String procs = "0";
public ArrayList<String> errorLogs = new ArrayList<String>();
}