RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-01-03 17:42:36 +00:00
Code Issues Packages Projects Releases Wiki Activity

rbd: rbd-mirroring: Added unit tests to test enable/disable image mirroring when pool-level mirroring changes

Browse Source 
Signed-off-by: Ricardo Dias <rdias@suse.com>
This commit is contained in:
Ricardo Dias 2016-03-22 13:26:15 +00:00
parent 490dc4f3d8
commit c61ae3e776
1 changed files with 128 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

128
src/test/librbd/test_mirroring.cc
View File

@ -42,6 +42,10 @@ public:
TestFixture::TearDown();
}
virtual void SetUp() {
ASSERT_EQ(0, _rados.ioctx_create(_pool_name.c_str(), m_ioctx));
}
std::string image_name = "mirrorimg1";
void check_mirror_image_enable(uint64_t features,
@ -61,6 +65,7 @@ public:
ASSERT_EQ(0, image.mirror_image_get_info(&mirror_image, sizeof(mirror_image)));
ASSERT_EQ(mirror_state, mirror_image.state);
image.mirror_image_disable(false);
ASSERT_EQ(0, image.close());
ASSERT_EQ(0, m_rbd.remove(m_ioctx, image_name.c_str()));
}
@ -80,6 +85,7 @@ public:
ASSERT_EQ(0, image.mirror_image_get_info(&mirror_image, sizeof(mirror_image)));
ASSERT_EQ(mirror_state, mirror_image.state);
image.mirror_image_disable(false);
ASSERT_EQ(0, image.close());
ASSERT_EQ(0, m_rbd.remove(m_ioctx, image_name.c_str()));
}
@ -106,10 +112,49 @@ public:
librbd::mirror_image_info_t mirror_image;
ASSERT_EQ(0, image.mirror_image_get_info(&mirror_image, sizeof(mirror_image)));
ASSERT_EQ(mirror_state, mirror_image.state);
image.mirror_image_disable(false);
ASSERT_EQ(0, image.close());
ASSERT_EQ(0, m_rbd.remove(m_ioctx, image_name.c_str()));
}
void setup_images_with_mirror_mode(rbd_mirror_mode_t mirror_mode,
std::vector<uint64_t>& features_vec) {
ASSERT_EQ(0, m_rbd.mirror_mode_set(m_ioctx, mirror_mode));
int id = 1;
int order = 20;
for (const auto& features : features_vec) {
std::stringstream img_name("img_");
img_name << id++;
std::string img_name_str = img_name.str();
ASSERT_EQ(0, m_rbd.create2(m_ioctx, img_name_str.c_str(), 2048, features, &order));
}
}
void check_mirroring_on_mirror_mode_set(rbd_mirror_mode_t mirror_mode,
std::vector<rbd_mirror_image_state_t>& states_vec) {
ASSERT_EQ(0, m_rbd.mirror_mode_set(m_ioctx, mirror_mode));
int id = 1;
for (const auto& mirror_state : states_vec) {
std::stringstream img_name("img_");
img_name << id++;
std::string img_name_str = img_name.str();
librbd::Image image;
ASSERT_EQ(0, m_rbd.open(m_ioctx, image, img_name_str.c_str()));
librbd::mirror_image_info_t mirror_image;
ASSERT_EQ(0, image.mirror_image_get_info(&mirror_image, sizeof(mirror_image)));
ASSERT_EQ(mirror_state, mirror_image.state);
image.mirror_image_disable(false);
ASSERT_EQ(0, image.close());
ASSERT_EQ(0, m_rbd.remove(m_ioctx, img_name_str.c_str()));
}
}
};
TEST_F(TestMirroring, EnableImageMirror) {
@ -217,3 +262,86 @@ TEST_F(TestMirroring, DisableJournaling_In_MirrorModeImage) {
RBD_MIRROR_MODE_IMAGE, RBD_MIRROR_IMAGE_ENABLED);
}
TEST_F(TestMirroring, MirrorModeSet_DisabledMode_To_PoolMode) {
std::vector<uint64_t> features_vec;
features_vec.push_back(RBD_FEATURE_EXCLUSIVE_LOCK);
features_vec.push_back(RBD_FEATURE_EXCLUSIVE_LOCK | RBD_FEATURE_JOURNALING);
setup_images_with_mirror_mode(RBD_MIRROR_MODE_DISABLED, features_vec);
std::vector<rbd_mirror_image_state_t> states_vec;
states_vec.push_back(RBD_MIRROR_IMAGE_DISABLED);
states_vec.push_back(RBD_MIRROR_IMAGE_ENABLED);
check_mirroring_on_mirror_mode_set(RBD_MIRROR_MODE_POOL, states_vec);
}
TEST_F(TestMirroring, MirrorModeSet_PoolMode_To_DisabledMode) {
std::vector<uint64_t> features_vec;
features_vec.push_back(RBD_FEATURE_EXCLUSIVE_LOCK);
features_vec.push_back(RBD_FEATURE_EXCLUSIVE_LOCK | RBD_FEATURE_JOURNALING);
setup_images_with_mirror_mode(RBD_MIRROR_MODE_POOL, features_vec);
std::vector<rbd_mirror_image_state_t> states_vec;
states_vec.push_back(RBD_MIRROR_IMAGE_DISABLED);
states_vec.push_back(RBD_MIRROR_IMAGE_DISABLED);
check_mirroring_on_mirror_mode_set(RBD_MIRROR_MODE_DISABLED, states_vec);
}
TEST_F(TestMirroring, MirrorModeSet_DisabledMode_To_ImageMode) {
std::vector<uint64_t> features_vec;
features_vec.push_back(RBD_FEATURE_EXCLUSIVE_LOCK);
features_vec.push_back(RBD_FEATURE_EXCLUSIVE_LOCK | RBD_FEATURE_JOURNALING);
setup_images_with_mirror_mode(RBD_MIRROR_MODE_DISABLED, features_vec);
std::vector<rbd_mirror_image_state_t> states_vec;
states_vec.push_back(RBD_MIRROR_IMAGE_DISABLED);
states_vec.push_back(RBD_MIRROR_IMAGE_DISABLED);
check_mirroring_on_mirror_mode_set(RBD_MIRROR_MODE_IMAGE, states_vec);
}
TEST_F(TestMirroring, MirrorModeSet_PoolMode_To_ImageMode) {
std::vector<uint64_t> features_vec;
features_vec.push_back(RBD_FEATURE_EXCLUSIVE_LOCK);
features_vec.push_back(RBD_FEATURE_EXCLUSIVE_LOCK | RBD_FEATURE_JOURNALING);
setup_images_with_mirror_mode(RBD_MIRROR_MODE_POOL, features_vec);
std::vector<rbd_mirror_image_state_t> states_vec;
states_vec.push_back(RBD_MIRROR_IMAGE_DISABLED);
states_vec.push_back(RBD_MIRROR_IMAGE_ENABLED);
check_mirroring_on_mirror_mode_set(RBD_MIRROR_MODE_IMAGE, states_vec);
}
TEST_F(TestMirroring, MirrorModeSet_ImageMode_To_PoolMode) {
std::vector<uint64_t> features_vec;
features_vec.push_back(RBD_FEATURE_EXCLUSIVE_LOCK);
features_vec.push_back(RBD_FEATURE_EXCLUSIVE_LOCK | RBD_FEATURE_JOURNALING);
setup_images_with_mirror_mode(RBD_MIRROR_MODE_IMAGE, features_vec);
std::vector<rbd_mirror_image_state_t> states_vec;
states_vec.push_back(RBD_MIRROR_IMAGE_DISABLED);
states_vec.push_back(RBD_MIRROR_IMAGE_ENABLED);
check_mirroring_on_mirror_mode_set(RBD_MIRROR_MODE_POOL, states_vec);
}
TEST_F(TestMirroring, MirrorModeSet_ImageMode_To_DisabledMode) {
std::vector<uint64_t> features_vec;
features_vec.push_back(RBD_FEATURE_EXCLUSIVE_LOCK);
features_vec.push_back(RBD_FEATURE_EXCLUSIVE_LOCK | RBD_FEATURE_JOURNALING);
setup_images_with_mirror_mode(RBD_MIRROR_MODE_POOL, features_vec);
ASSERT_EQ(0, m_rbd.mirror_mode_set(m_ioctx, RBD_MIRROR_MODE_IMAGE));
ASSERT_EQ(-EINVAL, m_rbd.mirror_mode_set(m_ioctx, RBD_MIRROR_MODE_DISABLED));
ASSERT_EQ(0, m_rbd.mirror_mode_set(m_ioctx, RBD_MIRROR_MODE_POOL));
std::vector<rbd_mirror_image_state_t> states_vec;
states_vec.push_back(RBD_MIRROR_IMAGE_DISABLED);
states_vec.push_back(RBD_MIRROR_IMAGE_DISABLED);
check_mirroring_on_mirror_mode_set(RBD_MIRROR_MODE_DISABLED, states_vec);
}