Job for decoding raw PDU bytes. More...

#include <pdu_decode_job.h>

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

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

Public Types
using	decode_callback = std::function<void(const decoded_pdu& pdu)>
	Callback type for decoded PDU.

using	error_callback
	Callback type for decode errors.

Public Member Functions
	pdu_decode_job (uint64_t session_id, std::vector< uint8_t > raw_data, decode_callback on_decoded=nullptr, error_callback on_error=nullptr)
	Construct a decode job.

	~pdu_decode_job () override=default

	pdu_decode_job (const pdu_decode_job &)=delete

pdu_decode_job &	operator= (const pdu_decode_job &)=delete

	pdu_decode_job (pdu_decode_job &&)=default

pdu_decode_job &	operator= (pdu_decode_job &&)=default

auto	execute (pipeline_coordinator &coordinator) -> VoidResult override
	Execute the decode 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_raw_data () const noexcept -> const std::vector< uint8_t > &
	Get the raw PDU data.

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

Private Member Functions
auto	decode_pdu () -> Result< decoded_pdu >
	Internal decode method.

Private Attributes
job_context	context_

std::vector< uint8_t >	raw_data_

decode_callback	on_decoded_

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 decoding raw PDU bytes.

Stage 2 of the pipeline. Decodes PDU bytes and submits the decoded result to the DIMSE processing stage.

Definition at line 66 of file pdu_decode_job.h.

Member Typedef Documentation

◆ decode_callback

using kcenon::pacs::network::pipeline::pdu_decode_job::decode_callback = std::function<void(const decoded_pdu& pdu)>

Callback type for decoded PDU.

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

Definition at line 69 of file pdu_decode_job.h.

◆ error_callback

using kcenon::pacs::network::pipeline::pdu_decode_job::error_callback

Initial value:

std::function<void(uint64_t session_id,

const std::string& error)>

Callback type for decode errors.

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

Definition at line 72 of file pdu_decode_job.h.

Constructor & Destructor Documentation

◆ pdu_decode_job() [1/3]

kcenon::pacs::network::pipeline::pdu_decode_job::pdu_decode_job	(	uint64_t	session_id,
		std::vector< uint8_t >	raw_data,
		decode_callback	on_decoded = nullptr,
		error_callback	on_error = nullptr )

Construct a decode job.

Parameters

session_id	The session/connection identifier
raw_data	The raw PDU bytes to decode
on_decoded	Callback to invoke when PDU is decoded
on_error	Callback to invoke on errors

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

