You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@uima.apache.org by bu...@apache.org on 2019/07/31 17:03:24 UTC
svn commit: r1864090 -
/uima/uima-ducc/trunk/uima-ducc-agent/src/main/java/org/apache/uima/ducc/agent/event/AgentEventListener.java
Author: burn
Date: Wed Jul 31 17:03:23 2019
New Revision: 1864090
URL: http://svn.apache.org/viewvc?rev=1864090&view=rev
Log:
UIMA-6104 Restore to accepting request from a 'single' as well as 'master' head node
Modified:
uima/uima-ducc/trunk/uima-ducc-agent/src/main/java/org/apache/uima/ducc/agent/event/AgentEventListener.java
Modified: uima/uima-ducc/trunk/uima-ducc-agent/src/main/java/org/apache/uima/ducc/agent/event/AgentEventListener.java
URL: http://svn.apache.org/viewvc/uima/uima-ducc/trunk/uima-ducc-agent/src/main/java/org/apache/uima/ducc/agent/event/AgentEventListener.java?rev=1864090&r1=1864089&r2=1864090&view=diff
==============================================================================
--- uima/uima-ducc/trunk/uima-ducc-agent/src/main/java/org/apache/uima/ducc/agent/event/AgentEventListener.java (original)
+++ uima/uima-ducc/trunk/uima-ducc-agent/src/main/java/org/apache/uima/ducc/agent/event/AgentEventListener.java Wed Jul 31 17:03:23 2019
@@ -63,7 +63,7 @@ public class AgentEventListener implemen
ProcessLifecycleController lifecycleController = null;
// On startup of the Agent we may need to do cleanup of cgroups.
// This cleanup will happen once right after processing of the first OR publication.
- private boolean cleanupPhase = true;
+ //private boolean cleanupPhase = true;
private AtomicLong lastSequence = new AtomicLong();
private volatile boolean forceInventoryUpdateDueToSequence = false;
@@ -270,6 +270,7 @@ public class AgentEventListener implemen
String message = "sequence="+sequence+" "+"type="+dhs+" "+"producer="+host+" "+"jobs="+jobs+" "+"reservations="+reservations+" "+"tid="+tid;
switch(dhs) {
case master:
+ case unspecified:
// Issue info and process master type publication
logger.info(location, null, "accept=Yes"+" "+message);
break;