}
}
+static void configure_crc_handling(crimson::net::Messenger& msgr)
+{
+ if (local_conf()->ms_crc_data) {
+ msgr.set_crc_data();
+ }
+ if (local_conf()->ms_crc_header) {
+ msgr.set_crc_header();
+ }
+}
+
seastar::future<> fetch_config()
{
// i don't have any client before joining the cluster, so no need to have
auto msgr = crimson::net::Messenger::create(entity_name_t::CLIENT(),
"temp_mon_client",
get_nonce());
+ configure_crc_handling(*msgr);
auto monc = std::make_unique<crimson::mon::Client>(*msgr, *auth_handler);
msgr->set_auth_client(monc.get());
return msgr->start({monc.get()}).then([monc=monc.get()] {
make_pair(std::ref(hb_back_msgr), "hb_back"s)}) {
msgr = crimson::net::Messenger::create(entity_name_t::OSD(whoami), name,
nonce);
- if (local_conf()->ms_crc_data) {
- msgr->set_crc_data();
- }
- if (local_conf()->ms_crc_header) {
- msgr->set_crc_header();
- }
+ configure_crc_handling(*msgr);
}
osd.start_single(whoami, nonce,
cluster_msgr, client_msgr,