seastar_test_suite_t::seastar_env.run([] {
return crimson::common::sharded_conf().start(
- EntityName{}, string_view{"ceph"}
+ EntityName{}, std::string_view{"ceph"}
).then([] {
return crimson::common::sharded_perf_coll().start();
});
msgr->set_require_authorizer(false);
}
DummyAuthClientServer dummy_auth;
- unique_ptr<Messenger> msgr;
+ std::unique_ptr<Messenger> msgr;
struct ServerDispatcher : Dispatcher {
std::mutex mutex;
std::condition_variable on_reply;
};
struct Client {
- unique_ptr<Messenger> msgr;
+ std::unique_ptr<Messenger> msgr;
Client(CephContext *cct)
: dummy_auth(cct), dispatcher(cct)
{
return true;
}
bool ping(Messenger* msgr, const entity_inst_t& peer) {
+ using namespace std::chrono_literals;
auto conn = msgr->connect_to(peer.name.type(),
entity_addrvec_t{peer.addr});
replied = false;
#include "common/config_obs.h"
#include "crimson/common/config_proxy.h"
+using namespace std::literals;
using Config = crimson::common::ConfigProxy;
const std::string test_uint_option = "osd_max_pgls";
const uint64_t INVALID_VALUE = (uint64_t)(-1);
static seastar::future<> test_config()
{
- return crimson::common::sharded_conf().start(EntityName{}, string_view{"ceph"}).then([] {
+ return crimson::common::sharded_conf().start(EntityName{}, "ceph"sv).then([] {
std::vector<const char*> args;
std::string cluster;
std::string conf_file_list;
#include "test_cmds.h"
+using namespace std::chrono_literals;
namespace bpo = boost::program_options;
using crimson::common::local_conf;
}
+using namespace std::literals;
+
static seastar::future<> test_monc()
{
- return crimson::common::sharded_conf().start(EntityName{}, string_view{"ceph"}).then([] {
+ return crimson::common::sharded_conf().start(EntityName{}, "ceph"sv).then([] {
std::vector<const char*> args;
std::string cluster;
std::string conf_file_list;
namespace {
+using namespace std::chrono_literals;
+
using seastar::engine;
using seastar::future;
using crimson::net::error;