remove ceph code

[stor4nfv.git] / src / ceph / src / test / librbd / operation / test_mock_Request.cc

diff --git a/src/ceph/src/test/librbd/operation/test_mock_Request.cc b/src/ceph/src/test/librbd/operation/test_mock_Request.cc
deleted file mode 100644 (file)
index df0e38d..0000000
--- a/src/ceph/src/test/librbd/operation/test_mock_Request.cc
+++ /dev/null
@@ -1,175 +0,0 @@
-// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
-// vim: ts=8 sw=2 smarttab
-
-#include "test/librbd/test_mock_fixture.h"
-#include "test/librbd/test_support.h"
-#include "test/librbd/mock/MockImageCtx.h"
-#include "test/librbd/mock/MockJournal.h"
-#include "librbd/AsyncRequest.h"
-#include "librbd/operation/Request.h"
-
-namespace librbd {
-namespace {
-
-struct MockTestImageCtx : public MockImageCtx {
-  MockTestImageCtx(ImageCtx &image_ctx) : MockImageCtx(image_ctx) {
-  }
-};
-
-} // anonymous namespace
-
-template <>
-struct AsyncRequest<librbd::MockTestImageCtx> {
-  librbd::MockTestImageCtx &m_image_ctx;
-  Context *m_on_finish;
-
-  AsyncRequest(librbd::MockTestImageCtx &image_ctx, Context *on_finish)
-    : m_image_ctx(image_ctx), m_on_finish(on_finish) {
-  }
-  virtual ~AsyncRequest() {
-  }
-
-  virtual void finish(int r) {
-    m_on_finish->complete(r);
-  }
-  virtual void finish_and_destroy(int r) {
-    finish(r);
-    delete this;
-  }
-};
-
-} // namespace librbd
-
-#include "librbd/operation/Request.cc"
-
-namespace librbd {
-namespace journal {
-
-std::ostream& operator<<(std::ostream& os, const Event&) {
-  return os;
-}
-
-} // namespace journal
-
-namespace operation {
-
-using ::testing::InSequence;
-using ::testing::Invoke;
-using ::testing::Return;
-
-struct MockRequest : public Request<librbd::MockTestImageCtx> {
-  MockRequest(librbd::MockTestImageCtx &image_ctx, Context *on_finish,
-              uint64_t journal_op_tid)
-    : Request<librbd::MockTestImageCtx>(image_ctx, on_finish, journal_op_tid) {
-  }
-
-  void complete(int r) {
-    finish_and_destroy(r);
-  }
-
-  void send_op_impl(int r) {
-    bool appending = append_op_event<
-      MockRequest, &MockRequest::handle_send>(this);
-    if (!appending) {
-      complete(r);
-    }
-  }
-  MOCK_METHOD1(should_complete, bool(int));
-  MOCK_METHOD0(send_op, void());
-  MOCK_METHOD1(handle_send, Context*(int*));
-  MOCK_CONST_METHOD0(can_affect_io, bool());
-  MOCK_CONST_METHOD1(create_event, journal::Event(uint64_t));
-};
-
-struct TestMockOperationRequest : public TestMockFixture {
-  void expect_can_affect_io(MockRequest &mock_request, bool can_affect) {
-    EXPECT_CALL(mock_request, can_affect_io())
-      .WillOnce(Return(can_affect));
-  }
-
-  void expect_is_journal_replaying(MockJournal &mock_journal, bool replaying) {
-    EXPECT_CALL(mock_journal, is_journal_replaying())
-      .WillOnce(Return(replaying));
-  }
-
-  void expect_is_journal_appending(MockJournal &mock_journal, bool appending) {
-    EXPECT_CALL(mock_journal, is_journal_appending())
-      .WillOnce(Return(appending));
-  }
-
-  void expect_send_op(MockRequest &mock_request, int r) {
-    EXPECT_CALL(mock_request, send_op())
-      .WillOnce(Invoke([&mock_request, r]() {
-                  mock_request.complete(r);
-                }));
-  }
-
-  void expect_send_op_affects_io(MockImageCtx &mock_image_ctx,
-                                 MockRequest &mock_request, int r) {
-    EXPECT_CALL(mock_request, send_op())
-      .WillOnce(Invoke([&mock_image_ctx, &mock_request, r]() {
-                  mock_image_ctx.image_ctx->op_work_queue->queue(
-                    new FunctionContext([&mock_request, r](int _) {
-                      mock_request.send_op_impl(r);
-                    }), 0);
-                }));
-  }
-
-};
-
-TEST_F(TestMockOperationRequest, SendJournalDisabled) {
-  REQUIRE_FEATURE(RBD_FEATURE_JOURNALING);
-
-  librbd::ImageCtx *ictx;
-  ASSERT_EQ(0, open_image(m_image_name, &ictx));
-
-  MockTestImageCtx mock_image_ctx(*ictx);
-  MockJournal mock_journal;
-  mock_image_ctx.journal = &mock_journal;
-
-  C_SaferCond ctx;
-  MockRequest *mock_request = new MockRequest(mock_image_ctx, &ctx, 0);
-
-  InSequence seq;
-  expect_can_affect_io(*mock_request, false);
-  expect_is_journal_appending(mock_journal, false);
-  expect_send_op(*mock_request, 0);
-
-  {
-    RWLock::RLocker owner_locker(mock_image_ctx.owner_lock);
-    mock_request->send();
-  }
-
-  ASSERT_EQ(0, ctx.wait());
-}
-
-TEST_F(TestMockOperationRequest, SendAffectsIOJournalDisabled) {
-  REQUIRE_FEATURE(RBD_FEATURE_JOURNALING);
-
-  librbd::ImageCtx *ictx;
-  ASSERT_EQ(0, open_image(m_image_name, &ictx));
-
-  MockTestImageCtx mock_image_ctx(*ictx);
-  MockJournal mock_journal;
-  mock_image_ctx.journal = &mock_journal;
-
-  C_SaferCond ctx;
-  MockRequest *mock_request = new MockRequest(mock_image_ctx, &ctx, 0);
-
-  InSequence seq;
-  expect_can_affect_io(*mock_request, true);
-  expect_send_op_affects_io(mock_image_ctx, *mock_request, 0);
-  expect_can_affect_io(*mock_request, true);
-  expect_is_journal_replaying(mock_journal, false);
-  expect_is_journal_appending(mock_journal, false);
-
-  {
-    RWLock::RLocker owner_locker(mock_image_ctx.owner_lock);
-    mock_request->send();
-  }
-
-  ASSERT_EQ(0, ctx.wait());
-}
-
-} // namespace operation
-} // namespace librbd