Method PostXQueueConfig

service/server/src/server.cpp:305–381

}

void Server::PostXQueueConfig(const httplib::Request &req, httplib::Response &res, const httplib::ContentReader &)
{
    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;
    }

    XPreemptLevel level = kPreemptLevelUnknown;
    if (req.has_param("level")) {
        size_t level_pos = 0;
        std::string level_str = req.get_param_value("level");
        level = (XPreemptLevel)std::stoi(level_str, &level_pos, 10);
        if (level_pos != level_str.length() || level <= kPreemptLevelUnknown || level >= kPreemptLevelMax) {
            res.status = httplib::StatusCode::BadRequest_400;
            res.set_content("{\"error\": \"invalid level\"}", "application/json");
            return;
        }
    }

    int64_t threshold = -1;
    if (req.has_param("threshold")) {
        size_t threshold_pos = 0;
        std::string threshold_str = req.get_param_value("threshold");
        threshold = std::stoll(threshold_str, &threshold_pos, 10);
        if (threshold_pos != threshold_str.length() || threshold <= 0) {
            res.status = httplib::StatusCode::BadRequest_400;
            res.set_content("{\"error\": \"invalid command threshold\"}", "application/json");
            return;
        }
    }

    int64_t batch_size = -1;
    if (req.has_param("batch_size")) {
        size_t sync_pos = 0;
        std::string sync_str = req.get_param_value("batch_size");
        batch_size = std::stoll(sync_str, &sync_pos, 10);
        if (sync_pos != sync_str.length() || batch_size <= 0) {
            res.status = httplib::StatusCode::BadRequest_400;
            res.set_content("{\"error\": \"invalid command batch size\"}", "application/json");
            return;
        }
    }

    XQueueStatus status;
    if (!GetXQueueStatus(handle, status)) {
        res.status = httplib::StatusCode::NotFound_404;
        res.set_content("{\"error\": \"XQueue not found\"}", "application/json");
        return;
    }

    if (level != kPreemptLevelUnknown) status.level = level;