From f8a0e053fe29844373fca6625a54ddddd34cfb84 Mon Sep 17 00:00:00 2001 From: Sage Weil Date: Thu, 6 Oct 2016 13:44:59 -0400 Subject: [PATCH] unittest_compression: subsume plugin test Signed-off-by: Sage Weil --- src/test/compressor/CMakeLists.txt | 9 --- src/test/compressor/test_compression.cc | 23 ++++++ .../compressor/test_compression_plugin.cc | 73 ------------------- 3 files changed, 23 insertions(+), 82 deletions(-) delete mode 100644 src/test/compressor/test_compression_plugin.cc diff --git a/src/test/compressor/CMakeLists.txt b/src/test/compressor/CMakeLists.txt index 7e73515964026..bf63e7e2eaf4b 100644 --- a/src/test/compressor/CMakeLists.txt +++ b/src/test/compressor/CMakeLists.txt @@ -7,12 +7,3 @@ add_executable(unittest_compression add_ceph_unittest(unittest_compression ${CMAKE_RUNTIME_OUTPUT_DIRECTORY}/unittest_compression) target_link_libraries(unittest_compression global) add_dependencies(unittest_compression ceph_example) - -# unittest_compression_plugin -add_executable(unittest_compression_plugin - test_compression_plugin.cc - ) -add_ceph_unittest(unittest_compression_plugin ${CMAKE_RUNTIME_OUTPUT_DIRECTORY}/unittest_compression_plugin) -target_link_libraries(unittest_compression_plugin global) -add_dependencies(unittest_compression_plugin ceph_example) - diff --git a/src/test/compressor/test_compression.cc b/src/test/compressor/test_compression.cc index 2c81c3f6f61c9..22e35c674159a 100644 --- a/src/test/compressor/test_compression.cc +++ b/src/test/compressor/test_compression.cc @@ -23,6 +23,7 @@ #include "common/ceph_argparse.h" #include "global/global_context.h" #include "common/config.h" +#include "compressor/CompressionPlugin.h" class CompressionTest : public ::testing::Test, public ::testing::WithParamInterface { @@ -356,6 +357,28 @@ TEST(ZlibCompressor, zlib_isal_compatibility) EXPECT_TRUE(exp.contents_equal(after)); } +TEST(CompressionPlugin, all) +{ + const char* env = getenv("CEPH_LIB"); + std::string directory(env ? env : ".libs"); + CompressorRef compressor; + PluginRegistry *reg = g_ceph_context->get_plugin_registry(); + EXPECT_TRUE(reg); + CompressionPlugin *factory = dynamic_cast(reg->get_with_load("compressor", "invalid")); + EXPECT_FALSE(factory); + factory = dynamic_cast(reg->get_with_load("compressor", "example")); + EXPECT_TRUE(factory); + stringstream ss; + EXPECT_EQ(0, factory->factory(&compressor, &ss)); + EXPECT_TRUE(compressor.get()); + { + Mutex::Locker l(reg->lock); + EXPECT_EQ(-ENOENT, reg->remove("compressor", "does not exist")); + EXPECT_EQ(0, reg->remove("compressor", "example")); + EXPECT_EQ(0, reg->load("compressor", "example")); + } +} + int main(int argc, char **argv) { vector args; argv_to_vec(argc, (const char **)argv, args); diff --git a/src/test/compressor/test_compression_plugin.cc b/src/test/compressor/test_compression_plugin.cc deleted file mode 100644 index c45fab8cca90e..0000000000000 --- a/src/test/compressor/test_compression_plugin.cc +++ /dev/null @@ -1,73 +0,0 @@ -// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*- -// vim: ts=8 sw=2 smarttab -/* - * Ceph distributed storage system - * - * Copyright (C) 2015 Mirantis, Inc. - * - * Author: Alyona Kiseleva - * - * This library is free software; you can redistribute it and/or - * modify it under the terms of the GNU Lesser General Public - * License as published by the Free Software Foundation; either - * version 2.1 of the License, or (at your option) any later version. - * - */ - -#include -#include -#include -#include -#include -#include "global/global_init.h" -#include "compressor/CompressionPlugin.h" -#include "common/ceph_argparse.h" -#include "global/global_context.h" -#include "common/config.h" - -TEST(CompressionPlugin, all) -{ - const char* env = getenv("CEPH_LIB"); - std::string directory(env ? env : ".libs"); - CompressorRef compressor; - PluginRegistry *reg = g_ceph_context->get_plugin_registry(); - EXPECT_TRUE(reg); - CompressionPlugin *factory = dynamic_cast(reg->get_with_load("compressor", "invalid")); - EXPECT_FALSE(factory); - factory = dynamic_cast(reg->get_with_load("compressor", "example")); - EXPECT_TRUE(factory); - stringstream ss; - EXPECT_EQ(0, factory->factory(&compressor, &ss)); - EXPECT_TRUE(compressor.get()); - { - Mutex::Locker l(reg->lock); - EXPECT_EQ(-ENOENT, reg->remove("compressor", "does not exist")); - EXPECT_EQ(0, reg->remove("compressor", "example")); - EXPECT_EQ(0, reg->load("compressor", "example")); - } -} - -int main(int argc, char **argv) { - vector args; - argv_to_vec(argc, (const char **)argv, args); - - global_init(NULL, args, CEPH_ENTITY_TYPE_CLIENT, CODE_ENVIRONMENT_UTILITY, 0); - common_init_finish(g_ceph_context); - - const char* env = getenv("CEPH_LIB"); - if (env) - g_conf->set_val("plugin_dir", env, false, false); - - ::testing::InitGoogleTest(&argc, argv); - return RUN_ALL_TESTS(); -} - -/* - * Local Variables: - * compile-command: "cd ../.. ; make -j4 && - * make unittest_compression_plugin && - * valgrind --tool=memcheck \ - * ./unittest_compression_plugin \ - * --gtest_filter=*.* --log-to-stderr=true --debug-osd=20" - * End: - */ -- 2.39.5