pipeline_job_types.h

Go to the documentation of this file.

// BSD 3-Clause License
// Copyright (c) 2021-2025, 🍀☀🌕🌥 🌊
// See the LICENSE file in the project root for full license information.
 
#pragma once
 
#include <cstdint>
#include <string_view>
 
namespace kcenon::pacs::network::pipeline {
 
enum class pipeline_stage : uint8_t {
    network_receive = 0,
 
    pdu_decode = 1,
 
    dimse_process = 2,
 
    storage_query_exec = 3,
 
    response_encode = 4,
 
    network_send = 5,
 
    stage_count = 6
};
 
[[nodiscard]] constexpr auto get_stage_name(pipeline_stage stage) noexcept
    -> std::string_view {
    switch (stage) {
        case pipeline_stage::network_receive:
            return "network_receive";
        case pipeline_stage::pdu_decode:
            return "pdu_decode";
        case pipeline_stage::dimse_process:
            return "dimse_process";
        case pipeline_stage::storage_query_exec:
            return "storage_query_exec";
        case pipeline_stage::response_encode:
            return "response_encode";
        case pipeline_stage::network_send:
            return "network_send";
        default:
            return "unknown";
    }
}
 
[[nodiscard]] constexpr auto is_blocking_stage(pipeline_stage stage) noexcept
    -> bool {
    return stage == pipeline_stage::storage_query_exec;
}
 
[[nodiscard]] constexpr auto is_network_io_stage(pipeline_stage stage) noexcept
    -> bool {
    return stage == pipeline_stage::network_receive ||
           stage == pipeline_stage::network_send;
}
 
enum class job_category : uint8_t {
    echo = 0,
 
    store = 1,
 
    find = 2,
 
    get = 3,
 
    move = 4,
 
    association = 5,
 
    control = 6,
 
    other = 7
};
 
[[nodiscard]] constexpr auto get_category_name(job_category category) noexcept
    -> std::string_view {
    switch (category) {
        case job_category::echo:
            return "echo";
        case job_category::store:
            return "store";
        case job_category::find:
            return "find";
        case job_category::get:
            return "get";
        case job_category::move:
            return "move";
        case job_category::association:
            return "association";
        case job_category::control:
            return "control";
        default:
            return "other";
    }
}
 
struct job_context {
    uint64_t job_id{0};
 
    uint64_t session_id{0};
 
    uint16_t message_id{0};
 
    pipeline_stage stage{pipeline_stage::network_receive};
 
    job_category category{job_category::other};
 
    uint64_t enqueue_time_ns{0};
 
    uint32_t sequence_number{0};
 
    uint8_t priority{128};
};
 
}  // namespace kcenon::pacs::network::pipeline