Job for processing DIMSE messages. More...

#include <dimse_process_job.h>

Inheritance diagram for kcenon::pacs::network::pipeline::dimse_process_job:

Collaboration diagram for kcenon::pacs::network::pipeline::dimse_process_job:

Public Types
using	request_callback = std::function<void(const dimse_request& request)>
	Callback type for processed request.

using	association_callback
	Callback type for association handling.

using	error_callback
	Callback type for processing errors.

Public Member Functions
	dimse_process_job (decoded_pdu pdu, request_callback on_request=nullptr, association_callback on_association=nullptr, error_callback on_error=nullptr)
	Construct a DIMSE process job from decoded PDU.

	~dimse_process_job () override=default

	dimse_process_job (const dimse_process_job &)=delete

dimse_process_job &	operator= (const dimse_process_job &)=delete

	dimse_process_job (dimse_process_job &&)=default

dimse_process_job &	operator= (dimse_process_job &&)=default

auto	execute (pipeline_coordinator &coordinator) -> VoidResult override
	Execute the DIMSE process job.

auto	get_context () const noexcept -> const job_context &override
	Get the job context.

auto	get_context () noexcept -> job_context &override
	Get the job context (mutable)

auto	get_name () const -> std::string override
	Get the job name.

auto	get_pdu () const noexcept -> const decoded_pdu &
	Get the decoded PDU.

Public Member Functions inherited from kcenon::pacs::network::pipeline::pipeline_job_base
virtual	~pipeline_job_base ()=default
	Virtual destructor.

Private Member Functions
auto	process_p_data () -> Result< dimse_request >
	Process P-DATA-TF PDU.

auto	process_association_pdu () -> VoidResult
	Process association PDUs (A-ASSOCIATE, A-RELEASE, A-ABORT)

Private Attributes
job_context	context_

decoded_pdu	pdu_

request_callback	on_request_

association_callback	on_association_

error_callback	on_error_

Additional Inherited Members
Protected Member Functions inherited from kcenon::pacs::network::pipeline::pipeline_job_base
	pipeline_job_base ()=default

	pipeline_job_base (const pipeline_job_base &)=delete

pipeline_job_base &	operator= (const pipeline_job_base &)=delete

	pipeline_job_base (pipeline_job_base &&)=default

pipeline_job_base &	operator= (pipeline_job_base &&)=default

Detailed Description

Job for processing DIMSE messages.

Stage 3 of the pipeline. Processes DIMSE messages and routes them to the storage/query execution stage.

Definition at line 108 of file dimse_process_job.h.

Member Typedef Documentation

◆ association_callback

using kcenon::pacs::network::pipeline::dimse_process_job::association_callback

Initial value:

 std::function<void(uint64_t session_id,
                                                    kcenon::pacs::network::pdu_type type,
                                                    const std::vector<uint8_t>& data)>

Callback type for association handling.

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/network/pipeline/jobs/dimse_process_job.h.

Definition at line 114 of file dimse_process_job.h.

◆ error_callback

using kcenon::pacs::network::pipeline::dimse_process_job::error_callback

Initial value:

std::function<void(uint64_t session_id,

const std::string& error)>

Callback type for processing errors.

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/network/pipeline/jobs/dimse_process_job.h.

Definition at line 119 of file dimse_process_job.h.

◆ request_callback

using kcenon::pacs::network::pipeline::dimse_process_job::request_callback = std::function<void(const dimse_request& request)>

Callback type for processed request.

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/network/pipeline/jobs/dimse_process_job.h.

Definition at line 111 of file dimse_process_job.h.

Constructor & Destructor Documentation

◆ dimse_process_job() [1/3]

kcenon::pacs::network::pipeline::dimse_process_job::dimse_process_job	(	decoded_pdu	pdu,
		request_callback	on_request = nullptr,
		association_callback	on_association = nullptr,
		error_callback	on_error = nullptr )

Construct a DIMSE process job from decoded PDU.

Parameters

pdu	The decoded PDU to process
on_request	Callback for DIMSE requests
on_association	Callback for association messages
on_error	Callback for errors

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/network/pipeline/jobs/dimse_process_job.h.

