From: Yingxin Cheng Date: Fri, 15 Feb 2019 07:27:04 +0000 (+0800) Subject: crimson/net: use entity_addrvec_t::front() inside messenger X-Git-Tag: v15.1.0~3027^2~26 X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=e8ef8f2ce1306c4151f4fad79ebcd953d6118e73;p=ceph-ci.git crimson/net: use entity_addrvec_t::front() inside messenger Do not expect legacy-addr in order to bind v2 address. Signed-off-by: Yingxin Cheng --- diff --git a/src/crimson/net/SocketMessenger.cc b/src/crimson/net/SocketMessenger.cc index e0a89f927e4..5de019a7010 100644 --- a/src/crimson/net/SocketMessenger.cc +++ b/src/crimson/net/SocketMessenger.cc @@ -54,12 +54,12 @@ seastar::future<> SocketMessenger::set_myaddrs(const entity_addrvec_t& addrs) seastar::future<> SocketMessenger::bind(const entity_addrvec_t& addrs) { - ceph_assert(addrs.legacy_addr().get_family() == AF_INET); + ceph_assert(addrs.front().get_family() == AF_INET); auto my_addrs = addrs; for (auto& addr : my_addrs.v) { addr.nonce = nonce; } - logger().info("listening on {}", my_addrs.legacy_addr().in4_addr()); + logger().info("listening on {}", my_addrs.front().in4_addr()); return container().invoke_on_all([my_addrs](auto& msgr) { msgr.do_bind(my_addrs); }); @@ -69,7 +69,7 @@ seastar::future<> SocketMessenger::try_bind(const entity_addrvec_t& addrs, uint32_t min_port, uint32_t max_port) { - auto addr = addrs.legacy_or_front_addr(); + auto addr = addrs.front(); if (addr.get_port() != 0) { return bind(addrs); } @@ -133,7 +133,7 @@ void SocketMessenger::do_bind(const entity_addrvec_t& addrs) Messenger::set_myaddrs(addrs); // TODO: v2: listen on multiple addresses - seastar::socket_address address(addrs.legacy_addr().in4_addr()); + seastar::socket_address address(addrs.front().in4_addr()); seastar::listen_options lo; lo.reuse_address = true; listener = seastar::listen(address, lo);