Method execute_command

src/crimson/admin/admin_socket.cc:182–212

}

auto AdminSocket::execute_command(const std::vector<std::string>& cmd,
				  ceph::bufferlist&& buf)
  -> seastar::future<tell_result_t>
{
  LOG_PREFIX(AdminSocket::execute_command);
  INFO("");
  auto maybe_parsed = parse_cmd(cmd);
  if (auto* parsed = std::get_if<parsed_command_t>(&maybe_parsed); parsed) {
    DEBUG("parsed ok");
    stringstream os;
    string desc{parsed->hook.desc};
    if (!validate_cmd(desc, parsed->params, os)) {
      ERROR("failed to validate '{}': {}", cmd, os.str());
      ceph::bufferlist out;
      out.append(os);
      return seastar::make_ready_future<tell_result_t>(
        tell_result_t{-EINVAL, "invalid command json", std::move(out)});
    }
    DEBUG("validated {} {}", cmd, os.str());
    auto owned = std::move(*parsed);
    return seastar::do_with(std::move(owned), std::move(buf),
                            [](const parsed_command_t& parsed,
                               ceph::bufferlist& buf) mutable {
      return parsed.hook.call(parsed.params, parsed.format, std::move(buf));
    });
  } else {
    DEBUG("failed to parse");
    auto& result = std::get<tell_result_t>(maybe_parsed);
    return seastar::make_ready_future<tell_result_t>(std::move(result));
  }
}

// an input_stream consumer that reads buffer into a std::string up to the first
// '\0' which indicates the end of command