diff options
Diffstat (limited to 'src/test/neorados/list_pool.cc')
-rw-r--r-- | src/test/neorados/list_pool.cc | 166 |
1 files changed, 166 insertions, 0 deletions
diff --git a/src/test/neorados/list_pool.cc b/src/test/neorados/list_pool.cc new file mode 100644 index 000000000..ae36c36e6 --- /dev/null +++ b/src/test/neorados/list_pool.cc @@ -0,0 +1,166 @@ +// -*- 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) 2019 Red Hat <contact@redhat.com> + * Author: Adam C. Emerson <aemerson@redhat.com> + * + * 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 <initializer_list> +#include <optional> +#include <thread> +#include <tuple> +#include <string_view> +#include <vector> + +#include <sys/param.h> + +#include <unistd.h> + +#include <boost/system/system_error.hpp> + +#include <fmt/format.h> + +#include "include/neorados/RADOS.hpp" + +#include "include/scope_guard.h" + +#include "common/async/context_pool.h" +#include "common/ceph_time.h" +#include "common/ceph_argparse.h" +#include "common/async/blocked_completion.h" + +#include "global/global_init.h" + +#include "test/neorados/common_tests.h" + + +namespace ba = boost::asio; +namespace bs = boost::system; +namespace ca = ceph::async; +namespace R = neorados; + +std::string_view hostname() { + static char hostname[MAXHOSTNAMELEN] = { 0 }; + static size_t len = 0; + if (!len) { + auto r = gethostname(hostname, sizeof(hostname)); + if (r != 0) { + throw bs::system_error( + errno, bs::system_category()); + } + len = std::strlen(hostname); + } + return {hostname, len}; +} + +std::string temp_pool_name(const std::string_view prefix) +{ + using namespace std::chrono; + static std::uint64_t num = 1; + return fmt::format( + "{}-{}-{}-{}-{}", + prefix, + hostname(), + getpid(), + duration_cast<milliseconds>(ceph::coarse_real_clock::now() + .time_since_epoch()).count(), + num++); +} + +bs::error_code noisy_list(R::RADOS& r, int64_t p) +{ + auto b = R::Cursor::begin(); + auto e = R::Cursor::end(); + + std::cout << "begin = " << b.to_str() << std::endl; + std::cout << "end = " << e.to_str() << std::endl; + try { + auto [v, next] = r.enumerate_objects(p, b, e, 1000, {}, ca::use_blocked, + R::all_nspaces); + + std::cout << "Got " << v.size() << " entries." << std::endl; + std::cout << "next cursor = " << next.to_str() << std::endl; + std::cout << "next == end: " << (next == e) << std::endl; + std::cout << "Returned Objects: "; + std::cout << "["; + auto o = v.cbegin(); + while (o != v.cend()) { + std::cout << *o; + if (++o != v.cend()) + std::cout << " "; + } + std::cout << "]" << std::endl; + } catch (const bs::system_error& e) { + std::cerr << "RADOS::enumerate_objects: " << e.what() << std::endl; + return e.code(); + } + return {}; +} + +bs::error_code create_several(R::RADOS& r, const R::IOContext& i, + std::initializer_list<std::string> l) +{ + for (const auto& o : l) try { + R::WriteOp op; + std::cout << "Creating " << o << std::endl; + ceph::bufferlist bl; + bl.append("My bologna has no name."); + op.write_full(std::move(bl)); + r.execute(o, i, std::move(op), ca::use_blocked); + } catch (const bs::system_error& e) { + std::cerr << "RADOS::execute: " << e.what() << std::endl; + return e.code(); + } + return {}; +} + +int main(int argc, char** argv) +{ + using namespace std::literals; + + auto args = argv_to_vec(argc, argv); + env_to_vec(args); + + auto cct = global_init(NULL, args, CEPH_ENTITY_TYPE_CLIENT, + CODE_ENVIRONMENT_UTILITY, 0); + common_init_finish(cct.get()); + + try { + ca::io_context_pool p(1); + auto r = R::RADOS::make_with_cct(cct.get(), p, ca::use_blocked); + + auto pool_name = get_temp_pool_name("ceph_test_RADOS_list_pool"sv); + r.create_pool(pool_name, std::nullopt, ca::use_blocked); + auto pd = make_scope_guard( + [&pool_name, &r]() { + r.delete_pool(pool_name, ca::use_blocked); + }); + auto pool = r.lookup_pool(pool_name, ca::use_blocked); + R::IOContext i(pool); + + if (noisy_list(r, pool)) { + return 1; + } + if (create_several(r, i, {"meow", "woof", "squeak"})) { + return 1; + } + if (noisy_list(r, pool)) { + return 1; + } + + } catch (const bs::system_error& e) { + std::cerr << "Error: " << e.what() << std::endl; + return 1; + } + + return 0; +} |