Method parse_cmd

src/crimson/admin/admin_socket.cc:66–129

}

auto AdminSocket::parse_cmd(const std::vector<std::string>& cmd)
  -> std::variant<parsed_command_t, tell_result_t>
{
  LOG_PREFIX(AdminSocket::parse_cmd);
  INFO("");
  // preliminaries:
  //   - create the formatter specified by the cmd parameters
  //   - locate the "op-code" string (the 'prefix' segment)
  //   - prepare for command parameters extraction via cmdmap_t
  cmdmap_t cmdmap;
  ceph::bufferlist out;

  try {
    stringstream errss;
    //  note that cmdmap_from_json() may throw on syntax issues
    if (!cmdmap_from_json(cmd, &cmdmap, errss)) {
      ERROR("incoming command error: {}", errss.str());
      out.append("error:"s);
      out.append(errss.str());
      return tell_result_t{-EINVAL, "invalid json", std::move(out)};
    }
  } catch (const std::runtime_error& e) {
    ERROR("incoming command syntax: {}", cmd);
    out.append(string{e.what()});
    return tell_result_t{-EINVAL, "invalid json", std::move(out)};
  }

  string format;
  string prefix;
  try {
    cmd_getval(cmdmap, "format", format);
    cmd_getval(cmdmap, "prefix", prefix);
    // tolerate old-style pg <pgid> command <args> style formatting
    if (prefix == "pg") {
      std::string pg_subcmd;
      cmd_getval(cmdmap, "cmd", pg_subcmd);
      prefix = pg_subcmd;

      if (auto arg = cmd_getval<std::string>(cmdmap, "arg"); arg) {
        if (pg_subcmd == "list_unfound") {
          cmdmap["offset"] = std::move(*arg);
        } else if (pg_subcmd == "mark_unfound_lost") {
          cmdmap["mulcmd"] = std::move(*arg);
        }
        cmdmap.erase("arg");
      }
    }
  } catch (const bad_cmd_get& e) {
    ERROR("invalid syntax: {}", cmd);
    out.append(string{e.what()});
    return tell_result_t{-EINVAL, "invalid json", std::move(out)};
  }

  // match the incoming op-code to one of the registered APIs
  auto found = hooks.find(prefix);
  if (found == hooks.end()) {
    ERROR("unknown command: {}", prefix);
    return tell_result_t{-EINVAL,