1 // -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
2 // vim: ts=8 sw=2 smarttab
3 #include "test/librbd/test_fixture.h"
4 #include "test/librbd/test_support.h"
5 #include "librbd/ExclusiveLock.h"
6 #include "librbd/ImageCtx.h"
7 #include "librbd/ImageState.h"
8 #include "librbd/ImageWatcher.h"
9 #include "librbd/internal.h"
10 #include "librbd/ObjectMap.h"
11 #include "cls/rbd/cls_rbd_client.h"
14 void register_test_object_map() {
17 class TestObjectMap
: public TestFixture
{
20 int when_open_object_map(librbd::ImageCtx
*ictx
) {
22 librbd::ObjectMap
<> object_map(*ictx
, ictx
->snap_id
);
23 object_map
.open(&ctx
);
28 TEST_F(TestObjectMap
, RefreshInvalidatesWhenCorrupt
) {
29 REQUIRE_FEATURE(RBD_FEATURE_OBJECT_MAP
);
31 librbd::ImageCtx
*ictx
;
32 ASSERT_EQ(0, open_image(m_image_name
, &ictx
));
34 ASSERT_EQ(0, ictx
->test_flags(RBD_FLAG_OBJECT_MAP_INVALID
, &flags_set
));
35 ASSERT_FALSE(flags_set
);
39 RWLock::WLocker
owner_locker(ictx
->owner_lock
);
40 ictx
->exclusive_lock
->try_acquire_lock(&lock_ctx
);
42 ASSERT_EQ(0, lock_ctx
.wait());
44 std::string oid
= librbd::ObjectMap
<>::object_map_name(ictx
->id
, CEPH_NOSNAP
);
47 ASSERT_EQ(0, ictx
->md_ctx
.write_full(oid
, bl
));
49 ASSERT_EQ(0, when_open_object_map(ictx
));
50 ASSERT_EQ(0, ictx
->test_flags(RBD_FLAG_OBJECT_MAP_INVALID
, &flags_set
));
51 ASSERT_TRUE(flags_set
);
54 TEST_F(TestObjectMap
, RefreshInvalidatesWhenTooSmall
) {
55 REQUIRE_FEATURE(RBD_FEATURE_OBJECT_MAP
);
57 librbd::ImageCtx
*ictx
;
58 ASSERT_EQ(0, open_image(m_image_name
, &ictx
));
60 ASSERT_EQ(0, ictx
->test_flags(RBD_FLAG_OBJECT_MAP_INVALID
, &flags_set
));
61 ASSERT_FALSE(flags_set
);
65 RWLock::WLocker
owner_locker(ictx
->owner_lock
);
66 ictx
->exclusive_lock
->try_acquire_lock(&lock_ctx
);
68 ASSERT_EQ(0, lock_ctx
.wait());
70 librados::ObjectWriteOperation op
;
71 librbd::cls_client::object_map_resize(&op
, 0, OBJECT_NONEXISTENT
);
73 std::string oid
= librbd::ObjectMap
<>::object_map_name(ictx
->id
, CEPH_NOSNAP
);
74 ASSERT_EQ(0, ictx
->md_ctx
.operate(oid
, &op
));
76 ASSERT_EQ(0, when_open_object_map(ictx
));
77 ASSERT_EQ(0, ictx
->test_flags(RBD_FLAG_OBJECT_MAP_INVALID
, &flags_set
));
78 ASSERT_TRUE(flags_set
);
81 TEST_F(TestObjectMap
, InvalidateFlagOnDisk
) {
82 REQUIRE_FEATURE(RBD_FEATURE_OBJECT_MAP
);
84 librbd::ImageCtx
*ictx
;
85 ASSERT_EQ(0, open_image(m_image_name
, &ictx
));
87 ASSERT_EQ(0, ictx
->test_flags(RBD_FLAG_OBJECT_MAP_INVALID
, &flags_set
));
88 ASSERT_FALSE(flags_set
);
92 RWLock::WLocker
owner_locker(ictx
->owner_lock
);
93 ictx
->exclusive_lock
->try_acquire_lock(&lock_ctx
);
95 ASSERT_EQ(0, lock_ctx
.wait());
97 std::string oid
= librbd::ObjectMap
<>::object_map_name(ictx
->id
, CEPH_NOSNAP
);
100 ASSERT_EQ(0, ictx
->md_ctx
.write_full(oid
, bl
));
102 ASSERT_EQ(0, when_open_object_map(ictx
));
103 ASSERT_EQ(0, ictx
->test_flags(RBD_FLAG_OBJECT_MAP_INVALID
, &flags_set
));
104 ASSERT_TRUE(flags_set
);
106 ASSERT_EQ(0, open_image(m_image_name
, &ictx
));
107 ASSERT_EQ(0, ictx
->test_flags(RBD_FLAG_OBJECT_MAP_INVALID
, &flags_set
));
108 ASSERT_TRUE(flags_set
);
111 TEST_F(TestObjectMap
, AcquireLockInvalidatesWhenTooSmall
) {
112 REQUIRE_FEATURE(RBD_FEATURE_OBJECT_MAP
);
114 librbd::ImageCtx
*ictx
;
115 ASSERT_EQ(0, open_image(m_image_name
, &ictx
));
117 ASSERT_EQ(0, ictx
->test_flags(RBD_FLAG_OBJECT_MAP_INVALID
, &flags_set
));
118 ASSERT_FALSE(flags_set
);
120 librados::ObjectWriteOperation op
;
121 librbd::cls_client::object_map_resize(&op
, 0, OBJECT_NONEXISTENT
);
123 std::string oid
= librbd::ObjectMap
<>::object_map_name(ictx
->id
, CEPH_NOSNAP
);
124 ASSERT_EQ(0, ictx
->md_ctx
.operate(oid
, &op
));
126 C_SaferCond lock_ctx
;
128 RWLock::WLocker
owner_locker(ictx
->owner_lock
);
129 ictx
->exclusive_lock
->try_acquire_lock(&lock_ctx
);
131 ASSERT_EQ(0, lock_ctx
.wait());
133 ASSERT_EQ(0, ictx
->test_flags(RBD_FLAG_OBJECT_MAP_INVALID
, &flags_set
));
134 ASSERT_TRUE(flags_set
);
136 // Test the flag is stored on disk
137 ASSERT_EQ(0, ictx
->state
->refresh());
138 ASSERT_EQ(0, ictx
->test_flags(RBD_FLAG_OBJECT_MAP_INVALID
,
140 ASSERT_TRUE(flags_set
);