Method get_perf_schema_python

src/mgr/ActivePyModules.cc:1143–1311

}

PyObject* ActivePyModules::get_perf_schema_python(
    const std::string& svc_type,
    const std::string& svc_id)
{
  without_gil_t no_gil;
  std::lock_guard l(lock);

  DaemonStateCollection daemons;

  if (svc_type == "") {
    daemons = daemon_state.get_all();
  } else if (svc_id.empty()) {
    daemons = daemon_state.get_by_service(svc_type);
  } else {
    auto key = DaemonKey{svc_type, svc_id};
    // so that the below can be a loop in all cases
    auto got = daemon_state.get(key);
    if (got != nullptr) {
      daemons[key] = got;
    }
  }

  auto f = with_gil(no_gil, [&] { return PyFormatter(); });

  auto dump_sub_counter_information = [](PyFormatter *f, PerfCounterType type) {
    // Labels can also have "." in them, eg (notice, client.4620):
    // "mds_client_metrics-cephfs^@client^@client.4620^@rank^@0^@.avg_metadata_latency"
    // Hence search for the last occurence of "." to get sub counter name
    size_t pos = type.path.rfind('.');
    std::string sub_counter_name = type.path.substr(pos + 1, type.path.length());
    Formatter::ObjectSection counter_section(*f, sub_counter_name);
    f->create_unique("description", type.description);
    if (!type.nick.empty()) {
      f->dump_string("nick", type.nick);
    }
    f->dump_unsigned("type", type.type);
    f->dump_unsigned("priority", type.priority);
    f->dump_unsigned("units", type.unit);
  };

  auto dump_counter_with_labels = [&dump_sub_counter_information](
				      PyFormatter *f, auto key_labels,
				      auto type) {
    f->open_object_section("");	 // counter should be enclosed by array

    for (Formatter::ObjectSection labels_section{*f, "labels"};
	 const auto &label : key_labels) {
      f->dump_string(label.first, label.second);
    }

    f->open_object_section("counters");
    dump_sub_counter_information(f, type);
  };


  if (!daemons.empty()) {
    for (auto &[key, state] : daemons) {
      std::lock_guard l(state->lock);