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 2014/02/17 14:32:51 UTC
svn commit: r1568984 -
/uima/sandbox/uima-ducc/branches/uima-ducc-1.0.0/uima-ducc-jd/src/main/java/org/apache/uima/ducc/jd/client/WorkItemListener.java
Author: degenaro
Date: Mon Feb 17 13:32:50 2014
New Revision: 1568984
URL: http://svn.apache.org/r1568984
Log:
UIMA-3623 DUCC Job Driver (JD) UIMA-AS CAS RefId tracking
Modified:
uima/sandbox/uima-ducc/branches/uima-ducc-1.0.0/uima-ducc-jd/src/main/java/org/apache/uima/ducc/jd/client/WorkItemListener.java
Modified: uima/sandbox/uima-ducc/branches/uima-ducc-1.0.0/uima-ducc-jd/src/main/java/org/apache/uima/ducc/jd/client/WorkItemListener.java
URL: http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/branches/uima-ducc-1.0.0/uima-ducc-jd/src/main/java/org/apache/uima/ducc/jd/client/WorkItemListener.java?rev=1568984&r1=1568983&r2=1568984&view=diff
==============================================================================
--- uima/sandbox/uima-ducc/branches/uima-ducc-1.0.0/uima-ducc-jd/src/main/java/org/apache/uima/ducc/jd/client/WorkItemListener.java (original)
+++ uima/sandbox/uima-ducc/branches/uima-ducc-1.0.0/uima-ducc-jd/src/main/java/org/apache/uima/ducc/jd/client/WorkItemListener.java Mon Feb 17 13:32:50 2014
@@ -36,6 +36,9 @@ public class WorkItemListener extends Ui
private IJobDriver jobDriver;
private DuccId jobid;
+ private String keyUimaAsCasTracking = "UimaAsCasTracking";
+ private boolean uimaAsCasTracking = false;
+
private String keyUimaAsClientTracking = "UimaAsClientTracking";
private boolean uimaAsClientTracking = false;
@@ -50,6 +53,9 @@ public class WorkItemListener extends Ui
super();
this.jobDriver = jobDriver;
this.jobid = jobDriver.getJob().getDuccId();
+ if(System.getProperty(keyUimaAsCasTracking) != null) {
+ uimaAsCasTracking = true;
+ }
if(System.getProperty(keyUimaAsClientTracking) != null) {
uimaAsClientTracking = true;
}
@@ -62,7 +68,10 @@ public class WorkItemListener extends Ui
String casId = ""+status.getCAS().hashCode();
WorkItem wi = jobDriver.getWorkItem(casId);
int seqNo = wi.getSeqNo();
- if(uimaAsClientTracking) {
+ if(uimaAsCasTracking) {
+ duccOut.info(methodName, jobid, "seqNo:"+seqNo+" "+"casId:"+casId+" "+"refId:"+status.getCasReferenceId());
+ }
+ else if(uimaAsClientTracking) {
duccOut.info(methodName, jobid, "seqNo:"+seqNo+" "+"casId:"+casId+" "+"refId:"+status.getCasReferenceId());
}
Thread thread = new OnBeforeMessageSendHandler(status);
@@ -151,7 +160,10 @@ public class WorkItemListener extends Ui
String casId = ""+status.getCAS().hashCode();
WorkItem wi = jobDriver.getWorkItem(casId);
int seqNo = wi.getSeqNo();
- if(uimaAsClientTracking) {
+ if(uimaAsCasTracking) {
+ duccOut.info(methodName, jobid, "seqNo:"+seqNo+" "+"casId:"+casId+" "+"refId:"+status.getCasReferenceId());
+ }
+ else if(uimaAsClientTracking) {
duccOut.info(methodName, jobid, "seqNo:"+seqNo+" "+"casId:"+casId+" "+"refId:"+status.getCasReferenceId());
}
Thread thread = new OnBeforeProcessCASHandler(status, nodeIP, pid);