Definition at line 20 of file dimse_process_job.cpp.

    : pdu_(std::move(pdu))
    , on_request_(std::move(on_request))
    , on_association_(std::move(on_association))
    , on_error_(std::move(on_error)) {
 
    context_.session_id = pdu_.session_id;
    context_.stage = pipeline_stage::dimse_process;
    context_.category = job_category::other;
    context_.enqueue_time_ns = static_cast<uint64_t>(
        std::chrono::duration_cast<std::chrono::nanoseconds>(
            std::chrono::steady_clock::now().time_since_epoch()
        ).count()
    );
}

References kcenon::pacs::network::pipeline::job_context::category, context_, kcenon::pacs::network::pipeline::dimse_process, kcenon::pacs::network::pipeline::job_context::enqueue_time_ns, kcenon::pacs::network::pipeline::other, pdu_, kcenon::pacs::network::pipeline::decoded_pdu::session_id, kcenon::pacs::network::pipeline::job_context::session_id, and kcenon::pacs::network::pipeline::job_context::stage.

◆ ~dimse_process_job()

kcenon::pacs::network::pipeline::dimse_process_job::~dimse_process_job ( )

overridedefault

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/network/pipeline/jobs/dimse_process_job.h.

◆ dimse_process_job() [2/3]

kcenon::pacs::network::pipeline::dimse_process_job::dimse_process_job ( const dimse_process_job & )

delete

◆ dimse_process_job() [3/3]

kcenon::pacs::network::pipeline::dimse_process_job::dimse_process_job ( dimse_process_job && )

default

Member Function Documentation

◆ execute()

auto kcenon::pacs::network::pipeline::dimse_process_job::execute ( pipeline_coordinator & coordinator ) -> VoidResult

nodiscardoverridevirtual

Execute the DIMSE process job.

Processes the PDU and routes to appropriate handler.

Parameters

coordinator Pipeline coordinator for stage submission

Returns: VoidResult indicating success or error

Implements kcenon::pacs::network::pipeline::pipeline_job_base.

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/network/pipeline/jobs/dimse_process_job.h.

Definition at line 39 of file dimse_process_job.cpp.

                                                                               {
    // Handle association PDUs differently
    if (pdu_.type != kcenon::pacs::network::pdu_type::p_data_tf) {
        return process_association_pdu();
    }
 
    // Process P-DATA-TF (DIMSE message)
    auto request_result = process_p_data();
    if (!request_result.is_ok()) {
        if (on_error_) {
            auto err = request_result.error();
            on_error_(context_.session_id, err.message);
        }
        return VoidResult(request_result.error());
    }
 
    auto request = request_result.value();
 
    // Update context with message ID and category
    context_.message_id = request.message_id;
 
    // Determine category from command type
    switch (request.command_type) {
        case dimse_command_type::c_echo_rq:
        case dimse_command_type::c_echo_rsp:
            context_.category = job_category::echo;
            break;
        case dimse_command_type::c_store_rq:
        case dimse_command_type::c_store_rsp:
            context_.category = job_category::store;
            break;
        case dimse_command_type::c_find_rq:
        case dimse_command_type::c_find_rsp:
            context_.category = job_category::find;
            break;
        case dimse_command_type::c_get_rq:
        case dimse_command_type::c_get_rsp:
            context_.category = job_category::get;
            break;
        case dimse_command_type::c_move_rq:
        case dimse_command_type::c_move_rsp:
            context_.category = job_category::move;
            break;
        default:
            context_.category = job_category::other;
            break;
    }
 
    // Invoke callback if set
    if (on_request_) {
        on_request_(request);
    }
 
    // For response messages, skip execution stage
    uint16_t cmd_type = static_cast<uint16_t>(request.command_type);
    if (cmd_type & 0x8000) {
        // This is a response, not a request - don't submit to execution
        return ok();
    }
 
    // Create execution job for request
    // Note: The actual service handler would be set by the adapter layer
    auto exec_job = std::make_unique<storage_query_exec_job>(
        std::move(request),
        nullptr  // Handler will be set by adapter
    );
 
    // Copy context to execution job
    exec_job->get_context() = context_;
    exec_job->get_context().stage = pipeline_stage::storage_query_exec;
 
    return coordinator.submit_to_stage(
        pipeline_stage::storage_query_exec,
        std::move(exec_job)
    );
}

◆ get_context() [1/2]

auto kcenon::pacs::network::pipeline::dimse_process_job::get_context ( ) const -> const job_context&

nodiscardoverridevirtualnoexcept

Get the job context.

