kcenon::pacs::network::pipeline::job_context Struct Reference

Context information attached to pipeline jobs for tracking. More...

#include <pipeline_job_types.h>

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

Public Attributes
uint64_t	job_id {0}
	Unique identifier for this job (monotonically increasing)
uint64_t	session_id {0}
	Session/association identifier.
uint16_t	message_id {0}
	Message ID from DIMSE command (if applicable)
pipeline_stage	stage {pipeline_stage::network_receive}
	Current pipeline stage.
job_category	category {job_category::other}
	Job category for metrics.
uint64_t	enqueue_time_ns {0}
	Timestamp when job entered the pipeline (nanoseconds since epoch)
uint32_t	sequence_number {0}
	Sequence number for ordering within a session.
uint8_t	priority {128}
	Priority (lower = higher priority, 0 = highest)

Detailed Description

Context information attached to pipeline jobs for tracking.

This context is passed through all pipeline stages for a single DICOM operation, enabling end-to-end tracing and metrics.

Definition at line 182 of file pipeline_job_types.h.

Member Data Documentation

category

job_category kcenon::pacs::network::pipeline::job_context::category {job_category::other}

Job category for metrics.

Definition at line 196 of file pipeline_job_types.h.

{job_category::other};

Referenced by kcenon::pacs::network::pipeline::dimse_process_job::dimse_process_job(), kcenon::pacs::network::pipeline::pipeline_adapter::on_job_completed(), kcenon::pacs::network::pipeline::pdu_decode_job::pdu_decode_job(), kcenon::pacs::network::pipeline::receive_network_io_job::receive_network_io_job(), kcenon::pacs::network::pipeline::send_network_io_job::send_network_io_job(), and kcenon::pacs::network::pipeline::storage_query_exec_job::storage_query_exec_job().

enqueue_time_ns

uint64_t kcenon::pacs::network::pipeline::job_context::enqueue_time_ns {0}

Timestamp when job entered the pipeline (nanoseconds since epoch)

Definition at line 199 of file pipeline_job_types.h.

{0};

Referenced by kcenon::pacs::network::pipeline::dimse_process_job::dimse_process_job(), kcenon::pacs::network::pipeline::pipeline_adapter::on_job_completed(), kcenon::pacs::network::pipeline::pdu_decode_job::pdu_decode_job(), kcenon::pacs::network::pipeline::receive_network_io_job::receive_network_io_job(), kcenon::pacs::network::pipeline::response_encode_job::response_encode_job(), kcenon::pacs::network::pipeline::send_network_io_job::send_network_io_job(), and kcenon::pacs::network::pipeline::storage_query_exec_job::storage_query_exec_job().

job_id

uint64_t kcenon::pacs::network::pipeline::job_context::job_id {0}

Unique identifier for this job (monotonically increasing)

Definition at line 184 of file pipeline_job_types.h.

{0};

message_id

uint16_t kcenon::pacs::network::pipeline::job_context::message_id {0}

Message ID from DIMSE command (if applicable)

Definition at line 190 of file pipeline_job_types.h.

{0};

Referenced by kcenon::pacs::network::pipeline::response_encode_job::response_encode_job(), and kcenon::pacs::network::pipeline::storage_query_exec_job::storage_query_exec_job().

priority

uint8_t kcenon::pacs::network::pipeline::job_context::priority {128}

Priority (lower = higher priority, 0 = highest)

Definition at line 205 of file pipeline_job_types.h.

{128};

sequence_number

uint32_t kcenon::pacs::network::pipeline::job_context::sequence_number {0}

Sequence number for ordering within a session.

Definition at line 202 of file pipeline_job_types.h.

{0};

session_id

uint64_t kcenon::pacs::network::pipeline::job_context::session_id {0}

Session/association identifier.

Definition at line 187 of file pipeline_job_types.h.

{0};

Referenced by kcenon::pacs::network::pipeline::dimse_process_job::dimse_process_job(), kcenon::pacs::network::pipeline::dimse_process_job::get_name(), kcenon::pacs::network::pipeline::pdu_decode_job::get_name(), kcenon::pacs::network::pipeline::receive_network_io_job::get_name(), kcenon::pacs::network::pipeline::response_encode_job::get_name(), kcenon::pacs::network::pipeline::send_network_io_job::get_name(), kcenon::pacs::network::pipeline::storage_query_exec_job::get_name(), kcenon::pacs::network::pipeline::receive_network_io_job::get_session_id(), kcenon::pacs::network::pipeline::send_network_io_job::get_session_id(), kcenon::pacs::network::pipeline::pdu_decode_job::pdu_decode_job(), kcenon::pacs::network::pipeline::receive_network_io_job::receive_network_io_job(), kcenon::pacs::network::pipeline::response_encode_job::response_encode_job(), kcenon::pacs::network::pipeline::send_network_io_job::send_network_io_job(), and kcenon::pacs::network::pipeline::storage_query_exec_job::storage_query_exec_job().

stage

pipeline_stage kcenon::pacs::network::pipeline::job_context::stage {pipeline_stage::network_receive}

Current pipeline stage.

Definition at line 193 of file pipeline_job_types.h.

{pipeline_stage::network_receive};

Referenced by kcenon::pacs::network::pipeline::dimse_process_job::dimse_process_job(), kcenon::pacs::network::pipeline::pipeline_adapter::on_job_completed(), kcenon::pacs::network::pipeline::pdu_decode_job::pdu_decode_job(), kcenon::pacs::network::pipeline::receive_network_io_job::receive_network_io_job(), kcenon::pacs::network::pipeline::response_encode_job::response_encode_job(), kcenon::pacs::network::pipeline::send_network_io_job::send_network_io_job(), and kcenon::pacs::network::pipeline::storage_query_exec_job::storage_query_exec_job().

---

The documentation for this struct was generated from the following file:

• include/kcenon/pacs/network/pipeline/pipeline_job_types.h