Function server_set_status

src/proxy/HostStatus.cc:481–513

JSON-RPC method to mark up or down a host.

// JSON-RPC method to mark up or down a host.
swoc::Rv<YAML::Node>
server_set_status(std::string_view id, YAML::Node const &params)
{
  Dbg(dbg_ctl_host_statuses, "id=%s", id.data());
  namespace err = rpc::handlers::errors;
  swoc::Rv<YAML::Node> resp;

  try {
    if (!params.IsNull()) {
      auto cmdInfo = params.as<HostCmdInfo>();

      for (auto const &name : cmdInfo.hosts) {
        HostStatus &hs       = HostStatus::instance();
        std::string statName = stat_prefix + name;
        Dbg(dbg_ctl_host_statuses, "marking server %s : %s", name.c_str(),
            (cmdInfo.type == TSHostStatus::TS_HOST_STATUS_UP ? "up" : "down"));
        hs.setHostStatus(name.c_str(), cmdInfo.type, cmdInfo.time, cmdInfo.reasonType);
      }
    } else {
      resp.errata().assign(std::error_code{rpc::handlers::errors::Codes::SERVER}).note("Invalid input parameters, null");
    }

    // schedule a write to the persistent store.
    Dbg(dbg_ctl_host_statuses, "updating persistent store");
    eventProcessor.schedule_imm(HostStatusSync::new_instance(), ET_TASK);
  } catch (std::exception const &ex) {
    Dbg(dbg_ctl_host_statuses, "Got an error HostCmdInfo decoding: %s", ex.what());
    resp.errata()
      .assign(std::error_code{rpc::handlers::errors::Codes::SERVER})
      .note("Error found during host status set: {}", ex.what());
  }
  return resp;
}

// method to write host status records to the persistent store.
void