svn commit: r1496446 - /uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/jd/DriverStatusReport.java

[degenaro]

Author: degenaro
Date: Tue Jun 25 12:21:00 2013
New Revision: 1496446

URL: http://svn.apache.org/r1496446
Log:
UIMA-2987 DUCC job driver (JD) should reap unprocessed work items

Modified:
    
uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/jd/DriverStatusReport.java

Modified: 
uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/jd/DriverStatusReport.java
URL: 
http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/jd/DriverStatusReport.java?rev=1496446&r1=1496445&r2=1496446&view=diff
==============================================================================
--- 
uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/jd/DriverStatusReport.java
 (original)
+++ 
uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/jd/DriverStatusReport.java
 Tue Jun 25 12:21:00 2013
@@ -386,6 +386,14 @@ public class DriverStatusReport implemen
                return workItemsPreempted.get();
        }
        
+       public long getWorkItemsToDo() {
+               long total = getWorkItemsTotal();
+               long done = getWorkItemsProcessingCompleted();
+               long error = getWorkItemsProcessingError();
+               long todo = total - (done + error);
+               return todo;
+       }
+       
        public int getThreadCount() {
                return threadCount.get();
        }