From 36892831020ff25b9c098e33a98474c407d94e90 Mon Sep 17 00:00:00 2001 From: Yuval Lifshitz Date: Tue, 12 May 2020 17:19:40 +0300 Subject: [PATCH] cls/2pc_queue: fix timing issue in test Fixes: https://tracker.ceph.com/issues/45513 Signed-off-by: Yuval Lifshitz --- src/test/cls_2pc_queue/test_cls_2pc_queue.cc | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/test/cls_2pc_queue/test_cls_2pc_queue.cc b/src/test/cls_2pc_queue/test_cls_2pc_queue.cc index 9b325b258d079..f66fcc773234e 100644 --- a/src/test/cls_2pc_queue/test_cls_2pc_queue.cc +++ b/src/test/cls_2pc_queue/test_cls_2pc_queue.cc @@ -505,7 +505,7 @@ TEST_F(TestCls2PCQueue, Cleanup) } }); } - + auto cleaned_reservations = 0U; auto committed_reservations = 0U; auto aborter = std::thread([this, &queue_name, &stale_time, &cleaned_reservations, &committed_reservations] { @@ -544,7 +544,7 @@ TEST_F(TestCls2PCQueue, Cleanup) aborter.join(); ASSERT_GT(cleaned_reservations, 0); - ASSERT_GT(committed_reservations, 0); + ASSERT_EQ(committed_reservations + cleaned_reservations, number_of_ops*max_workers); cls_2pc_reservations reservations; ASSERT_EQ(0, cls_2pc_queue_list_reservations(ioctx, queue_name, reservations)); ASSERT_EQ(reservations.size(), 0); -- 2.39.5