[Java] Remove inappropriate check from duty cycle of clustered servic…

…e agent.
LeeCampbell · Apr 3, 2018 · 280d60b · 280d60b
1 parent ac2a2d7
commit 280d60b
Showing 1 changed file with 1 addition and 8 deletions.
diff --git a/aeron-cluster/src/main/java/io/aeron/cluster/service/ClusteredServiceAgent.java b/aeron-cluster/src/main/java/io/aeron/cluster/service/ClusteredServiceAgent.java
@@ -141,15 +141,8 @@ public int doWork()
         }
 
         int workCount = logAdapter.poll();
-        if (0 == workCount)
-        {
-            if (!CommitPos.isActive(aeron.countersReader(), logAdapter.upperBoundCounterId()))
-            {
-                throw new AgentTerminationException("Commit position is not active");
-            }
-        }
-
         workCount += serviceControlAdapter.poll();
+
         if (activeLog != null)
         {
             switchActiveLog();