Code Review / stor4nfv.git / blobdiff
? search:
summary | shortlog | log | commit | commitdiff | review | tree
raw | inline | side by side
remove ceph code
[stor4nfv.git] / src / ceph / src / test / cls_hello / test_cls_hello.cc
diff --git a/src/ceph/src/test/cls_hello/test_cls_hello.cc b/src/ceph/src/test/cls_hello/test_cls_hello.cc
deleted file mode 100644 (file)
index efd9fc7..0000000
--- a/src/ceph/src/test/cls_hello/test_cls_hello.cc
+++ /dev/null
@@ -1,185 +0,0 @@
-// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
-// vim: ts=8 sw=2 smarttab
-/*
- * Ceph - scalable distributed file system
- *
- * Copyright (C) 2013 Inktank
- *
- * 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.
- *
- */
-
-#include <iostream>
-#include <errno.h>
-
-#include "include/rados/librados.hpp"
-#include "include/encoding.h"
-#include "test/librados/test.h"
-#include "gtest/gtest.h"
-
-using namespace librados;
-
-TEST(ClsHello, SayHello) {
-  Rados cluster;
-  std::string pool_name = get_temp_pool_name();
-  ASSERT_EQ("", create_one_pool_pp(pool_name, cluster));
-  IoCtx ioctx;
-  cluster.ioctx_create(pool_name.c_str(), ioctx);
-
-  bufferlist in, out;
-  ASSERT_EQ(-ENOENT, ioctx.exec("myobject", "hello", "say_hello", in, out));
-  ASSERT_EQ(0, ioctx.write_full("myobject", in));
-  ASSERT_EQ(0, ioctx.exec("myobject", "hello", "say_hello", in, out));
-  ASSERT_EQ(std::string("Hello, world!"), std::string(out.c_str(), out.length()));
-
-  out.clear();
-  in.append("Tester");
-  ASSERT_EQ(0, ioctx.exec("myobject", "hello", "say_hello", in, out));
-  ASSERT_EQ(std::string("Hello, Tester!"), std::string(out.c_str(), out.length()));
-
-  out.clear();
-  in.clear();
-  char buf[4096];
-  memset(buf, 1, sizeof(buf));
-  in.append(buf, sizeof(buf));
-  ASSERT_EQ(-EINVAL, ioctx.exec("myobject", "hello", "say_hello", in, out));
-
-  ASSERT_EQ(0, destroy_one_pool_pp(pool_name, cluster));
-}
-
-TEST(ClsHello, RecordHello) {
-  Rados cluster;
-  std::string pool_name = get_temp_pool_name();
-  ASSERT_EQ("", create_one_pool_pp(pool_name, cluster));
-  IoCtx ioctx;
-  cluster.ioctx_create(pool_name.c_str(), ioctx);
-
-  bufferlist in, out;
-  ASSERT_EQ(0, ioctx.exec("myobject", "hello", "record_hello", in, out));
-  ASSERT_EQ(-EEXIST, ioctx.exec("myobject", "hello", "record_hello", in, out));
-
-  in.append("Tester");
-  ASSERT_EQ(0, ioctx.exec("myobject2", "hello", "record_hello", in, out));
-  ASSERT_EQ(-EEXIST, ioctx.exec("myobject2", "hello", "record_hello", in, out));
-  ASSERT_EQ(0u, out.length());
-
-  in.clear();
-  out.clear();
-  ASSERT_EQ(0, ioctx.exec("myobject", "hello", "replay", in, out));
-  ASSERT_EQ(std::string("Hello, world!"), std::string(out.c_str(), out.length()));
-  out.clear();
-  ASSERT_EQ(0, ioctx.exec("myobject2", "hello", "replay", in, out));
-  ASSERT_EQ(std::string("Hello, Tester!"), std::string(out.c_str(), out.length()));
-
-  ASSERT_EQ(0, destroy_one_pool_pp(pool_name, cluster));
-}
-
-TEST(ClsHello, WriteReturnData) {
-  Rados cluster;
-  std::string pool_name = get_temp_pool_name();
-  ASSERT_EQ("", create_one_pool_pp(pool_name, cluster));
-  IoCtx ioctx;
-  cluster.ioctx_create(pool_name.c_str(), ioctx);
-
-  bufferlist in, out;
-  ASSERT_EQ(0, ioctx.exec("myobject", "hello", "writes_dont_return_data", in, out));
-  ASSERT_EQ(std::string(), std::string(out.c_str(), out.length()));
-
-  char buf[4096];
-  memset(buf, 1, sizeof(buf));
-  in.append(buf, sizeof(buf));
-  ASSERT_EQ(-EINVAL, ioctx.exec("myobject2", "hello", "writes_dont_return_data", in, out));
-  ASSERT_EQ(std::string("too much input data!"), std::string(out.c_str(), out.length()));
-  ASSERT_EQ(-ENOENT, ioctx.getxattr("myobject2", "foo", out));
-
-  ASSERT_EQ(0, destroy_one_pool_pp(pool_name, cluster));
-}
-
-TEST(ClsHello, Loud) {
-  Rados cluster;
-  std::string pool_name = get_temp_pool_name();
-  ASSERT_EQ("", create_one_pool_pp(pool_name, cluster));
-  IoCtx ioctx;
-  cluster.ioctx_create(pool_name.c_str(), ioctx);
-
-  bufferlist in, out;
-  ASSERT_EQ(0, ioctx.exec("myobject", "hello", "record_hello", in, out));
-  ASSERT_EQ(0, ioctx.exec("myobject", "hello", "replay", in, out));
-  ASSERT_EQ(std::string("Hello, world!"), std::string(out.c_str(), out.length()));
-
-  ASSERT_EQ(0, ioctx.exec("myobject", "hello", "turn_it_to_11", in, out));
-  ASSERT_EQ(0, ioctx.exec("myobject", "hello", "replay", in, out));
-  ASSERT_EQ(std::string("HELLO, WORLD!"), std::string(out.c_str(), out.length()));
-
-  ASSERT_EQ(0, destroy_one_pool_pp(pool_name, cluster));
-}
-
-TEST(ClsHello, BadMethods) {
-  Rados cluster;
-  std::string pool_name = get_temp_pool_name();
-  ASSERT_EQ("", create_one_pool_pp(pool_name, cluster));
-  IoCtx ioctx;
-  cluster.ioctx_create(pool_name.c_str(), ioctx);
-
-  bufferlist in, out;
-
-  ASSERT_EQ(0, ioctx.write_full("myobject", in));
-  ASSERT_EQ(-EIO, ioctx.exec("myobject", "hello", "bad_reader", in, out));
-  ASSERT_EQ(-EIO, ioctx.exec("myobject", "hello", "bad_writer", in, out));
-
-  ASSERT_EQ(0, destroy_one_pool_pp(pool_name, cluster));
-}
-
-TEST(ClsHello, Filter) {
-  Rados cluster;
-  std::string pool_name = get_temp_pool_name();
-  ASSERT_EQ("", create_one_pool_pp(pool_name, cluster));
-  IoCtx ioctx;
-  cluster.ioctx_create(pool_name.c_str(), ioctx);
-
-  char buf[128];
-  memset(buf, 0xcc, sizeof(buf));
-  bufferlist obj_content;
-  obj_content.append(buf, sizeof(buf));
-
-  std::string target_str = "content";
-
-  // Write xattr bare, no ::encod'ing
-  bufferlist target_val;
-  target_val.append(target_str);
-  bufferlist nontarget_val;
-  nontarget_val.append("rhubarb");
-
-  ASSERT_EQ(0, ioctx.write("has_xattr", obj_content, obj_content.length(), 0));
-  ASSERT_EQ(0, ioctx.write("has_wrong_xattr", obj_content, obj_content.length(), 0));
-  ASSERT_EQ(0, ioctx.write("no_xattr", obj_content, obj_content.length(), 0));
-
-  ASSERT_EQ(0, ioctx.setxattr("has_xattr", "theattr", target_val));
-  ASSERT_EQ(0, ioctx.setxattr("has_wrong_xattr", "theattr", nontarget_val));
-
-  bufferlist filter_bl;
-  std::string filter_name = "hello.hello";
-  ::encode(filter_name, filter_bl);
-  ::encode("_theattr", filter_bl);
-  ::encode(target_str, filter_bl);
-
-  NObjectIterator iter(ioctx.nobjects_begin(filter_bl));
-  bool foundit = false;
-  int k = 0;
-  while (iter != ioctx.nobjects_end()) {
-    foundit = true;
-    // We should only see the object that matches the filter
-    ASSERT_EQ((*iter).get_oid(), "has_xattr");
-    // We should only see it once
-    ASSERT_EQ(k, 0);
-    ++iter;
-    ++k;
-  }
-  ASSERT_TRUE(foundit);
-
-  ASSERT_EQ(0, destroy_one_pool_pp(pool_name, cluster));
-}
-