From e6918187568dbd01842d8d1d2c808ce16a894239 Mon Sep 17 00:00:00 2001 From: Daniel Baumann Date: Sun, 21 Apr 2024 13:54:28 +0200 Subject: Adding upstream version 18.2.2. Signed-off-by: Daniel Baumann --- src/test/erasure-code/TestErasureCodePlugin.cc | 131 +++++++++++++++++++++++++ 1 file changed, 131 insertions(+) create mode 100644 src/test/erasure-code/TestErasureCodePlugin.cc (limited to 'src/test/erasure-code/TestErasureCodePlugin.cc') diff --git a/src/test/erasure-code/TestErasureCodePlugin.cc b/src/test/erasure-code/TestErasureCodePlugin.cc new file mode 100644 index 000000000..e396d9467 --- /dev/null +++ b/src/test/erasure-code/TestErasureCodePlugin.cc @@ -0,0 +1,131 @@ +// -*- 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) 2013,2014 Cloudwatt + * Copyright (C) 2014 Red Hat + * + * Author: Loic Dachary + * + * 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 "common/Thread.h" +#include "erasure-code/ErasureCodePlugin.h" +#include "global/global_context.h" +#include "common/config_proxy.h" +#include "gtest/gtest.h" + +using namespace std; + +class ErasureCodePluginRegistryTest : public ::testing::Test {}; + +TEST_F(ErasureCodePluginRegistryTest, factory_mutex) { + ErasureCodePluginRegistry &instance = ErasureCodePluginRegistry::instance(); + + { + unique_lock l{instance.lock, std::try_to_lock}; + EXPECT_TRUE(l.owns_lock()); + } + // + // Test that the loading of a plugin is protected by a mutex. + + std::thread sleep_for_10_secs([] { + ErasureCodeProfile profile; + ErasureCodePluginRegistry &instance = ErasureCodePluginRegistry::instance(); + ErasureCodeInterfaceRef erasure_code; + instance.factory("hangs", + g_conf().get_val("erasure_code_dir"), + profile, &erasure_code, &cerr); + }); + auto wait_until = [&instance](bool loading, unsigned max_secs) { + auto delay = 0ms; + const auto DELAY_MAX = std::chrono::seconds(max_secs); + for (; delay < DELAY_MAX; delay = (delay + 1ms) * 2) { + cout << "Trying (1) with delay " << delay << "us\n"; + if (delay.count() > 0) { + std::this_thread::sleep_for(delay); + } + if (instance.loading == loading) { + return true; + } + } + return false; + }; + // should be loading in 5 seconds + ASSERT_TRUE(wait_until(true, 5)); + { + unique_lock l{instance.lock, std::try_to_lock}; + EXPECT_TRUE(!l.owns_lock()); + } + // should finish loading in 15 seconds + ASSERT_TRUE(wait_until(false, 15)); + { + unique_lock l{instance.lock, std::try_to_lock}; + EXPECT_TRUE(l.owns_lock()); + } + sleep_for_10_secs.join(); +} + +TEST_F(ErasureCodePluginRegistryTest, all) +{ + ErasureCodeProfile profile; + string directory = g_conf().get_val("erasure_code_dir"); + ErasureCodeInterfaceRef erasure_code; + ErasureCodePluginRegistry &instance = ErasureCodePluginRegistry::instance(); + EXPECT_FALSE(erasure_code); + EXPECT_EQ(-EIO, instance.factory("invalid", + g_conf().get_val("erasure_code_dir"), + profile, &erasure_code, &cerr)); + EXPECT_FALSE(erasure_code); + EXPECT_EQ(-EXDEV, instance.factory("missing_version", + g_conf().get_val("erasure_code_dir"), + profile, + &erasure_code, &cerr)); + EXPECT_FALSE(erasure_code); + EXPECT_EQ(-ENOENT, instance.factory("missing_entry_point", + g_conf().get_val("erasure_code_dir"), + profile, + &erasure_code, &cerr)); + EXPECT_FALSE(erasure_code); + EXPECT_EQ(-ESRCH, instance.factory("fail_to_initialize", + g_conf().get_val("erasure_code_dir"), + profile, + &erasure_code, &cerr)); + EXPECT_FALSE(erasure_code); + EXPECT_EQ(-EBADF, instance.factory("fail_to_register", + g_conf().get_val("erasure_code_dir"), + profile, + &erasure_code, &cerr)); + EXPECT_FALSE(erasure_code); + EXPECT_EQ(0, instance.factory("example", + g_conf().get_val("erasure_code_dir"), + profile, &erasure_code, &cerr)); + EXPECT_TRUE(erasure_code.get()); + ErasureCodePlugin *plugin = 0; + { + std::lock_guard l{instance.lock}; + EXPECT_EQ(-EEXIST, instance.load("example", directory, &plugin, &cerr)); + EXPECT_EQ(-ENOENT, instance.remove("does not exist")); + EXPECT_EQ(0, instance.remove("example")); + EXPECT_EQ(0, instance.load("example", directory, &plugin, &cerr)); + } +} + +/* + * Local Variables: + * compile-command: "cd ../../../build ; make -j4 && + * make unittest_erasure_code_plugin && + * valgrind --tool=memcheck \ + * ./bin/unittest_erasure_code_plugin \ + * --gtest_filter=*.* --log-to-stderr=true --debug-osd=20" + * End: + */ -- cgit v1.2.3