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/25 14:12:42 UTC
svn commit: r1496439 -
/uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/common/DuccWorkJob.java
Author: degenaro
Date: Tue Jun 25 12:12:42 2013
New Revision: 1496439
URL: http://svn.apache.org/r1496439
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/common/DuccWorkJob.java
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=1496439&r1=1496438&r2=1496439&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 Jun 25 12:12:42 2013
@@ -279,6 +279,20 @@ public class DuccWorkJob extends ADuccWo
// **********
+ public long getWorkItemCapacity() {
+ long capacity = 0;
+ try {
+ IDuccProcessMap processMap = getProcessMap();
+ int threads_per_share = Integer.parseInt(getSchedulingInfo().getThreadsPerShare());
+ capacity = processMap.getUsableProcessCount() * threads_per_share;
+ }
+ catch(Exception e) {
+ }
+ return capacity;
+ }
+
+ // **********
+
public IDuccProcess getProcess(String dpid) {
IDuccProcess idp = null;
try {