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;