Method preprocess_command

src/mon/MgrMonitor.cc:965–1166

}

bool MgrMonitor::preprocess_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));

  string prefix;
  cmd_getval(cmdmap, "prefix", prefix);
  int r = 0;

  if (prefix == "mgr stat") {
    if (!f) {
      f.reset(Formatter::create(format, "json-pretty", "json-pretty"));
    }
    f->open_object_section("stat");
    f->dump_unsigned("epoch", map.get_epoch());
    f->dump_bool("available", map.get_available());
    f->dump_string("active_name", map.get_active_name());
    f->dump_unsigned("num_standby", map.get_num_standby());
    f->close_section();
    f->flush(rdata);
  } else if (prefix == "mgr dump") {
    if (!f) {
      f.reset(Formatter::create(format, "json-pretty", "json-pretty"));
    }
    int64_t epoch = cmd_getval_or<int64_t>(cmdmap, "epoch", map.get_epoch());
    if (epoch == (int64_t)map.get_epoch()) {
      f->dump_object("mgrmap", map);
    } else {
      bufferlist bl;
      int err = get_version(epoch, bl);
      if (err == -ENOENT) {
	r = -ENOENT;
	ss << "there is no map for epoch " << epoch;
	goto reply;
      }
      MgrMap m;
      auto p = bl.cbegin();
      m.decode(p);
      f->dump_object("mgrmap", m);
    }