From 069dd7af3923cded76cbbd96f4b1020397ea6f11 Mon Sep 17 00:00:00 2001 From: Casey Bodley Date: Thu, 5 Dec 2019 17:08:44 -0500 Subject: [PATCH] test/rgw: unittest_rgw_reshard_wait uses spawn library Signed-off-by: Casey Bodley --- src/test/rgw/test_rgw_reshard_wait.cc | 17 +++++++++-------- 1 file changed, 9 insertions(+), 8 deletions(-) diff --git a/src/test/rgw/test_rgw_reshard_wait.cc b/src/test/rgw/test_rgw_reshard_wait.cc index 788b15c859f..96a155274c2 100644 --- a/src/test/rgw/test_rgw_reshard_wait.cc +++ b/src/test/rgw/test_rgw_reshard_wait.cc @@ -13,6 +13,7 @@ */ #include "rgw/rgw_reshard.h" +#include #include @@ -64,7 +65,7 @@ TEST(ReshardWait, wait_yield) RGWReshardWait waiter(wait_duration); boost::asio::io_context context; - boost::asio::spawn(context, [&] (boost::asio::yield_context yield) { + spawn::spawn(context, [&] (spawn::yield_context yield) { EXPECT_EQ(0, waiter.wait(optional_yield{context, yield})); }); @@ -89,8 +90,8 @@ TEST(ReshardWait, stop_yield) RGWReshardWait short_waiter(short_duration); boost::asio::io_context context; - boost::asio::spawn(context, - [&] (boost::asio::yield_context yield) { + spawn::spawn(context, + [&] (spawn::yield_context yield) { EXPECT_EQ(-ECANCELED, long_waiter.wait(optional_yield{context, yield})); }); @@ -133,13 +134,13 @@ TEST(ReshardWait, stop_multiple) // spawn 4 coroutines boost::asio::io_context context; { - auto async_waiter = [&] (boost::asio::yield_context yield) { + auto async_waiter = [&] (spawn::yield_context yield) { EXPECT_EQ(-ECANCELED, long_waiter.wait(optional_yield{context, yield})); }; - boost::asio::spawn(context, async_waiter); - boost::asio::spawn(context, async_waiter); - boost::asio::spawn(context, async_waiter); - boost::asio::spawn(context, async_waiter); + spawn::spawn(context, async_waiter); + spawn::spawn(context, async_waiter); + spawn::spawn(context, async_waiter); + spawn::spawn(context, async_waiter); } const auto start = Clock::now(); -- 2.39.5