Method GetXQueue

service/server/src/server.cpp:228–268

}

void Server::GetXQueue(const httplib::Request &req, httplib::Response &res)
{
    size_t pos = 0;
    std::string handle_str = req.path_params.at("handle");
    if (handle_str.empty()) {
        res.status = httplib::StatusCode::BadRequest_400;
        return;
    }
    XQueueHandle handle = std::stoull(handle_str, &pos, 16);
    if (pos != handle_str.length() || handle == 0) {
        res.status = httplib::StatusCode::BadRequest_400;
        return;
    }

    static std::mutex query_mtx;
    std::lock_guard<std::mutex> lock(query_mtx);

    static StatusQuery query(true); // also query process info
    query.Reset();
    query.status_.reserve(128);
    query.processes_.reserve(128);

    auto e = std::make_unique<XQueueQueryEvent>(handle, &query);
    XASSERT(self_chan_->Send(e->Data(), e->Size()), "cannot send XQueue query event");
    query.Wait();

    if (query.status_.empty() || query.processes_.empty()) {
        res.status = httplib::StatusCode::NotFound_404;
        return;
    }
    Json::Value xqueue(Json::objectValue);
    XQueueStatusToJson(xqueue, *query.status_[0]);
    Json::Value process(Json::objectValue);
    process["pid"] = (Json::Int)query.processes_[0]->pid;
    process["cmdline"] = query.processes_[0]->cmdline;

    Json::Value response(Json::objectValue);
    response["xqueue"] = xqueue;
    response["process"] = process;
    res.set_content(Json::writeString(json_writer_, response).c_str(), "application/json");
}

void Server::GetXQueues(const httplib::Request &, httplib::Response &res)
{