X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Ftest%2Flibrbd%2Fobject_map%2Ftest_mock_LockRequest.cc;fp=src%2Fceph%2Fsrc%2Ftest%2Flibrbd%2Fobject_map%2Ftest_mock_LockRequest.cc;h=0000000000000000000000000000000000000000;hb=7da45d65be36d36b880cc55c5036e96c24b53f00;hp=413fd71b186a12d8a5a9a1d10b11f695193753ba;hpb=691462d09d0987b47e112d6ee8740375df3c51b2;p=stor4nfv.git diff --git a/src/ceph/src/test/librbd/object_map/test_mock_LockRequest.cc b/src/ceph/src/test/librbd/object_map/test_mock_LockRequest.cc deleted file mode 100644 index 413fd71..0000000 --- a/src/ceph/src/test/librbd/object_map/test_mock_LockRequest.cc +++ /dev/null @@ -1,219 +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/librados_test_stub/MockTestMemIoCtxImpl.h" -#include "cls/lock/cls_lock_ops.h" -#include "librbd/ObjectMap.h" -#include "librbd/object_map/LockRequest.h" - -// template definitions -#include "librbd/object_map/LockRequest.cc" - -namespace librbd { -namespace object_map { - -using ::testing::_; -using ::testing::DoAll; -using ::testing::InSequence; -using ::testing::Return; -using ::testing::StrEq; -using ::testing::WithArg; - -class TestMockObjectMapLockRequest : public TestMockFixture { -public: - typedef LockRequest MockLockRequest; - - void expect_lock(MockImageCtx &mock_image_ctx, int r) { - std::string oid(ObjectMap<>::object_map_name(mock_image_ctx.id, - CEPH_NOSNAP)); - EXPECT_CALL(get_mock_io_ctx(mock_image_ctx.md_ctx), - exec(oid, _, StrEq("lock"), StrEq("lock"), _, _, _)) - .WillOnce(Return(r)); - } - - void expect_get_lock_info(MockImageCtx &mock_image_ctx, int r) { - std::string oid(ObjectMap<>::object_map_name(mock_image_ctx.id, - CEPH_NOSNAP)); - auto &expect = EXPECT_CALL(get_mock_io_ctx(mock_image_ctx.md_ctx), - exec(oid, _, StrEq("lock"), StrEq("get_info"), _, _, _)); - if (r < 0) { - expect.WillOnce(Return(r)); - } else { - entity_name_t entity1(entity_name_t::CLIENT(1)); - entity_name_t entity2(entity_name_t::CLIENT(2)); - - cls_lock_get_info_reply reply; - reply.lockers = decltype(reply.lockers){ - {rados::cls::lock::locker_id_t(entity1, "cookie1"), - rados::cls::lock::locker_info_t()}, - {rados::cls::lock::locker_id_t(entity2, "cookie2"), - rados::cls::lock::locker_info_t()}}; - - bufferlist bl; - ::encode(reply, bl, CEPH_FEATURES_SUPPORTED_DEFAULT); - - std::string str(bl.c_str(), bl.length()); - expect.WillOnce(DoAll(WithArg<5>(CopyInBufferlist(str)), Return(r))); - } - } - - void expect_break_lock(MockImageCtx &mock_image_ctx, int r) { - std::string oid(ObjectMap<>::object_map_name(mock_image_ctx.id, - CEPH_NOSNAP)); - auto &expect = EXPECT_CALL(get_mock_io_ctx(mock_image_ctx.md_ctx), - exec(oid, _, StrEq("lock"), StrEq("break_lock"), _, _, _)); - if (r < 0) { - expect.WillOnce(Return(r)); - } else { - expect.Times(2).WillRepeatedly(Return(0)); - } - } -}; - -TEST_F(TestMockObjectMapLockRequest, Success) { - librbd::ImageCtx *ictx; - ASSERT_EQ(0, open_image(m_image_name, &ictx)); - - MockImageCtx mock_image_ctx(*ictx); - - C_SaferCond ctx; - MockLockRequest *req = new MockLockRequest(mock_image_ctx, &ctx); - - InSequence seq; - expect_lock(mock_image_ctx, 0); - req->send(); - - ASSERT_EQ(0, ctx.wait()); -} - -TEST_F(TestMockObjectMapLockRequest, LockBusy) { - librbd::ImageCtx *ictx; - ASSERT_EQ(0, open_image(m_image_name, &ictx)); - - MockImageCtx mock_image_ctx(*ictx); - - C_SaferCond ctx; - MockLockRequest *req = new MockLockRequest(mock_image_ctx, &ctx); - - InSequence seq; - expect_lock(mock_image_ctx, -EBUSY); - expect_get_lock_info(mock_image_ctx, 0); - expect_break_lock(mock_image_ctx, 0); - expect_lock(mock_image_ctx, 0); - req->send(); - - ASSERT_EQ(0, ctx.wait()); -} - -TEST_F(TestMockObjectMapLockRequest, LockError) { - librbd::ImageCtx *ictx; - ASSERT_EQ(0, open_image(m_image_name, &ictx)); - - MockImageCtx mock_image_ctx(*ictx); - - C_SaferCond ctx; - MockLockRequest *req = new MockLockRequest(mock_image_ctx, &ctx); - - InSequence seq; - expect_lock(mock_image_ctx, -ENOENT); - req->send(); - - ASSERT_EQ(0, ctx.wait()); -} - -TEST_F(TestMockObjectMapLockRequest, GetLockInfoMissing) { - librbd::ImageCtx *ictx; - ASSERT_EQ(0, open_image(m_image_name, &ictx)); - - MockImageCtx mock_image_ctx(*ictx); - - C_SaferCond ctx; - MockLockRequest *req = new MockLockRequest(mock_image_ctx, &ctx); - - InSequence seq; - expect_lock(mock_image_ctx, -EBUSY); - expect_get_lock_info(mock_image_ctx, -ENOENT); - expect_lock(mock_image_ctx, 0); - req->send(); - - ASSERT_EQ(0, ctx.wait()); -} - -TEST_F(TestMockObjectMapLockRequest, GetLockInfoError) { - librbd::ImageCtx *ictx; - ASSERT_EQ(0, open_image(m_image_name, &ictx)); - - MockImageCtx mock_image_ctx(*ictx); - - C_SaferCond ctx; - MockLockRequest *req = new MockLockRequest(mock_image_ctx, &ctx); - - InSequence seq; - expect_lock(mock_image_ctx, -EBUSY); - expect_get_lock_info(mock_image_ctx, -EINVAL); - req->send(); - - ASSERT_EQ(0, ctx.wait()); -} - -TEST_F(TestMockObjectMapLockRequest, BreakLockMissing) { - librbd::ImageCtx *ictx; - ASSERT_EQ(0, open_image(m_image_name, &ictx)); - - MockImageCtx mock_image_ctx(*ictx); - - C_SaferCond ctx; - MockLockRequest *req = new MockLockRequest(mock_image_ctx, &ctx); - - InSequence seq; - expect_lock(mock_image_ctx, -EBUSY); - expect_get_lock_info(mock_image_ctx, 0); - expect_break_lock(mock_image_ctx, -ENOENT); - expect_lock(mock_image_ctx, 0); - req->send(); - - ASSERT_EQ(0, ctx.wait()); -} - -TEST_F(TestMockObjectMapLockRequest, BreakLockError) { - librbd::ImageCtx *ictx; - ASSERT_EQ(0, open_image(m_image_name, &ictx)); - - MockImageCtx mock_image_ctx(*ictx); - - C_SaferCond ctx; - MockLockRequest *req = new MockLockRequest(mock_image_ctx, &ctx); - - InSequence seq; - expect_lock(mock_image_ctx, -EBUSY); - expect_get_lock_info(mock_image_ctx, 0); - expect_break_lock(mock_image_ctx, -EINVAL); - req->send(); - - ASSERT_EQ(0, ctx.wait()); -} - -TEST_F(TestMockObjectMapLockRequest, LockErrorAfterBrokeLock) { - librbd::ImageCtx *ictx; - ASSERT_EQ(0, open_image(m_image_name, &ictx)); - - MockImageCtx mock_image_ctx(*ictx); - - C_SaferCond ctx; - MockLockRequest *req = new MockLockRequest(mock_image_ctx, &ctx); - - InSequence seq; - expect_lock(mock_image_ctx, -EBUSY); - expect_get_lock_info(mock_image_ctx, 0); - expect_break_lock(mock_image_ctx, 0); - expect_lock(mock_image_ctx, -EBUSY); - req->send(); - - ASSERT_EQ(0, ctx.wait()); -} - -} // namespace object_map -} // namespace librbd