Test multiple scheduled synchronous tasks

1 files changed, 18 insertions, 0 deletions

diff --git a/clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/StateChangeTest.java b/clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/StateChangeTest.java
index 24cecd4f5b6..a452a85c870 100644
--- a/clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/StateChangeTest.java
+++ b/clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/StateChangeTest.java
@@ -1447,6 +1447,24 @@ public class StateChangeTest extends FleetControllerTest {
     }
 
     @Test
+    public void multiple_tasks_may_be_scheduled_and_answered_at_the_same_time() throws Exception {
+        RemoteTaskFixture fixture = createDefaultFixture();
+        communicator.setShouldDeferDistributorClusterStateAcks(true);
+
+        MockTask task1 = fixture.scheduleNonIdempotentVersionDependentTask();
+        MockTask task2 = fixture.scheduleNonIdempotentVersionDependentTask();
+
+        fixture.processScheduledTask();
+        assertFalse(task1.isCompleted());
+        assertFalse(task2.isCompleted());
+
+        fixture.sendAllDeferredDistributorClusterStateAcks();
+
+        assertTrue(task1.isCompleted());
+        assertTrue(task2.isCompleted());
+    }
+
+    @Test
     public void synchronous_task_immediately_failed_when_leadership_lost() throws Exception {
         FleetControllerOptions options = optionsWithZeroTransitionTime();
         options.fleetControllerCount = 3;