From: Kefu Chai Date: Mon, 11 Feb 2019 14:02:02 +0000 (+0800) Subject: test/crimson: always use "async" for alien msgr X-Git-Tag: v14.1.0~124^2~4 X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=c0bca9c296aa7537e453396138d23214ea191abe;p=ceph.git test/crimson: always use "async" for alien msgr avoid reading from conf as it is not populated yet without calling `ceph::common::sharded_conf().start()` first. Signed-off-by: Kefu Chai --- diff --git a/src/test/crimson/test_alien_echo.cc b/src/test/crimson/test_alien_echo.cc index 74b6a9af7061..ad91f74078a3 100644 --- a/src/test/crimson/test_alien_echo.cc +++ b/src/test/crimson/test_alien_echo.cc @@ -106,7 +106,7 @@ struct Server { Server(CephContext* cct, const entity_inst_t& entity) : dispatcher(cct) { - msgr.reset(Messenger::create(cct, cct->_conf.get_val("ms_type"), + msgr.reset(Messenger::create(cct, "async", entity.name, "pong", entity.addr.get_nonce(), 0)); msgr->set_cluster_protocol(CEPH_OSD_PROTOCOL); msgr->set_default_policy(Messenger::Policy::stateless_server(0)); @@ -161,7 +161,7 @@ struct Client { Client(CephContext *cct) : dispatcher(cct) { - msgr.reset(Messenger::create(cct, cct->_conf.get_val("ms_type"), + msgr.reset(Messenger::create(cct, "async", entity_name_t::CLIENT(-1), "ping", getpid(), 0)); msgr->set_cluster_protocol(CEPH_OSD_PROTOCOL);