update source to Ceph Pacific 16.2.2

[ceph.git] / ceph / src / test / librbd / deep_copy / test_mock_SetHeadRequest.cc

diff --git a/ceph/src/test/librbd/deep_copy/test_mock_SetHeadRequest.cc b/ceph/src/test/librbd/deep_copy/test_mock_SetHeadRequest.cc
index f0714f9d303308e60a86be7ca97f03371f649e8e..209339973ed0c203edada392d94c29cebba57b60 100644 (file)
--- a/ceph/src/test/librbd/deep_copy/test_mock_SetHeadRequest.cc
+++ b/ceph/src/test/librbd/deep_copy/test_mock_SetHeadRequest.cc
@@ -4,6 +4,7 @@
 #include "test/librbd/test_mock_fixture.h"
 #include "test/librados_test_stub/LibradosTestStub.h"
 #include "include/rbd/librbd.hpp"
+#include "librbd/AsioEngine.h"
 #include "librbd/ImageCtx.h"
 #include "librbd/ImageState.h"
 #include "osdc/Striper.h"
@@ -97,16 +98,18 @@ public:
   typedef image::DetachParentRequest<MockTestImageCtx> MockDetachParentRequest;
 
   librbd::ImageCtx *m_image_ctx;
-  ThreadPool *m_thread_pool;
-  ContextWQ *m_work_queue;
+
+  std::shared_ptr<librbd::AsioEngine> m_asio_engine;
+  asio::ContextWQ *m_work_queue;
 
   void SetUp() override {
     TestMockFixture::SetUp();
 
     ASSERT_EQ(0, open_image(m_image_name, &m_image_ctx));
 
-    librbd::ImageCtx::get_thread_pool_instance(m_image_ctx->cct, &m_thread_pool,
-                                               &m_work_queue);
+    m_asio_engine = std::make_shared<librbd::AsioEngine>(
+      m_image_ctx->md_ctx);
+    m_work_queue = m_asio_engine->get_work_queue();
   }
 
   void expect_start_op(librbd::MockExclusiveLock &mock_exclusive_lock) {
@@ -121,7 +124,8 @@ public:
 
   void expect_set_size(librbd::MockTestImageCtx &mock_image_ctx, int r) {
     EXPECT_CALL(get_mock_io_ctx(mock_image_ctx.md_ctx),
-                exec(mock_image_ctx.header_oid, _, StrEq("rbd"), StrEq("set_size"), _, _, _))
+                exec(mock_image_ctx.header_oid, _, StrEq("rbd"),
+                     StrEq("set_size"), _, _, _, _))
                   .WillOnce(Return(r));
   }