.then([&client] (ceph::net::Messenger *messenger) {
client.msgr = messenger;
client.msgr->set_default_policy(ceph::net::SocketPolicy::lossy_client(0));
+ client.msgr->set_require_authorizer(false);
client.msgr->set_auth_client(&client.dummy_auth);
client.msgr->set_auth_server(&client.dummy_auth);
return client.msgr->start(&client);
server.msgr.set_default_policy(ceph::net::SocketPolicy::stateless_server(0));
server.msgr.set_policy_throttler(entity_name_t::TYPE_OSD,
&server.byte_throttler);
+ client.msgr->set_require_authorizer(false);
server.msgr.set_auth_client(&server.dummy_auth);
server.msgr.set_auth_server(&server.dummy_auth);
return server.msgr.bind(entity_addrvec_t{addr})
client.msgr.set_default_policy(ceph::net::SocketPolicy::lossy_client(0));
client.msgr.set_policy_throttler(entity_name_t::TYPE_OSD,
&client.byte_throttler);
+ client.msgr->set_require_authorizer(false);
client.msgr.set_auth_client(&client.dummy_auth);
client.msgr.set_auth_server(&client.dummy_auth);
return client.msgr.start(&client.dispatcher)
return container().invoke_on_all([messenger](auto& server) {
server.msgr = messenger->get_local_shard();
server.msgr->set_default_policy(ceph::net::SocketPolicy::stateless_server(0));
+ server.msgr->set_require_authorizer(false);
server.msgr->set_auth_client(&server.dummy_auth);
server.msgr->set_auth_server(&server.dummy_auth);
}).then([messenger, addr] {
if (conf->ms_crc_header) {
msgr->set_crc_header();
}
+ msgr->set_require_authorizer(false);
return seastar::do_with(MonClient{*msgr, dummy_handler},
[msgr](auto& monc) {
return msgr->start(&monc).then([&monc] {