Implements kcenon::pacs::network::pipeline::pipeline_job_base.

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/network/pipeline/jobs/dimse_process_job.h.

Definition at line 116 of file dimse_process_job.cpp.

                                                                         {
    return context_;
}

References context_.

◆ get_context() [2/2]

auto kcenon::pacs::network::pipeline::dimse_process_job::get_context ( ) -> job_context &override

nodiscardoverridevirtualnoexcept

Get the job context (mutable)

Returns: Reference to the job context

Implements kcenon::pacs::network::pipeline::pipeline_job_base.

Definition at line 120 of file dimse_process_job.cpp.

                                                             {
    return context_;
}

References context_.

◆ get_name()

auto kcenon::pacs::network::pipeline::dimse_process_job::get_name ( ) const -> std::string

nodiscardoverridevirtual

Get the job name.

Implements kcenon::pacs::network::pipeline::pipeline_job_base.

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/network/pipeline/jobs/dimse_process_job.h.

Definition at line 124 of file dimse_process_job.cpp.

                                                    {
    return "dimse_process_job[session=" +
           std::to_string(context_.session_id) +
           ", pdu_type=" + std::to_string(static_cast<int>(pdu_.type)) + "]";
}

References context_, pdu_, kcenon::pacs::network::pipeline::job_context::session_id, and kcenon::pacs::network::pipeline::decoded_pdu::type.

◆ get_pdu()

auto kcenon::pacs::network::pipeline::dimse_process_job::get_pdu ( ) const -> const decoded_pdu&

nodiscardnoexcept

Get the decoded PDU.

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/network/pipeline/jobs/dimse_process_job.h.

Definition at line 130 of file dimse_process_job.cpp.

                                                                     {
    return pdu_;
}

References pdu_.

◆ operator=() [1/2]

dimse_process_job & kcenon::pacs::network::pipeline::dimse_process_job::operator= ( const dimse_process_job & )

delete

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/network/pipeline/jobs/dimse_process_job.h.

◆ operator=() [2/2]

dimse_process_job & kcenon::pacs::network::pipeline::dimse_process_job::operator= ( dimse_process_job && )

default

◆ process_association_pdu()

auto kcenon::pacs::network::pipeline::dimse_process_job::process_association_pdu ( ) -> VoidResult

nodiscardprivate

Process association PDUs (A-ASSOCIATE, A-RELEASE, A-ABORT)

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/network/pipeline/jobs/dimse_process_job.h.

Definition at line 227 of file dimse_process_job.cpp.

                                                              {
    // Invoke association callback
    if (on_association_) {
        on_association_(pdu_.session_id, pdu_.type, pdu_.data);
    }
 
    // Association PDUs don't go through the execution pipeline
    // They are handled directly by the association state machine
    return ok();
}

◆ process_p_data()

auto kcenon::pacs::network::pipeline::dimse_process_job::process_p_data ( ) -> Result<dimse_request>

nodiscardprivate

Process P-DATA-TF PDU.

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/network/pipeline/jobs/dimse_process_job.h.

