From 95867fce14ce6f9e713c4920c094d303c2366093 Mon Sep 17 00:00:00 2001 From: Yehuda Sadeh Date: Tue, 26 Feb 2013 18:01:46 -0800 Subject: cls_version: unitest Signed-off-by: Yehuda Sadeh --- src/Makefile.am | 6 + src/test/cls_version/test_cls_version.cc | 287 +++++++++++++++++++++++++++++++ 2 files changed, 293 insertions(+) create mode 100644 src/test/cls_version/test_cls_version.cc diff --git a/src/Makefile.am b/src/Makefile.am index 4d0c11bfc1a..c7e0bd0c933 100644 --- a/src/Makefile.am +++ b/src/Makefile.am @@ -895,6 +895,12 @@ ceph_test_cls_refcount_LDADD = librados.la libcls_refcount_client.a ${UNITTEST_S ceph_test_cls_refcount_CXXFLAGS = ${AM_CXXFLAGS} ${UNITTEST_CXXFLAGS} bin_DEBUGPROGRAMS += ceph_test_cls_refcount +ceph_test_cls_version_SOURCES = test/cls_version/test_cls_version.cc \ + test/librados/test.cc +ceph_test_cls_version_LDADD = librados.la libcls_version_client.a ${UNITTEST_STATIC_LDADD} +ceph_test_cls_version_CXXFLAGS = ${AM_CXXFLAGS} ${UNITTEST_CXXFLAGS} +bin_DEBUGPROGRAMS += ceph_test_cls_version + ceph_test_cls_lock_SOURCES = test/cls_lock/test_cls_lock.cc test/librados/test.cc ceph_test_cls_lock_LDFLAGS = ${AM_LDFLAGS} ceph_test_cls_lock_LDADD = libcls_lock_client.a librados.la ${UNITTEST_STATIC_LDADD} diff --git a/src/test/cls_version/test_cls_version.cc b/src/test/cls_version/test_cls_version.cc new file mode 100644 index 00000000000..5012957f0ae --- /dev/null +++ b/src/test/cls_version/test_cls_version.cc @@ -0,0 +1,287 @@ +// -*- mode:C; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*- +// vim: ts=8 sw=2 smarttab + +#include "include/types.h" +#include "cls/version/cls_version_types.h" +#include "cls/version/cls_version_client.h" + +#include "gtest/gtest.h" +#include "test/librados/test.h" + +#include +#include +#include + +static librados::ObjectWriteOperation *new_op() { + return new librados::ObjectWriteOperation(); +} + +static librados::ObjectReadOperation *new_rop() { + return new librados::ObjectReadOperation(); +} + +TEST(cls_rgw, test_version_inc_read) +{ + librados::Rados rados; + librados::IoCtx ioctx; + string pool_name = get_temp_pool_name(); + + /* create pool */ + ASSERT_EQ("", create_one_pool_pp(pool_name, rados)); + ASSERT_EQ(0, rados.ioctx_create(pool_name.c_str(), ioctx)); + + /* add chains */ + string oid = "obj"; + + + /* create object */ + + ASSERT_EQ(0, ioctx.create(oid, true)); + + obj_version ver; + + ASSERT_EQ(0, cls_version_read(ioctx, oid, &ver)); + ASSERT_EQ(0, (long long)ver.ver); + ASSERT_EQ(0, (int)ver.tag.size()); + + + /* inc version */ + librados::ObjectWriteOperation *op = new_op(); + cls_version_inc(*op); + ASSERT_EQ(0, ioctx.operate(oid, op)); + + ASSERT_EQ(0, cls_version_read(ioctx, oid, &ver)); + ASSERT_GT((long long)ver.ver, 0); + ASSERT_NE(0, (int)ver.tag.size()); + + /* inc version again! */ + op = new_op(); + cls_version_inc(*op); + ASSERT_EQ(0, ioctx.operate(oid, op)); + + obj_version ver2; + + ASSERT_EQ(0, cls_version_read(ioctx, oid, &ver2)); + ASSERT_GT((long long)ver2.ver, (long long)ver.ver); + ASSERT_EQ(0, (int)ver2.tag.compare(ver.tag)); + + delete op; +} + + +TEST(cls_rgw, test_version_set) +{ + librados::Rados rados; + librados::IoCtx ioctx; + string pool_name = get_temp_pool_name(); + + /* create pool */ + ASSERT_EQ("", create_one_pool_pp(pool_name, rados)); + ASSERT_EQ(0, rados.ioctx_create(pool_name.c_str(), ioctx)); + + /* add chains */ + string oid = "obj"; + + + /* create object */ + + ASSERT_EQ(0, ioctx.create(oid, true)); + + obj_version ver; + + ASSERT_EQ(0, cls_version_read(ioctx, oid, &ver)); + ASSERT_EQ(0, (long long)ver.ver); + ASSERT_EQ(0, (int)ver.tag.size()); + + + ver.ver = 123; + ver.tag = "foo"; + + /* set version */ + librados::ObjectWriteOperation *op = new_op(); + cls_version_set(*op, ver); + ASSERT_EQ(0, ioctx.operate(oid, op)); + + /* read version */ + obj_version ver2; + + ASSERT_EQ(0, cls_version_read(ioctx, oid, &ver2)); + ASSERT_EQ((long long)ver2.ver, (long long)ver.ver); + ASSERT_EQ(0, (int)ver2.tag.compare(ver.tag)); + + delete op; +} + +TEST(cls_rgw, test_version_inc_cond) +{ + librados::Rados rados; + librados::IoCtx ioctx; + string pool_name = get_temp_pool_name(); + + /* create pool */ + ASSERT_EQ("", create_one_pool_pp(pool_name, rados)); + ASSERT_EQ(0, rados.ioctx_create(pool_name.c_str(), ioctx)); + + /* add chains */ + string oid = "obj"; + + + /* create object */ + + ASSERT_EQ(0, ioctx.create(oid, true)); + + obj_version ver; + + ASSERT_EQ(0, cls_version_read(ioctx, oid, &ver)); + ASSERT_EQ(0, (long long)ver.ver); + ASSERT_EQ(0, (int)ver.tag.size()); + + /* inc version */ + librados::ObjectWriteOperation *op = new_op(); + cls_version_inc(*op); + ASSERT_EQ(0, ioctx.operate(oid, op)); + + ASSERT_EQ(0, cls_version_read(ioctx, oid, &ver)); + ASSERT_GT((long long)ver.ver, 0); + ASSERT_NE(0, (int)ver.tag.size()); + + obj_version cond_ver = ver; + + + /* inc version again! */ + op = new_op(); + cls_version_inc(*op); + ASSERT_EQ(0, ioctx.operate(oid, op)); + + obj_version ver2; + + ASSERT_EQ(0, cls_version_read(ioctx, oid, &ver2)); + ASSERT_GT((long long)ver2.ver, (long long)ver.ver); + ASSERT_EQ(0, (int)ver2.tag.compare(ver.tag)); + + + /* now check various condition tests */ + cls_version_inc(*op, cond_ver, VER_COND_NONE); + ASSERT_EQ(0, ioctx.operate(oid, op)); + + ASSERT_EQ(0, cls_version_read(ioctx, oid, &ver2)); + ASSERT_GT((long long)ver2.ver, (long long)ver.ver); + ASSERT_EQ(0, (int)ver2.tag.compare(ver.tag)); + + /* a bunch of conditions that should fail */ + op = new_op(); + cls_version_inc(*op, cond_ver, VER_COND_EQ); + ASSERT_EQ(-ECANCELED, ioctx.operate(oid, op)); + + op = new_op(); + cls_version_inc(*op, cond_ver, VER_COND_LT); + ASSERT_EQ(-ECANCELED, ioctx.operate(oid, op)); + + op = new_op(); + cls_version_inc(*op, cond_ver, VER_COND_LE); + ASSERT_EQ(-ECANCELED, ioctx.operate(oid, op)); + + op = new_op(); + cls_version_inc(*op, cond_ver, VER_COND_TAG_NE); + ASSERT_EQ(-ECANCELED, ioctx.operate(oid, op)); + + ASSERT_EQ(0, cls_version_read(ioctx, oid, &ver2)); + ASSERT_GT((long long)ver2.ver, (long long)ver.ver); + ASSERT_EQ(0, (int)ver2.tag.compare(ver.tag)); + + /* a bunch of conditions that should succeed */ + op = new_op(); + cls_version_inc(*op, ver2, VER_COND_EQ); + ASSERT_EQ(0, ioctx.operate(oid, op)); + + op = new_op(); + cls_version_inc(*op, cond_ver, VER_COND_GT); + ASSERT_EQ(0, ioctx.operate(oid, op)); + + op = new_op(); + cls_version_inc(*op, cond_ver, VER_COND_GE); + ASSERT_EQ(0, ioctx.operate(oid, op)); + + op = new_op(); + cls_version_inc(*op, cond_ver, VER_COND_TAG_EQ); + ASSERT_EQ(0, ioctx.operate(oid, op)); + + delete op; +} + +TEST(cls_rgw, test_version_inc_check) +{ + librados::Rados rados; + librados::IoCtx ioctx; + string pool_name = get_temp_pool_name(); + + /* create pool */ + ASSERT_EQ("", create_one_pool_pp(pool_name, rados)); + ASSERT_EQ(0, rados.ioctx_create(pool_name.c_str(), ioctx)); + + /* add chains */ + string oid = "obj"; + + + /* create object */ + + ASSERT_EQ(0, ioctx.create(oid, true)); + + obj_version ver; + + ASSERT_EQ(0, cls_version_read(ioctx, oid, &ver)); + ASSERT_EQ(0, (long long)ver.ver); + ASSERT_EQ(0, (int)ver.tag.size()); + + /* inc version */ + librados::ObjectWriteOperation *op = new_op(); + cls_version_inc(*op); + ASSERT_EQ(0, ioctx.operate(oid, op)); + + ASSERT_EQ(0, cls_version_read(ioctx, oid, &ver)); + ASSERT_GT((long long)ver.ver, 0); + ASSERT_NE(0, (int)ver.tag.size()); + + obj_version cond_ver = ver; + + /* a bunch of conditions that should succeed */ + librados::ObjectReadOperation *rop = new_rop(); + cls_version_check(*rop, cond_ver, VER_COND_EQ); + bufferlist bl; + ASSERT_EQ(0, ioctx.operate(oid, rop, &bl)); + + rop = new_rop(); + cls_version_check(*rop, cond_ver, VER_COND_GE); + ASSERT_EQ(0, ioctx.operate(oid, rop, &bl)); + + rop = new_rop(); + cls_version_check(*rop, cond_ver, VER_COND_LE); + ASSERT_EQ(0, ioctx.operate(oid, rop, &bl)); + + rop = new_rop(); + cls_version_check(*rop, cond_ver, VER_COND_TAG_EQ); + ASSERT_EQ(0, ioctx.operate(oid, rop, &bl)); + + obj_version ver2; + + op = new_op(); + cls_version_inc(*op); + ASSERT_EQ(0, ioctx.operate(oid, op)); + + ASSERT_EQ(0, cls_version_read(ioctx, oid, &ver2)); + ASSERT_GT((long long)ver2.ver, (long long)ver.ver); + ASSERT_EQ(0, (int)ver2.tag.compare(ver.tag)); + + /* a bunch of conditions that should fail */ + rop = new_rop(); + cls_version_check(*rop, ver, VER_COND_LT); + ASSERT_EQ(-ECANCELED, ioctx.operate(oid, rop, &bl)); + + rop = new_rop(); + cls_version_check(*rop, cond_ver, VER_COND_LE); + ASSERT_EQ(-ECANCELED, ioctx.operate(oid, rop, &bl)); + + rop = new_rop(); + cls_version_check(*rop, cond_ver, VER_COND_TAG_NE); + ASSERT_EQ(-ECANCELED, ioctx.operate(oid, rop, &bl)); +} -- cgit v1.2.1