From 97e9a44b16396cb75d8bfe22d52cd80e8293323c Mon Sep 17 00:00:00 2001 From: Radoslaw Zarzynski Date: Fri, 12 Feb 2021 19:18:23 +0000 Subject: [PATCH] crimson: configure CRC for the temp_mon_client's messenger. Signed-off-by: Radoslaw Zarzynski --- src/crimson/osd/main.cc | 18 ++++++++++++------ 1 file changed, 12 insertions(+), 6 deletions(-) diff --git a/src/crimson/osd/main.cc b/src/crimson/osd/main.cc index edc712b2b2134..21654cddd1b7f 100644 --- a/src/crimson/osd/main.cc +++ b/src/crimson/osd/main.cc @@ -118,6 +118,16 @@ uint64_t get_nonce() } } +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 @@ -132,6 +142,7 @@ seastar::future<> fetch_config() auto msgr = crimson::net::Messenger::create(entity_name_t::CLIENT(), "temp_mon_client", get_nonce()); + configure_crc_handling(*msgr); auto monc = std::make_unique(*msgr, *auth_handler); msgr->set_auth_client(monc.get()); return msgr->start({monc.get()}).then([monc=monc.get()] { @@ -221,12 +232,7 @@ int main(int argc, char* argv[]) 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, -- 2.39.5