]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph.git/commitdiff
test/rgw: unittest_rgw_reshard_wait uses spawn library
authorCasey Bodley <cbodley@redhat.com>
Thu, 5 Dec 2019 22:08:44 +0000 (17:08 -0500)
committerMauricio Faria de Oliveira <mfo@canonical.com>
Mon, 8 Mar 2021 12:36:37 +0000 (09:36 -0300)
Signed-off-by: Casey Bodley <cbodley@redhat.com>
(cherry picked from commit 069dd7af3923cded76cbbd96f4b1020397ea6f11)
Signed-off-by: Mauricio Faria de Oliveira <mfo@canonical.com>
src/test/rgw/test_rgw_reshard_wait.cc

index e63f066d08a302aff94daaae79770a1e6239be7c..5895d4ba155d31fac00bd54e826821a1b39feb14 100644 (file)
@@ -13,6 +13,7 @@
  */
 
 #include "rgw/rgw_reshard.h"
+#include <spawn/spawn.hpp>
 
 #include <gtest/gtest.h>
 
@@ -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();