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/12/23 19:24:12 UTC
svn commit: r1647640 - in
/uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container:
common/Standardize.java jd/fsm/wi/ActionGet.java jd/fsm/wi/WiFsm.java
Author: degenaro
Date: Tue Dec 23 18:24:11 2014
New Revision: 1647640
URL: http://svn.apache.org/r1647640
Log: (empty)
Modified:
uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/common/Standardize.java
uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/jd/fsm/wi/ActionGet.java
uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/jd/fsm/wi/WiFsm.java
Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/common/Standardize.java
URL: http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/common/Standardize.java?rev=1647640&r1=1647639&r2=1647640&view=diff
==============================================================================
--- uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/common/Standardize.java (original)
+++ uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/common/Standardize.java Tue Dec 23 18:24:11 2014
@@ -21,6 +21,8 @@ package org.apache.uima.ducc.container.c
public class Standardize {
public enum Label {
+ enter,
+ exit,
dispatch,
done,
error,
Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/jd/fsm/wi/ActionGet.java
URL: http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/jd/fsm/wi/ActionGet.java?rev=1647640&r1=1647639&r2=1647640&view=diff
==============================================================================
--- uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/jd/fsm/wi/ActionGet.java (original)
+++ uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/jd/fsm/wi/ActionGet.java Tue Dec 23 18:24:11 2014
@@ -18,6 +18,8 @@
*/
package org.apache.uima.ducc.container.jd.fsm.wi;
+import java.util.concurrent.atomic.AtomicBoolean;
+
import org.apache.uima.ducc.common.jd.files.workitem.IWorkItemStateKeeper;
import org.apache.uima.ducc.container.common.MessageBuffer;
import org.apache.uima.ducc.container.common.MetaCasHelper;
@@ -45,11 +47,13 @@ public class ActionGet implements IActio
private static Logger logger = Logger.getLogger(ActionGet.class, IComponent.Id.JD.name());
+ private AtomicBoolean warned = new AtomicBoolean(false);
+
@Override
public String getName() {
return ActionGet.class.getName();
}
-
+
@Override
public void engage(Object objectData) {
String location = "engage";
@@ -66,7 +70,18 @@ public class ActionGet implements IActio
JobDriverHelper jdh = JobDriverHelper.getInstance();
jd.advanceJdState(JdState.Active);
CasManager cm = jd.getCasManager();
- IMetaCas metaCas = cm.getMetaCas();
+ IMetaCas metaCas = null;
+ if(cm.getCasManagerStats().isKillJob()) {
+ if(!warned.getAndSet(true)) {
+ MessageBuffer mb = new MessageBuffer();
+ mb.append(Standardize.Label.transNo.get()+trans.getTransactionId().toString());
+ mb.append("this and future requests refused due to pending kill job");
+ logger.info(location, ILogger.null_id, mb.toString());
+ }
+ }
+ else {
+ metaCas = cm.getMetaCas();
+ }
trans.setMetaCas(metaCas);
IWorkItemStateKeeper wisk = jd.getWorkItemStateKeeper();
MetaCasHelper metaCasHelper = new MetaCasHelper(metaCas);
@@ -97,6 +112,8 @@ public class ActionGet implements IActio
else {
event = WiFsm.CAS_Unavailable;
MessageBuffer mb = new MessageBuffer();
+ mb.append(Standardize.Label.transNo.get()+trans.getTransactionId().toString());
+ mb.append(Standardize.Label.remote.get()+rwt.toString());
mb.append("No CAS found for processing");
logger.info(location, ILogger.null_id, mb.toString());
}
Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/jd/fsm/wi/WiFsm.java
URL: http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/jd/fsm/wi/WiFsm.java?rev=1647640&r1=1647639&r2=1647640&view=diff
==============================================================================
--- uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/jd/fsm/wi/WiFsm.java (original)
+++ uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/jd/fsm/wi/WiFsm.java Tue Dec 23 18:24:11 2014
@@ -18,6 +18,8 @@
*/
package org.apache.uima.ducc.container.jd.fsm.wi;
+import org.apache.uima.ducc.container.common.MessageBuffer;
+import org.apache.uima.ducc.container.common.Standardize;
import org.apache.uima.ducc.container.common.fsm.Event;
import org.apache.uima.ducc.container.common.fsm.Fsm;
import org.apache.uima.ducc.container.common.fsm.FsmException;
@@ -25,8 +27,13 @@ import org.apache.uima.ducc.container.co
import org.apache.uima.ducc.container.common.fsm.iface.IAction;
import org.apache.uima.ducc.container.common.fsm.iface.IEvent;
import org.apache.uima.ducc.container.common.fsm.iface.IState;
+import org.apache.uima.ducc.container.common.logger.IComponent;
+import org.apache.uima.ducc.container.common.logger.ILogger;
+import org.apache.uima.ducc.container.common.logger.Logger;
public class WiFsm extends Fsm {
+
+ private static Logger logger = Logger.getLogger(WiFsm.class, IComponent.Id.JD.name());
public static IState Start = new State("Start");
public static IState Get_Pending = new State("Get_Pending");
@@ -62,6 +69,11 @@ public class WiFsm extends Fsm {
}
private void initialize() throws FsmException {
+ String location = "initialize";
+
+ MessageBuffer mb1 = new MessageBuffer();
+ mb1.append(Standardize.Label.enter.get());
+ logger.debug(location, ILogger.null_id, mb1.toString());
// current state // event // action // next state //
@@ -91,5 +103,9 @@ public class WiFsm extends Fsm {
add(CAS_Active, Ack_Request, ActionError, CAS_Active);
add(CAS_Active, End_Request, ActionEnd, Start);
add(CAS_Active, Process_Preempt, ActionPreempt, Start);
+
+ MessageBuffer mb2 = new MessageBuffer();
+ mb2.append(Standardize.Label.exit.get());
+ logger.debug(location, ILogger.null_id, mb2.toString());
}
}