svn commit: r1496445 - /uima/sandbox/uima-ducc/trunk/uima-ducc-orchestrator/src/main/java/org/apache/uima/ducc/orchestrator/StateManager.java

[degenaro]

Author: degenaro
Date: Tue Jun 25 12:19:12 2013
New Revision: 1496445

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

Modified:
    
uima/sandbox/uima-ducc/trunk/uima-ducc-orchestrator/src/main/java/org/apache/uima/ducc/orchestrator/StateManager.java

Modified: 
uima/sandbox/uima-ducc/trunk/uima-ducc-orchestrator/src/main/java/org/apache/uima/ducc/orchestrator/StateManager.java
URL: 
http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-orchestrator/src/main/java/org/apache/uima/ducc/orchestrator/StateManager.java?rev=1496445&r1=1496444&r2=1496445&view=diff
==============================================================================
--- 
uima/sandbox/uima-ducc/trunk/uima-ducc-orchestrator/src/main/java/org/apache/uima/ducc/orchestrator/StateManager.java
 (original)
+++ 
uima/sandbox/uima-ducc/trunk/uima-ducc-orchestrator/src/main/java/org/apache/uima/ducc/orchestrator/StateManager.java
 Tue Jun 25 12:19:12 2013
@@ -558,9 +558,7 @@ public class StateManager {
                String methodName = "isExcessCapacity";
                boolean retVal = false;
                if(jdStatusReport != null) {
-                       IDuccProcessMap processMap = job.getProcessMap();
-                       int threads_per_share = 
Integer.parseInt(job.getSchedulingInfo().getThreadsPerShare());
-                       long capacity = processMap.getUsableProcessCount() * 
threads_per_share;
+                       long capacity = job.getWorkItemCapacity();
                        long total = jdStatusReport.getWorkItemsTotal();
                        long done = 
jdStatusReport.getWorkItemsProcessingCompleted();
                        long error = 
jdStatusReport.getWorkItemsProcessingError();