Definition at line 20 of file pdu_decode_job.cpp.

    : raw_data_(std::move(raw_data))
    , on_decoded_(std::move(on_decoded))
    , on_error_(std::move(on_error)) {
 
    context_.session_id = session_id;
    context_.stage = pipeline_stage::pdu_decode;
    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::job_context::enqueue_time_ns, kcenon::pacs::network::pipeline::other, kcenon::pacs::network::pipeline::pdu_decode, kcenon::pacs::network::pipeline::job_context::session_id, and kcenon::pacs::network::pipeline::job_context::stage.

◆ ~pdu_decode_job()

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

overridedefault

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

◆ pdu_decode_job() [2/3]

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

delete

◆ pdu_decode_job() [3/3]

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

default

Member Function Documentation

◆ decode_pdu()

auto kcenon::pacs::network::pipeline::pdu_decode_job::decode_pdu ( ) -> Result<decoded_pdu>

nodiscardprivate

Internal decode method.

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

Definition at line 107 of file pdu_decode_job.cpp.

                                                       {
    decoded_pdu result;
    result.session_id = context_.session_id;
 
    // PDU Header: Type (1 byte) + Reserved (1 byte) + Length (4 bytes)
    if (raw_data_.size() < 6) {
        return pacs_error<decoded_pdu>(error_codes::insufficient_data,
                                       "Insufficient data for PDU header");
    }
 
    // Extract PDU type
    result.type = static_cast<kcenon::pacs::network::pdu_type>(raw_data_[0]);
 
    // Extract length (big-endian, 4 bytes starting at offset 2)
    uint32_t length = (static_cast<uint32_t>(raw_data_[2]) << 24) |
                      (static_cast<uint32_t>(raw_data_[3]) << 16) |
                      (static_cast<uint32_t>(raw_data_[4]) << 8) |
                      static_cast<uint32_t>(raw_data_[5]);
 
    // Validate we have complete PDU
    if (raw_data_.size() < 6 + length) {
        return pacs_error<decoded_pdu>(error_codes::incomplete_pdu,
                                       "Incomplete PDU data");
    }
 
    // Copy PDU data (excluding header)
    result.data.assign(raw_data_.begin() + 6,
                       raw_data_.begin() + 6 + length);
 
    // For P-DATA-TF, extract presentation context ID and flags
    if (result.type == kcenon::pacs::network::pdu_type::p_data_tf && !result.data.empty()) {
        // P-DATA-TF contains PDV items
        // PDV Item: Length (4) + Presentation Context ID (1) + Message Control Header (1) + Data
        if (result.data.size() >= 6) {
            result.presentation_context_id = result.data[4];
            uint8_t control_header = result.data[5];
            result.is_last_fragment = (control_header & 0x02) != 0;
        }
    }
 
    return ok(std::move(result));
}

References kcenon::pacs::network::pipeline::decoded_pdu::data, kcenon::pacs::error_codes::incomplete_pdu, kcenon::pacs::error_codes::insufficient_data, kcenon::pacs::network::pipeline::decoded_pdu::is_last_fragment, kcenon::pacs::network::p_data_tf, kcenon::pacs::pacs_error(), kcenon::pacs::network::pipeline::decoded_pdu::presentation_context_id, kcenon::pacs::network::pipeline::decoded_pdu::session_id, and kcenon::pacs::network::pipeline::decoded_pdu::type.

Here is the call graph for this function:

◆ execute()

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

nodiscardoverridevirtual

Execute the decode job.

Decodes the PDU and submits to the DIMSE processing stage.

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/pdu_decode_job.h.

Definition at line 38 of file pdu_decode_job.cpp.

                                                                            {
    // Validate we have data
    if (raw_data_.size() < 6) {  // Minimum PDU header size
        if (on_error_) {
            on_error_(context_.session_id, "PDU data too short");
        }
        return pacs_void_error(error_codes::insufficient_data,
                               "PDU data too short for header");
    }
 
    // Decode the PDU
    auto decode_result = decode_pdu();
    if (!decode_result.is_ok()) {
        if (on_error_) {
            auto err = decode_result.error();
            on_error_(context_.session_id, err.message);
        }
        return VoidResult(decode_result.error());
    }
 
    auto pdu = decode_result.value();
 
    // Invoke callback if set
    if (on_decoded_) {
        on_decoded_(pdu);
    }
 
    // Update context based on PDU type
    if (pdu.type == kcenon::pacs::network::pdu_type::associate_rq ||
        pdu.type == kcenon::pacs::network::pdu_type::associate_ac ||
        pdu.type == kcenon::pacs::network::pdu_type::associate_rj ||
        pdu.type == kcenon::pacs::network::pdu_type::release_rq ||
        pdu.type == kcenon::pacs::network::pdu_type::release_rp ||
        pdu.type == kcenon::pacs::network::pdu_type::abort) {
        context_.category = job_category::association;
    }
 
    // Create DIMSE process job and submit to next stage
    auto dimse_job = std::make_unique<dimse_process_job>(std::move(pdu));
 
    // Copy context to DIMSE job
    dimse_job->get_context() = context_;
    dimse_job->get_context().stage = pipeline_stage::dimse_process;
 
    return coordinator.submit_to_stage(
        pipeline_stage::dimse_process,
        std::move(dimse_job)
    );
}

References kcenon::pacs::network::abort, kcenon::pacs::network::associate_ac, kcenon::pacs::network::associate_rj, kcenon::pacs::network::associate_rq, kcenon::pacs::network::pipeline::association, kcenon::pacs::network::pipeline::dimse_process, kcenon::pacs::error_codes::insufficient_data, kcenon::pacs::pacs_void_error(), kcenon::pacs::network::release_rp, and kcenon::pacs::network::release_rq.

Here is the call graph for this function:

◆ get_context() [1/2]

auto kcenon::pacs::network::pipeline::pdu_decode_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/pdu_decode_job.h.

Definition at line 88 of file pdu_decode_job.cpp.

                                                                      {
    return context_;
}

References context_.

◆ get_context() [2/2]

auto kcenon::pacs::network::pipeline::pdu_decode_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 92 of file pdu_decode_job.cpp.

                                                          {
    return context_;
}

References context_.

◆ get_name()

auto kcenon::pacs::network::pipeline::pdu_decode_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/pdu_decode_job.h.

Definition at line 96 of file pdu_decode_job.cpp.

                                                 {
    return "pdu_decode_job[session=" +
           std::to_string(context_.session_id) +
           ", bytes=" + std::to_string(raw_data_.size()) + "]";
}

References context_, raw_data_, and kcenon::pacs::network::pipeline::job_context::session_id.

◆ get_raw_data()

auto kcenon::pacs::network::pipeline::pdu_decode_job::get_raw_data ( ) const -> const std::vector<uint8_t>&

nodiscardnoexcept

Get the raw PDU data.

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

Definition at line 102 of file pdu_decode_job.cpp.

                                 {
    return raw_data_;
}

References raw_data_.

◆ operator=() [1/2]

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

delete

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

◆ operator=() [2/2]

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

default

Member Data Documentation

◆ context_

job_context kcenon::pacs::network::pipeline::pdu_decode_job::context_

private

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

Definition at line 123 of file pdu_decode_job.h.

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

◆ on_decoded_

decode_callback kcenon::pacs::network::pipeline::pdu_decode_job::on_decoded_

private

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

Definition at line 125 of file pdu_decode_job.h.

◆ on_error_

error_callback kcenon::pacs::network::pipeline::pdu_decode_job::on_error_

private

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

Definition at line 126 of file pdu_decode_job.h.

◆ raw_data_

std::vector<uint8_t> kcenon::pacs::network::pipeline::pdu_decode_job::raw_data_

private

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

Definition at line 124 of file pdu_decode_job.h.

Referenced by get_name(), and get_raw_data().

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

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

Public Types

Public Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Member Typedef Documentation

◆ decode_callback

◆ error_callback

Constructor & Destructor Documentation

◆ pdu_decode_job() [1/3]

◆ ~pdu_decode_job()

◆ pdu_decode_job() [2/3]

◆ pdu_decode_job() [3/3]

Member Function Documentation

◆ decode_pdu()

◆ execute()

◆ get_context() [1/2]

◆ get_context() [2/2]

◆ get_name()

◆ get_raw_data()

◆ operator=() [1/2]

◆ operator=() [2/2]

Member Data Documentation

◆ context_

◆ on_decoded_

◆ on_error_

◆ raw_data_