remove ceph code
[stor4nfv.git] / src / ceph / src / test / cls_replica_log / test_cls_replica_log.cc
diff --git a/src/ceph/src/test/cls_replica_log/test_cls_replica_log.cc b/src/ceph/src/test/cls_replica_log/test_cls_replica_log.cc
deleted file mode 100644 (file)
index de6146e..0000000
+++ /dev/null
@@ -1,151 +0,0 @@
-/*
- * Ceph - scalable distributed file system
- *
- * This is free software; you can redistribute it and/or
- * modify it under the terms of the GNU Lesser General Public
- * License version 2.1, as published by the Free Software 
- * Foundation.  See file COPYING.
- * Copyright 2013 Inktank
- */
-
-#include "gtest/gtest.h"
-#include "test/librados/test.h"
-
-#include "cls/replica_log/cls_replica_log_client.h"
-#include "cls/replica_log/cls_replica_log_types.h"
-
-class cls_replica_log_Test : public ::testing::Test {
-public:
-  librados::Rados rados;
-  librados::IoCtx ioctx;
-  string pool_name;
-  string oid;
-  string entity;
-  string marker;
-  utime_t time;
-  list<pair<string, utime_t> > entries;
-  cls_replica_log_progress_marker progress;
-
-  void SetUp() override {
-    pool_name = get_temp_pool_name();
-    ASSERT_EQ("", create_one_pool_pp(pool_name, rados));
-    ASSERT_EQ(0, rados.ioctx_create(pool_name.c_str(), ioctx));
-    oid = "obj";
-    ASSERT_EQ(0, ioctx.create(oid, true));
-  }
-
-  void add_marker() {
-    entity = "tester_entity";
-    marker = "tester_marker1";
-    time.set_from_double(10);
-    entries.push_back(make_pair("tester_obj1", time));
-    time.set_from_double(20);
-    cls_replica_log_prepare_marker(progress, entity, marker, time, &entries);
-    librados::ObjectWriteOperation opw;
-    cls_replica_log_update_bound(opw, progress);
-    ASSERT_EQ(0, ioctx.operate(oid, &opw));
-  }
-};
-
-TEST_F(cls_replica_log_Test, test_set_get_marker)
-{
-  add_marker();
-
-  string reply_position_marker;
-  utime_t reply_time;
-  list<cls_replica_log_progress_marker> return_progress_list;
-  ASSERT_EQ(0, cls_replica_log_get_bounds(ioctx, oid, reply_position_marker,
-                                          reply_time, return_progress_list));
-
-  ASSERT_EQ(reply_position_marker, marker);
-  ASSERT_EQ((double)10, (double)reply_time);
-  string response_entity;
-  string response_marker;
-  utime_t response_time;
-  list<pair<string, utime_t> > response_item_list;
-
-  cls_replica_log_extract_marker(return_progress_list.front(),
-                                 response_entity, response_marker,
-                                 response_time, response_item_list);
-  ASSERT_EQ(response_entity, entity);
-  ASSERT_EQ(response_marker, marker);
-  ASSERT_EQ(response_time, time);
-  ASSERT_EQ((unsigned)1, response_item_list.size());
-  ASSERT_EQ("tester_obj1", response_item_list.front().first);
-}
-
-TEST_F(cls_replica_log_Test, test_bad_update)
-{
-  add_marker();
-
-  time.set_from_double(15);
-  cls_replica_log_progress_marker bad_marker;
-  cls_replica_log_prepare_marker(bad_marker, entity, marker, time, &entries);
-  librados::ObjectWriteOperation badw;
-  cls_replica_log_update_bound(badw, bad_marker);
-  ASSERT_EQ(-EINVAL, ioctx.operate(oid, &badw));
-}
-
-TEST_F(cls_replica_log_Test, test_bad_delete)
-{
-  add_marker();
-
-  librados::ObjectWriteOperation badd;
-  cls_replica_log_delete_bound(badd, entity);
-  ASSERT_EQ(-ENOTEMPTY, ioctx.operate(oid, &badd));
-}
-
-TEST_F(cls_replica_log_Test, test_good_delete)
-{
-  add_marker();
-
-  librados::ObjectWriteOperation opc;
-  progress.items.clear();
-  cls_replica_log_update_bound(opc, progress);
-  ASSERT_EQ(0, ioctx.operate(oid, &opc));
-  librados::ObjectWriteOperation opd;
-  cls_replica_log_delete_bound(opd, entity);
-  ASSERT_EQ(0, ioctx.operate(oid, &opd));
-
-  string reply_position_marker;
-  utime_t reply_time;
-  list<cls_replica_log_progress_marker> return_progress_list;
-  ASSERT_EQ(0, cls_replica_log_get_bounds(ioctx, oid, reply_position_marker,
-                                          reply_time, return_progress_list));
-  ASSERT_EQ((unsigned)0, return_progress_list.size());
-}
-
-TEST_F(cls_replica_log_Test, test_bad_get)
-{
-  string reply_position_marker;
-  utime_t reply_time;
-  list<cls_replica_log_progress_marker> return_progress_list;
-  ASSERT_EQ(-ENOENT,
-            cls_replica_log_get_bounds(ioctx, oid, reply_position_marker,
-                                       reply_time, return_progress_list));
-}
-
-TEST_F(cls_replica_log_Test, test_double_delete)
-{
-  add_marker();
-
-  librados::ObjectWriteOperation opc;
-  progress.items.clear();
-  cls_replica_log_update_bound(opc, progress);
-  ASSERT_EQ(0, ioctx.operate(oid, &opc));
-  librados::ObjectWriteOperation opd;
-  cls_replica_log_delete_bound(opd, entity);
-  ASSERT_EQ(0, ioctx.operate(oid, &opd));
-
-  librados::ObjectWriteOperation opd2;
-  cls_replica_log_delete_bound(opd2, entity);
-  ASSERT_EQ(0, ioctx.operate(oid, &opd2));
-
-  string reply_position_marker;
-  utime_t reply_time;
-  list<cls_replica_log_progress_marker> return_progress_list;
-  ASSERT_EQ(0, cls_replica_log_get_bounds(ioctx, oid, reply_position_marker,
-                                          reply_time, return_progress_list));
-  ASSERT_EQ((unsigned)0, return_progress_list.size());
-
-}