diff options
Diffstat (limited to 'src/test/cls_rgw_gc')
| -rw-r--r-- | src/test/cls_rgw_gc/CMakeLists.txt | 18 | ||||
| -rw-r--r-- | src/test/cls_rgw_gc/test_cls_rgw_gc.cc | 699 |
2 files changed, 717 insertions, 0 deletions
diff --git a/src/test/cls_rgw_gc/CMakeLists.txt b/src/test/cls_rgw_gc/CMakeLists.txt new file mode 100644 index 000000000..dd1661525 --- /dev/null +++ b/src/test/cls_rgw_gc/CMakeLists.txt @@ -0,0 +1,18 @@ +if(${WITH_RADOSGW}) + add_executable(ceph_test_cls_rgw_gc + test_cls_rgw_gc.cc + ) + target_link_libraries(ceph_test_cls_rgw_gc + cls_rgw_gc_client + librados + global + ${UNITTEST_LIBS} + ${EXTRALIBS} + ${BLKID_LIBRARIES} + ${CMAKE_DL_LIBS} + radostest-cxx) + install(TARGETS + ceph_test_cls_rgw_gc + DESTINATION ${CMAKE_INSTALL_BINDIR}) +endif(${WITH_RADOSGW}) + diff --git a/src/test/cls_rgw_gc/test_cls_rgw_gc.cc b/src/test/cls_rgw_gc/test_cls_rgw_gc.cc new file mode 100644 index 000000000..26a1e11ae --- /dev/null +++ b/src/test/cls_rgw_gc/test_cls_rgw_gc.cc @@ -0,0 +1,699 @@ +// -*- 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/rgw/cls_rgw_types.h" +#include "cls/rgw_gc/cls_rgw_gc_client.h" +#include "cls/rgw_gc/cls_rgw_gc_ops.h" + +#include "gtest/gtest.h" +#include "test/librados/test_cxx.h" +#include "global/global_context.h" + +#include <errno.h> +#include <string> +#include <vector> +#include <map> +#include <set> + +using namespace librados; + +librados::Rados rados; +librados::IoCtx ioctx; +string pool_name; + + +/* must be the first test! */ +TEST(cls_rgw_gc, init) +{ + 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)); +} + + +string str_int(string s, int i) +{ + char buf[32]; + snprintf(buf, sizeof(buf), "-%d", i); + s.append(buf); + + return s; +} + +/* test garbage collection */ +static void create_obj(cls_rgw_obj& obj, int i, int j) +{ + char buf[32]; + snprintf(buf, sizeof(buf), "-%d.%d", i, j); + obj.pool = "pool"; + obj.pool.append(buf); + obj.key.name = "oid"; + obj.key.name.append(buf); + obj.loc = "loc"; + obj.loc.append(buf); +} + +TEST(cls_rgw_gc, gc_queue_ops1) +{ + //Testing queue ops when data size is NOT a multiple of queue size + string queue_name = "my-queue"; + uint64_t queue_size = 322, num_urgent_data_entries = 10; + librados::ObjectWriteOperation op; + op.create(true); + cls_rgw_gc_queue_init(op, queue_size, num_urgent_data_entries); + ASSERT_EQ(0, ioctx.operate(queue_name, &op)); + + uint64_t size = 0; + int ret = cls_rgw_gc_queue_get_capacity(ioctx, queue_name, size); + ASSERT_EQ(0, ret); + ASSERT_EQ(queue_size, size); + + //Test enqueue + for (int i = 0; i < 2; i++) { + string tag = "chain-" + to_string(i); + librados::ObjectWriteOperation op; + cls_rgw_gc_obj_info info; + + cls_rgw_obj obj1, obj2; + create_obj(obj1, i, 1); + create_obj(obj2, i, 2); + info.chain.objs.push_back(obj1); + info.chain.objs.push_back(obj2); + + info.tag = tag; + cls_rgw_gc_queue_enqueue(op, 0, info); + if (i == 1) { + ASSERT_EQ(-ENOSPC, ioctx.operate(queue_name, &op)); + } else { + ASSERT_EQ(0, ioctx.operate(queue_name, &op)); + } + } + + //Test remove queue entries + librados::ObjectWriteOperation remove_op; + string marker1; + uint64_t num_entries = 1; + cls_rgw_gc_queue_remove_entries(remove_op, num_entries); + ASSERT_EQ(0, ioctx.operate(queue_name, &remove_op)); + + //Test enqueue again + for (int i = 0; i < 1; i++) { + string tag = "chain-" + to_string(i); + librados::ObjectWriteOperation op; + cls_rgw_gc_obj_info info; + + cls_rgw_obj obj1, obj2; + create_obj(obj1, i, 1); + create_obj(obj2, i, 2); + info.chain.objs.push_back(obj1); + info.chain.objs.push_back(obj2); + + info.tag = tag; + cls_rgw_gc_queue_enqueue(op, 0, info); + ASSERT_EQ(0, ioctx.operate(queue_name, &op)); + } + + //Test list queue + list<cls_rgw_gc_obj_info> list_info1; + string marker, next_marker; + uint64_t max = 1; + bool expired_only = false, truncated; + cls_rgw_gc_queue_list_entries(ioctx, queue_name, marker, max, expired_only, list_info1, &truncated, next_marker); + ASSERT_EQ(1, list_info1.size()); + + for (auto it : list_info1) { + std::cerr << "[ ] list info tag = " << it.tag << std::endl; + ASSERT_EQ("chain-0", it.tag); + } +} + +TEST(cls_rgw_gc, gc_queue_ops2) +{ + //Testing list queue + string queue_name = "my-second-queue"; + uint64_t queue_size = 334, num_urgent_data_entries = 10; + librados::ObjectWriteOperation op; + op.create(true); + cls_rgw_gc_queue_init(op, queue_size, num_urgent_data_entries); + ASSERT_EQ(0, ioctx.operate(queue_name, &op)); + + uint64_t size = 0; + int ret = cls_rgw_gc_queue_get_capacity(ioctx, queue_name, size); + ASSERT_EQ(0, ret); + ASSERT_EQ(size, queue_size); + + //Test list queue, when queue is empty + list<cls_rgw_gc_obj_info> list_info; + string marker1, next_marker1; + uint64_t max1 = 2; + bool expired_only1 = false, truncated1; + cls_rgw_gc_queue_list_entries(ioctx, queue_name, marker1, max1, expired_only1, list_info, &truncated1, next_marker1); + ASSERT_EQ(0, list_info.size()); + + //Test enqueue + for (int i = 0; i < 3; i++) { + string tag = "chain-" + to_string(i); + librados::ObjectWriteOperation op; + cls_rgw_gc_obj_info info; + + cls_rgw_obj obj1, obj2; + create_obj(obj1, i, 1); + create_obj(obj2, i, 2); + info.chain.objs.push_back(obj1); + info.chain.objs.push_back(obj2); + + info.tag = tag; + cls_rgw_gc_queue_enqueue(op, 0, info); + if (i == 2) { + ASSERT_EQ(-ENOSPC, ioctx.operate(queue_name, &op)); + } else { + ASSERT_EQ(0, ioctx.operate(queue_name, &op)); + } + } + + //Test list queue + list<cls_rgw_gc_obj_info> list_info1, list_info2, list_info3; + string marker, next_marker; + uint64_t max = 2; + bool expired_only = false, truncated; + cls_rgw_gc_queue_list_entries(ioctx, queue_name, marker, max, expired_only, list_info1, &truncated, next_marker); + ASSERT_EQ(2, list_info1.size()); + + int i = 0; + for (auto it : list_info1) { + string tag = "chain-" + to_string(i); + ASSERT_EQ(tag, it.tag); + i++; + } + + max = 1; + truncated = false; + cls_rgw_gc_queue_list_entries(ioctx, queue_name, marker, max, expired_only, list_info2, &truncated, next_marker); + auto it = list_info2.front(); + ASSERT_EQ(1, list_info2.size()); + ASSERT_EQ(true, truncated); + ASSERT_EQ("chain-0", it.tag); + std::cerr << "[ ] next_marker is: = " << next_marker << std::endl; + + marker = next_marker; + cls_rgw_gc_queue_list_entries(ioctx, queue_name, marker, max, expired_only, list_info3, &truncated, next_marker); + it = list_info3.front(); + ASSERT_EQ(1, list_info3.size()); + ASSERT_EQ(false, truncated); + ASSERT_EQ("chain-1", it.tag); +} + +#if 0 // TODO: fix or remove defer_gc() +TEST(cls_rgw_gc, gc_queue_ops3) +{ + //Testing remove queue entries + string queue_name = "my-third-queue"; + uint64_t queue_size = 501, num_urgent_data_entries = 10; + librados::ObjectWriteOperation op; + op.create(true); + cls_rgw_gc_queue_init(op, queue_size, num_urgent_data_entries); + ASSERT_EQ(0, ioctx.operate(queue_name, &op)); + + uint64_t size = 0; + int ret = cls_rgw_gc_queue_get_capacity(ioctx, queue_name, size); + ASSERT_EQ(0, ret); + ASSERT_EQ(size, queue_size); + + //Test remove queue, when queue is empty + librados::ObjectWriteOperation remove_op; + string marker1; + uint64_t num_entries = 2; + cls_rgw_gc_queue_remove_entries(remove_op, num_entries); + ASSERT_EQ(0, ioctx.operate(queue_name, &remove_op)); + + cls_rgw_gc_obj_info defer_info; + + //Test enqueue + for (int i = 0; i < 2; i++) { + string tag = "chain-" + to_string(i); + librados::ObjectWriteOperation op; + cls_rgw_gc_obj_info info; + + cls_rgw_obj obj1, obj2; + create_obj(obj1, i, 1); + create_obj(obj2, i, 2); + info.chain.objs.push_back(obj1); + info.chain.objs.push_back(obj2); + + info.tag = tag; + cls_rgw_gc_queue_enqueue(op, 5, info); + ASSERT_EQ(0, ioctx.operate(queue_name, &op)); + if (i == 0) + defer_info = info; + } + + //Test defer entry for 1st element + librados::ObjectWriteOperation defer_op; + cls_rgw_gc_queue_defer_entry(defer_op, 10, defer_info); + ASSERT_EQ(0, ioctx.operate(queue_name, &defer_op)); + + //Test list queue + list<cls_rgw_gc_obj_info> list_info1, list_info2; + string marker, next_marker; + uint64_t max = 2; + bool expired_only = false, truncated; + cls_rgw_gc_queue_list_entries(ioctx, queue_name, marker, max, expired_only, list_info1, &truncated, next_marker); + ASSERT_EQ(2, list_info1.size()); + + int i = 0; + for (auto it : list_info1) { + std::cerr << "[ ] list info tag = " << it.tag << std::endl; + if (i == 0) { + ASSERT_EQ("chain-1", it.tag); + } + if (i == 1) { + ASSERT_EQ("chain-0", it.tag); + } + i++; + } + + //Test remove entries + num_entries = 2; + cls_rgw_gc_queue_remove_entries(remove_op, num_entries); + ASSERT_EQ(0, ioctx.operate(queue_name, &remove_op)); + + //Test list queue again + cls_rgw_gc_queue_list_entries(ioctx, queue_name, marker, max, expired_only, list_info2, &truncated, next_marker); + ASSERT_EQ(0, list_info2.size()); + +} + +TEST(cls_rgw_gc, gc_queue_ops4) +{ + //Testing remove queue entries + string queue_name = "my-fourth-queue"; + uint64_t queue_size = 501, num_urgent_data_entries = 10; + librados::ObjectWriteOperation op; + op.create(true); + cls_rgw_gc_queue_init(op, queue_size, num_urgent_data_entries); + ASSERT_EQ(0, ioctx.operate(queue_name, &op)); + + uint64_t size = 0; + int ret = cls_rgw_gc_queue_get_capacity(ioctx, queue_name, size); + ASSERT_EQ(0, ret); + ASSERT_EQ(size, queue_size); + + //Test remove queue, when queue is empty + librados::ObjectWriteOperation remove_op; + string marker1; + uint64_t num_entries = 2; + + cls_rgw_gc_queue_remove_entries(remove_op, num_entries); + ASSERT_EQ(0, ioctx.operate(queue_name, &remove_op)); + + cls_rgw_gc_obj_info defer_info; + + //Test enqueue + for (int i = 0; i < 2; i++) { + string tag = "chain-" + to_string(i); + librados::ObjectWriteOperation op; + cls_rgw_gc_obj_info info; + + cls_rgw_obj obj1, obj2; + create_obj(obj1, i, 1); + create_obj(obj2, i, 2); + info.chain.objs.push_back(obj1); + info.chain.objs.push_back(obj2); + + info.tag = tag; + cls_rgw_gc_queue_enqueue(op, 5, info); + ASSERT_EQ(0, ioctx.operate(queue_name, &op)); + defer_info = info; + } + + //Test defer entry for last element + librados::ObjectWriteOperation defer_op; + cls_rgw_gc_queue_defer_entry(defer_op, 10, defer_info); + ASSERT_EQ(0, ioctx.operate(queue_name, &defer_op)); + + //Test list queue + list<cls_rgw_gc_obj_info> list_info1, list_info2; + string marker, next_marker; + uint64_t max = 2; + bool expired_only = false, truncated; + cls_rgw_gc_queue_list_entries(ioctx, queue_name, marker, max, expired_only, list_info1, &truncated, next_marker); + ASSERT_EQ(2, list_info1.size()); + + int i = 0; + for (auto it : list_info1) { + string tag = "chain-" + to_string(i); + ASSERT_EQ(tag, it.tag); + i++; + } + + //Test remove entries + num_entries = 2; + cls_rgw_gc_queue_remove_entries(remove_op, num_entries); + ASSERT_EQ(0, ioctx.operate(queue_name, &remove_op)); + + //Test list queue again + cls_rgw_gc_queue_list_entries(ioctx, queue_name, marker, max, expired_only, list_info2, &truncated, next_marker); + ASSERT_EQ(0, list_info2.size()); + +} +#endif // defer_gc() disabled + +TEST(cls_rgw_gc, gc_queue_ops5) +{ + //Testing remove queue entries + string queue_name = "my-fifth-queue"; + uint64_t queue_size = 501, num_urgent_data_entries = 10; + librados::ObjectWriteOperation op; + op.create(true); + cls_rgw_gc_queue_init(op, queue_size, num_urgent_data_entries); + ASSERT_EQ(0, ioctx.operate(queue_name, &op)); + + uint64_t size = 0; + int ret = cls_rgw_gc_queue_get_capacity(ioctx, queue_name, size); + ASSERT_EQ(0, ret); + ASSERT_EQ(size, queue_size); + + //Test enqueue + for (int i = 0; i < 3; i++) { + string tag = "chain-" + to_string(i); + librados::ObjectWriteOperation op; + cls_rgw_gc_obj_info info; + + cls_rgw_obj obj1, obj2; + create_obj(obj1, i, 1); + create_obj(obj2, i, 2); + info.chain.objs.push_back(obj1); + info.chain.objs.push_back(obj2); + + info.tag = tag; + if (i == 2) { + cls_rgw_gc_queue_enqueue(op, 300, info); + } else { + cls_rgw_gc_queue_enqueue(op, 0, info); + } + ASSERT_EQ(0, ioctx.operate(queue_name, &op)); + } + //Test list queue for expired entries only + list<cls_rgw_gc_obj_info> list_info1, list_info2; + string marker, next_marker, marker1; + uint64_t max = 10; + bool expired_only = true, truncated; + cls_rgw_gc_queue_list_entries(ioctx, queue_name, marker, max, expired_only, list_info1, &truncated, next_marker); + ASSERT_EQ(2, list_info1.size()); + + int i = 0; + for (auto it : list_info1) { + string tag = "chain-" + to_string(i); + ASSERT_EQ(tag, it.tag); + i++; + } + + //Test remove entries + librados::ObjectWriteOperation remove_op; + auto num_entries = list_info1.size(); + cls_rgw_gc_queue_remove_entries(remove_op, num_entries); + ASSERT_EQ(0, ioctx.operate(queue_name, &remove_op)); + + //Test list queue again for all entries + expired_only = false; + cls_rgw_gc_queue_list_entries(ioctx, queue_name, marker, max, expired_only, list_info2, &truncated, next_marker); + ASSERT_EQ(1, list_info2.size()); + +} + +TEST(cls_rgw_gc, gc_queue_ops6) +{ + //Testing list queue, when data size is split at the end of the queue + string queue_name = "my-sixth-queue"; + uint64_t queue_size = 341, num_urgent_data_entries = 10; + librados::ObjectWriteOperation op; + op.create(true); + cls_rgw_gc_queue_init(op, queue_size, num_urgent_data_entries); + ASSERT_EQ(0, ioctx.operate(queue_name, &op)); + + uint64_t size = 0; + int ret = cls_rgw_gc_queue_get_capacity(ioctx, queue_name, size); + ASSERT_EQ(0, ret); + ASSERT_EQ(size, queue_size); + + //Test enqueue + for (int i = 0; i < 2; i++) { + string tag = "chain-" + to_string(i); + librados::ObjectWriteOperation op; + cls_rgw_gc_obj_info info; + + cls_rgw_obj obj1, obj2; + create_obj(obj1, i, 1); + create_obj(obj2, i, 2); + info.chain.objs.push_back(obj1); + info.chain.objs.push_back(obj2); + + info.tag = tag; + cls_rgw_gc_queue_enqueue(op, 0, info); + + ASSERT_EQ(0, ioctx.operate(queue_name, &op)); + } + + //Remove one element from queue + librados::ObjectWriteOperation remove_op; + string marker1; + uint64_t num_entries = 1; + + cls_rgw_gc_queue_remove_entries(remove_op, num_entries); + ASSERT_EQ(0, ioctx.operate(queue_name, &remove_op)); + + //Enqueue one more element + librados::ObjectWriteOperation enq_op; + cls_rgw_gc_obj_info info; + + cls_rgw_obj obj1, obj2; + create_obj(obj1, 2, 1); + create_obj(obj2, 2, 2); + info.chain.objs.push_back(obj1); + info.chain.objs.push_back(obj2); + + info.tag = "chain-2"; + cls_rgw_gc_queue_enqueue(enq_op, 0, info); + + ASSERT_EQ(0, ioctx.operate(queue_name, &enq_op)); + + //Test list queue + list<cls_rgw_gc_obj_info> list_info1, list_info2, list_info3; + string marker, next_marker; + uint64_t max = 2; + bool expired_only = false, truncated; + cls_rgw_gc_queue_list_entries(ioctx, queue_name, marker, max, expired_only, list_info1, &truncated, next_marker); + ASSERT_EQ(2, list_info1.size()); + + int i = 1; + for (auto it : list_info1) { + string tag = "chain-" + to_string(i); + ASSERT_EQ(tag, it.tag); + i++; + } +} + +TEST(cls_rgw_gc, gc_queue_ops7) +{ + //Testing list queue, when data size is written at the end of queue and data is written after wrap around + string queue_name = "my-seventh-queue"; + uint64_t queue_size = 342, num_urgent_data_entries = 10; + librados::ObjectWriteOperation op; + op.create(true); + cls_rgw_gc_queue_init(op, queue_size, num_urgent_data_entries); + ASSERT_EQ(0, ioctx.operate(queue_name, &op)); + + uint64_t size = 0; + int ret = cls_rgw_gc_queue_get_capacity(ioctx, queue_name, size); + ASSERT_EQ(0, ret); + ASSERT_EQ(size, queue_size); + + //Test enqueue + for (int i = 0; i < 2; i++) { + string tag = "chain-" + to_string(i); + librados::ObjectWriteOperation op; + cls_rgw_gc_obj_info info; + + cls_rgw_obj obj1, obj2; + create_obj(obj1, i, 1); + create_obj(obj2, i, 2); + info.chain.objs.push_back(obj1); + info.chain.objs.push_back(obj2); + + info.tag = tag; + cls_rgw_gc_queue_enqueue(op, 0, info); + + ASSERT_EQ(0, ioctx.operate(queue_name, &op)); + } + + //Remove one element from queue + librados::ObjectWriteOperation remove_op; + string marker1; + uint64_t num_entries = 1; + + cls_rgw_gc_queue_remove_entries(remove_op, num_entries); + ASSERT_EQ(0, ioctx.operate(queue_name, &remove_op)); + + //Enqueue one more element + librados::ObjectWriteOperation enq_op; + cls_rgw_gc_obj_info info; + + cls_rgw_obj obj1, obj2; + create_obj(obj1, 2, 1); + create_obj(obj2, 2, 2); + info.chain.objs.push_back(obj1); + info.chain.objs.push_back(obj2); + + info.tag = "chain-2"; + cls_rgw_gc_queue_enqueue(enq_op, 0, info); + + ASSERT_EQ(0, ioctx.operate(queue_name, &enq_op)); + + //Test list queue + list<cls_rgw_gc_obj_info> list_info1, list_info2, list_info3; + string marker, next_marker; + uint64_t max = 2; + bool expired_only = false, truncated; + cls_rgw_gc_queue_list_entries(ioctx, queue_name, marker, max, expired_only, list_info1, &truncated, next_marker); + ASSERT_EQ(2, list_info1.size()); + + int i = 1; + for (auto it : list_info1) { + string tag = "chain-" + to_string(i); + ASSERT_EQ(tag, it.tag); + i++; + } +} + +TEST(cls_rgw_gc, gc_queue_ops8) +{ + //Testing list queue, when data is split at the end of the queue + string queue_name = "my-eighth-queue"; + uint64_t queue_size = 344, num_urgent_data_entries = 10; + librados::ObjectWriteOperation op; + op.create(true); + cls_rgw_gc_queue_init(op, queue_size, num_urgent_data_entries); + ASSERT_EQ(0, ioctx.operate(queue_name, &op)); + + uint64_t size = 0; + int ret = cls_rgw_gc_queue_get_capacity(ioctx, queue_name, size); + ASSERT_EQ(0, ret); + ASSERT_EQ(size, queue_size); + + //Test enqueue + for (int i = 0; i < 2; i++) { + string tag = "chain-" + to_string(i); + librados::ObjectWriteOperation op; + cls_rgw_gc_obj_info info; + + cls_rgw_obj obj1, obj2; + create_obj(obj1, i, 1); + create_obj(obj2, i, 2); + info.chain.objs.push_back(obj1); + info.chain.objs.push_back(obj2); + + info.tag = tag; + cls_rgw_gc_queue_enqueue(op, 0, info); + + ASSERT_EQ(0, ioctx.operate(queue_name, &op)); + } + + //Remove one element from queue + librados::ObjectWriteOperation remove_op; + string marker1; + uint64_t num_entries = 1; + + cls_rgw_gc_queue_remove_entries(remove_op, num_entries); + ASSERT_EQ(0, ioctx.operate(queue_name, &remove_op)); + + //Enqueue one more element + librados::ObjectWriteOperation enq_op; + cls_rgw_gc_obj_info info; + + cls_rgw_obj obj1, obj2; + create_obj(obj1, 2, 1); + create_obj(obj2, 2, 2); + info.chain.objs.push_back(obj1); + info.chain.objs.push_back(obj2); + + info.tag = "chain-2"; + cls_rgw_gc_queue_enqueue(enq_op, 0, info); + + ASSERT_EQ(0, ioctx.operate(queue_name, &enq_op)); + + //Test list queue + list<cls_rgw_gc_obj_info> list_info1, list_info2, list_info3; + string marker, next_marker; + uint64_t max = 2; + bool expired_only = false, truncated; + cls_rgw_gc_queue_list_entries(ioctx, queue_name, marker, max, expired_only, list_info1, &truncated, next_marker); + ASSERT_EQ(2, list_info1.size()); + + int i = 1; + for (auto it : list_info1) { + string tag = "chain-" + to_string(i); + ASSERT_EQ(tag, it.tag); + i++; + } +} + +TEST(cls_rgw_gc, gc_queue_ops9) +{ + //Testing remove queue entries + string queue_name = "my-ninth-queue"; + uint64_t queue_size = 668, num_urgent_data_entries = 1; + librados::ObjectWriteOperation op; + op.create(true); + cls_rgw_gc_queue_init(op, queue_size, num_urgent_data_entries); + ASSERT_EQ(0, ioctx.operate(queue_name, &op)); + + uint64_t size = 0; + int ret = cls_rgw_gc_queue_get_capacity(ioctx, queue_name, size); + ASSERT_EQ(0, ret); + ASSERT_EQ(size, queue_size); + + cls_rgw_gc_obj_info defer_info1, defer_info2; + + //Test enqueue + for (int i = 0; i < 2; i++) { + string tag = "chain-" + to_string(i); + librados::ObjectWriteOperation op; + cls_rgw_gc_obj_info info; + + cls_rgw_obj obj1, obj2; + create_obj(obj1, i, 1); + create_obj(obj2, i, 2); + info.chain.objs.push_back(obj1); + info.chain.objs.push_back(obj2); + + info.tag = tag; + cls_rgw_gc_queue_enqueue(op, 5, info); + ASSERT_EQ(0, ioctx.operate(queue_name, &op)); + if (i == 0) { + defer_info1 = info; + } + if (i == 1) { + defer_info2 = info; + } + } + + //Test defer entry for last element + librados::ObjectWriteOperation defer_op; + cls_rgw_gc_queue_defer_entry(defer_op, 10, defer_info2); + ASSERT_EQ(0, ioctx.operate(queue_name, &defer_op)); + + //Test defer entry for first element + cls_rgw_gc_queue_defer_entry(defer_op, 10, defer_info1); + ASSERT_EQ(-ENOSPC, ioctx.operate(queue_name, &defer_op)); +} + +/* must be last test! */ +TEST(cls_rgw_gc, finalize) +{ + /* remove pool */ + ioctx.close(); + ASSERT_EQ(0, destroy_one_pool_pp(pool_name, rados)); +} |