From 04420a84c76bb63c6846b3259b35fbfb81e8a9ca Mon Sep 17 00:00:00 2001 From: Tyler Neely Date: Fri, 18 Nov 2022 16:54:38 +0000 Subject: [PATCH] Fix incorrect usage of IncrementServerCountAndWaitForQuiescentState in the shard_rsm.cpp simulation test --- tests/simulation/shard_rsm.cpp | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/tests/simulation/shard_rsm.cpp b/tests/simulation/shard_rsm.cpp index 64d0a0861..230bd9222 100644 --- a/tests/simulation/shard_rsm.cpp +++ b/tests/simulation/shard_rsm.cpp @@ -1115,11 +1115,12 @@ int TestMessages() { ConcreteShardRsm shard_server3(std::move(shard_server_io_3), address_for_3, ShardRsm(std::move(shard_ptr3))); auto server_thread1 = std::jthread([&shard_server1]() { shard_server1.Run(); }); - auto server_thread2 = std::jthread([&shard_server2]() { shard_server2.Run(); }); - auto server_thread3 = std::jthread([&shard_server3]() { shard_server3.Run(); }); - simulator.IncrementServerCountAndWaitForQuiescentState(shard_server_1_address); + + auto server_thread2 = std::jthread([&shard_server2]() { shard_server2.Run(); }); simulator.IncrementServerCountAndWaitForQuiescentState(shard_server_2_address); + + auto server_thread3 = std::jthread([&shard_server3]() { shard_server3.Run(); }); simulator.IncrementServerCountAndWaitForQuiescentState(shard_server_3_address); std::cout << "Beginning test after servers have become quiescent." << std::endl;