X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Ftest%2Fcls_version%2Ftest_cls_version.cc;fp=src%2Fceph%2Fsrc%2Ftest%2Fcls_version%2Ftest_cls_version.cc;h=0000000000000000000000000000000000000000;hb=7da45d65be36d36b880cc55c5036e96c24b53f00;hp=4c2d59500df9b29a5e8d4b88a5c690e4b16bd391;hpb=691462d09d0987b47e112d6ee8740375df3c51b2;p=stor4nfv.git diff --git a/src/ceph/src/test/cls_version/test_cls_version.cc b/src/ceph/src/test/cls_version/test_cls_version.cc deleted file mode 100644 index 4c2d595..0000000 --- a/src/ceph/src/test/cls_version/test_cls_version.cc +++ /dev/null @@ -1,318 +0,0 @@ -// -*- 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! */ - delete op; - 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; - - obj_version ver3; - - librados::ObjectReadOperation *rop = new_rop(); - cls_version_read(*rop, &ver3); - bufferlist outbl; - ASSERT_EQ(0, ioctx.operate(oid, rop, &outbl)); - ASSERT_EQ(ver2.ver, ver3.ver); - ASSERT_EQ(1, (long long)ver2.compare(&ver3)); - - delete rop; -} - - -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! */ - delete op; - 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 */ - delete op; - op = new_op(); - cls_version_inc(*op, cond_ver, VER_COND_EQ); - ASSERT_EQ(-ECANCELED, ioctx.operate(oid, op)); - - delete op; - op = new_op(); - cls_version_inc(*op, cond_ver, VER_COND_LT); - ASSERT_EQ(-ECANCELED, ioctx.operate(oid, op)); - - delete op; - op = new_op(); - cls_version_inc(*op, cond_ver, VER_COND_LE); - ASSERT_EQ(-ECANCELED, ioctx.operate(oid, op)); - - delete 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 */ - delete op; - op = new_op(); - cls_version_inc(*op, ver2, VER_COND_EQ); - ASSERT_EQ(0, ioctx.operate(oid, op)); - - delete op; - op = new_op(); - cls_version_inc(*op, cond_ver, VER_COND_GT); - ASSERT_EQ(0, ioctx.operate(oid, op)); - - delete op; - op = new_op(); - cls_version_inc(*op, cond_ver, VER_COND_GE); - ASSERT_EQ(0, ioctx.operate(oid, op)); - - delete 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)); - - delete rop; - rop = new_rop(); - cls_version_check(*rop, cond_ver, VER_COND_GE); - ASSERT_EQ(0, ioctx.operate(oid, rop, &bl)); - - delete rop; - rop = new_rop(); - cls_version_check(*rop, cond_ver, VER_COND_LE); - ASSERT_EQ(0, ioctx.operate(oid, rop, &bl)); - - delete rop; - rop = new_rop(); - cls_version_check(*rop, cond_ver, VER_COND_TAG_EQ); - ASSERT_EQ(0, ioctx.operate(oid, rop, &bl)); - - obj_version ver2; - - delete op; - 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)); - - delete op; - - /* a bunch of conditions that should fail */ - delete rop; - rop = new_rop(); - cls_version_check(*rop, ver, VER_COND_LT); - ASSERT_EQ(-ECANCELED, ioctx.operate(oid, rop, &bl)); - - delete rop; - rop = new_rop(); - cls_version_check(*rop, cond_ver, VER_COND_LE); - ASSERT_EQ(-ECANCELED, ioctx.operate(oid, rop, &bl)); - - delete rop; - rop = new_rop(); - cls_version_check(*rop, cond_ver, VER_COND_TAG_NE); - ASSERT_EQ(-ECANCELED, ioctx.operate(oid, rop, &bl)); - - delete rop; -}