Method prepare_command

src/mon/MgrMonitor.cc:1168–1423

}

bool MgrMonitor::prepare_command(MonOpRequestRef op)
{
  auto m = op->get_req<MMonCommand>();

  std::stringstream ss;
  bufferlist rdata;

  cmdmap_t cmdmap;
  if (!cmdmap_from_json(m->cmd, &cmdmap, ss)) {
    string rs = ss.str();
    mon.reply_command(op, -EINVAL, rs, rdata, get_last_committed());
    return true;
  }

  MonSession *session = op->get_session();
  if (!session) {
    mon.reply_command(op, -EACCES, "access denied", rdata, get_last_committed());
    return true;
  }

  string format = cmd_getval_or<string>(cmdmap, "format", "plain");
  boost::scoped_ptr<Formatter> f(Formatter::create(format));

  const auto prefix = cmd_getval_or<string>(cmdmap, "prefix", string{});
  int r = 0;
  bool plugged = false;

  if (prefix == "mgr set") {
    std::string var;
    if (!cmd_getval(cmdmap, "var", var) || var.empty()) {
      ss << "Invalid variable";
      return -EINVAL;
    }
    string val;
    if (!cmd_getval(cmdmap, "val", val)) {
      return -EINVAL;
    }

    if (var == "down") {
      bool enable_down = false;
      int r = parse_bool(val, &enable_down, ss);
      if (r != 0) {
        return r;
      }
      if (enable_down) {
        bool has_active = !!pending_map.active_gid;
        if (has_active && !mon.osdmon()->is_writeable()) {
          mon.osdmon()->wait_for_writeable(op, new C_RetryMessage(this, op));
          return false;
        }
        pending_map.flags |= MgrMap::FLAG_DOWN;
        if (has_active) {
          plugged |= drop_active();
        }
      } else {
        pending_map.flags &= ~(MgrMap::FLAG_DOWN);
        if (pending_map.active_gid == 0) {
          promote_standby();