]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph.git/commitdiff
osdc: replace asio::io_context::strand with asio::strand<>
authorCasey Bodley <cbodley@redhat.com>
Thu, 9 Feb 2023 19:46:27 +0000 (14:46 -0500)
committerAdam Emerson <aemerson@redhat.com>
Wed, 6 Dec 2023 20:39:35 +0000 (15:39 -0500)
Signed-off-by: Casey Bodley <cbodley@redhat.com>
src/librados/RadosClient.h
src/mon/MonClient.h
src/osdc/Objecter.h

index 052249a76db36953f16836d492e8148b361fadf1..e7144b2e3f9dd2b0a6159c72a63ff3f72e0324d3 100644 (file)
@@ -96,7 +96,8 @@ private:
   int wait_for_osdmap();
 
 public:
-  boost::asio::io_context::strand finish_strand{poolctx.get_io_context()};
+  boost::asio::strand<boost::asio::io_context::executor_type>
+      finish_strand{poolctx.get_executor()};
 
   explicit RadosClient(CephContext *cct);
   ~RadosClient() override;
index 081893ae9c4a48546247068af8f489b9edd0c264..803c74eb7f62945a5841aad665846a42e82f8d0f 100644 (file)
@@ -23,8 +23,8 @@
 #include <vector>
 
 #include <boost/asio/io_context.hpp>
-#include <boost/asio/io_context_strand.hpp>
 #include <boost/asio/steady_timer.hpp>
+#include <boost/asio/strand.hpp>
 
 #include "msg/Messenger.h"
 
@@ -301,7 +301,8 @@ private:
   mutable ceph::mutex monc_lock = ceph::make_mutex("MonClient::monc_lock");
   SafeTimer timer;
   boost::asio::io_context& service;
-  boost::asio::io_context::strand finish_strand{service};
+  boost::asio::strand<boost::asio::io_context::executor_type>
+      finish_strand{service.get_executor()};
 
   bool initialized;
   bool stopping = false;
index a0d9d0b32e767199824ebecd0d3a17d23510efb7..9ca09b476476160c39db5d57c117fdb095df3133 100644 (file)
@@ -1643,7 +1643,8 @@ public:
   boost::asio::io_context& service;
   // The guaranteed sequenced, one-at-a-time execution and apparently
   // people sometimes depend on this.
-  boost::asio::io_context::strand finish_strand{service};
+  boost::asio::strand<boost::asio::io_context::executor_type>
+      finish_strand{service.get_executor()};
   ZTracer::Endpoint trace_endpoint{"0.0.0.0", 0, "Objecter"};
 private:
   std::unique_ptr<OSDMap> osdmap{std::make_unique<OSDMap>()};