Method call

src/msg/async/AsyncMessenger.cc:292–339

    : m_msgrs{{name, &m}} {}

int AsyncMessengerSocketHook::call(
    std::string_view command, const cmdmap_t& cmdmap, const bufferlist&,
    Formatter* f, std::ostream& errss, ceph::buffer::list& out) {
  if (command == "messenger dump") {
    std::string name;
    if (common::cmd_getval(cmdmap, "msgr", name)) {
      if (auto it = m_msgrs.find(name); it != m_msgrs.end()) {
        std::vector<std::string> opts;
        const bool tcp_info =
            common::cmd_getval_or<bool>(cmdmap, "tcp_info", false);
        const bool has_filter =
            common::cmd_getval(cmdmap, "dumpcontents", opts);
        const std::set<std::string> optset(opts.begin(), opts.end());
        const bool all = !has_filter || optset.contains("all");
        const auto filter_fn = [&](const std::string& key) {
          if (key == "tcp_info") {
            return tcp_info;
          } else if (all) {
            return true;
          } else {
            return optset.contains(key);
          }
        };

        const auto msgr = (*it).second;
        f->open_object_section("status");
	f->dump_string("name", name);
        f->open_object_section("messenger");
        msgr->dump(f, filter_fn);
        f->close_section();  // messenger
        f->close_section();  // status
        return 0;
      } else {
        return -ENOENT;
      }
    } else {
      f->open_object_section("status");
      f->open_array_section("messengers");
      for (const auto& [name, _] : m_msgrs) {
        f->dump_string("name", name);
      }
      f->close_section();
      f->close_section();
      return 0;
    }
  }
  return -ENOSYS;
}

bool AsyncMessengerSocketHook::add_messenger(
    const std::string& name, AsyncMessenger& msgr) {