Definition at line 134 of file dimse_process_job.cpp.

                                                                {
    dimse_request request;
    request.session_id = pdu_.session_id;
    request.presentation_context_id = pdu_.presentation_context_id;
 
    // PDV data starts after length (4) + context ID (1) + control header (1)
    if (pdu_.data.size() < 6) {
        return pacs_error<dimse_request>(error_codes::insufficient_data,
                                         "PDV data too short");
    }
 
    // Extract command from PDV data
    // The command is DICOM dataset starting at offset 6
    const auto& data = pdu_.data;
    size_t offset = 6;
 
    // Parse DICOM command elements
    // Minimum: (0000,0000) CommandGroupLength + (0000,0100) CommandField
    while (offset + 8 <= data.size()) {
        // Tag: group (2) + element (2)
        uint16_t group = static_cast<uint16_t>(data[offset]) |
                        (static_cast<uint16_t>(data[offset + 1]) << 8);
        uint16_t element = static_cast<uint16_t>(data[offset + 2]) |
                          (static_cast<uint16_t>(data[offset + 3]) << 8);
        offset += 4;
 
        // VR is implicit for command set (Implicit VR Little Endian)
        // Length (4 bytes)
        if (offset + 4 > data.size()) break;
        uint32_t length = static_cast<uint32_t>(data[offset]) |
                         (static_cast<uint32_t>(data[offset + 1]) << 8) |
                         (static_cast<uint32_t>(data[offset + 2]) << 16) |
                         (static_cast<uint32_t>(data[offset + 3]) << 24);
        offset += 4;
 
        if (offset + length > data.size()) break;
 
        // Extract key elements
        if (group == 0x0000) {
            switch (element) {
                case 0x0100:  // CommandField
                    if (length >= 2) {
                        request.command_type = static_cast<dimse_command_type>(
                            static_cast<uint16_t>(data[offset]) |
                            (static_cast<uint16_t>(data[offset + 1]) << 8)
                        );
                    }
                    break;
                case 0x0110:  // MessageID
                    if (length >= 2) {
                        request.message_id = static_cast<uint16_t>(data[offset]) |
                                            (static_cast<uint16_t>(data[offset + 1]) << 8);
                    }
                    break;
                case 0x0002:  // AffectedSOPClassUID
                case 0x0003:  // RequestedSOPClassUID
                    request.sop_class_uid = std::string(
                        reinterpret_cast<const char*>(&data[offset]), length);
                    // Trim trailing nulls/spaces
                    while (!request.sop_class_uid.empty() &&
                           (request.sop_class_uid.back() == '\0' ||
                            request.sop_class_uid.back() == ' ')) {
                        request.sop_class_uid.pop_back();
                    }
                    break;
                case 0x1000:  // AffectedSOPInstanceUID
                case 0x1001:  // RequestedSOPInstanceUID
                    request.sop_instance_uid = std::string(
                        reinterpret_cast<const char*>(&data[offset]), length);
                    while (!request.sop_instance_uid.empty() &&
                           (request.sop_instance_uid.back() == '\0' ||
                            request.sop_instance_uid.back() == ' ')) {
                        request.sop_instance_uid.pop_back();
                    }
                    break;
                case 0x0700:  // Priority
                    if (length >= 2) {
                        request.priority = static_cast<uint16_t>(data[offset]) |
                                          (static_cast<uint16_t>(data[offset + 1]) << 8);
                    }
                    break;
            }
        }
 
        offset += length;
    }
 
    // Store full command data for later use
    request.command_data = pdu_.data;
 
    return ok(std::move(request));
}

Here is the call graph for this function:

Member Data Documentation

◆ context_

job_context kcenon::pacs::network::pipeline::dimse_process_job::context_

private

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/network/pipeline/jobs/dimse_process_job.h.

Definition at line 170 of file dimse_process_job.h.

Referenced by dimse_process_job(), get_context(), get_context(), and get_name().

◆ on_association_

association_callback kcenon::pacs::network::pipeline::dimse_process_job::on_association_

private

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/network/pipeline/jobs/dimse_process_job.h.

Definition at line 173 of file dimse_process_job.h.

◆ on_error_

error_callback kcenon::pacs::network::pipeline::dimse_process_job::on_error_

private

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/network/pipeline/jobs/dimse_process_job.h.

Definition at line 174 of file dimse_process_job.h.

◆ on_request_

request_callback kcenon::pacs::network::pipeline::dimse_process_job::on_request_

private

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/network/pipeline/jobs/dimse_process_job.h.

Definition at line 172 of file dimse_process_job.h.

◆ pdu_

decoded_pdu kcenon::pacs::network::pipeline::dimse_process_job::pdu_

private

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/network/pipeline/jobs/dimse_process_job.h.

Definition at line 171 of file dimse_process_job.h.

Referenced by dimse_process_job(), get_name(), and get_pdu().

The documentation for this class was generated from the following files:

include/kcenon/pacs/network/pipeline/jobs/dimse_process_job.h
src/network/pipeline/jobs/dimse_process_job.cpp

Public Types

Public Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Member Typedef Documentation

◆ association_callback

◆ error_callback

◆ request_callback

Constructor & Destructor Documentation

◆ dimse_process_job() [1/3]

◆ ~dimse_process_job()

◆ dimse_process_job() [2/3]

◆ dimse_process_job() [3/3]

Member Function Documentation

◆ execute()

◆ get_context() [1/2]

◆ get_context() [2/2]

◆ get_name()

◆ get_pdu()

◆ operator=() [1/2]

◆ operator=() [2/2]

◆ process_association_pdu()

◆ process_p_data()

Member Data Documentation

◆ context_

◆ on_association_

◆ on_error_

◆ on_request_

◆ pdu_