Metrics for tracking DICOM association lifecycle. More...

#include <pacs_metrics.h>

Collaboration diagram for kcenon::pacs::monitoring::association_counters:

Public Member Functions
void	record_established () noexcept
	Record an association being established.

void	record_released () noexcept
	Record an association being released normally.

void	record_rejected () noexcept
	Record an association being rejected.

void	record_aborted () noexcept
	Record an association being aborted.

void	reset () noexcept
	Reset all counters to zero.

Public Attributes
std::atomic< std::uint64_t >	total_established {0}

std::atomic< std::uint64_t >	total_rejected {0}

std::atomic< std::uint64_t >	total_aborted {0}

std::atomic< std::uint32_t >	current_active {0}

std::atomic< std::uint32_t >	peak_active {0}

Detailed Description

Metrics for tracking DICOM association lifecycle.

Thread-safe counters for tracking association establishment, rejection, and current active count.

Definition at line 217 of file pacs_metrics.h.

Member Function Documentation

◆ record_aborted()

void kcenon::pacs::monitoring::association_counters::record_aborted ( )

inlinenoexcept

Record an association being aborted.

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/monitoring/pacs_metrics.h.

Definition at line 251 of file pacs_metrics.h.

                                   {
        total_aborted.fetch_add(1, std::memory_order_relaxed);
        const auto prev = current_active.load(std::memory_order_relaxed);
        if (prev > 0) {
            current_active.fetch_sub(1, std::memory_order_relaxed);
        }
    }

References current_active, and total_aborted.

Referenced by kcenon::pacs::monitoring::pacs_metrics::record_association_aborted().

Here is the caller graph for this function:

◆ record_established()

void kcenon::pacs::monitoring::association_counters::record_established ( )

inlinenoexcept

Record an association being established.

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/monitoring/pacs_metrics.h.

Definition at line 225 of file pacs_metrics.h.

                                       {
        total_established.fetch_add(1, std::memory_order_relaxed);
        const auto active = current_active.fetch_add(1, std::memory_order_relaxed) + 1;
 
        // Update peak with CAS loop
        auto current_peak = peak_active.load(std::memory_order_relaxed);
        while (active > current_peak &&
               !peak_active.compare_exchange_weak(current_peak, active,
                                                   std::memory_order_relaxed)) {
        }
    }

References current_active, peak_active, and total_established.

Referenced by kcenon::pacs::monitoring::pacs_metrics::record_association_established().

Here is the caller graph for this function:

◆ record_rejected()

void kcenon::pacs::monitoring::association_counters::record_rejected ( )

inlinenoexcept

Record an association being rejected.

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/monitoring/pacs_metrics.h.

Definition at line 246 of file pacs_metrics.h.

                                    {
        total_rejected.fetch_add(1, std::memory_order_relaxed);
    }

References total_rejected.

Referenced by kcenon::pacs::monitoring::pacs_metrics::record_association_rejected().

Here is the caller graph for this function:

◆ record_released()

void kcenon::pacs::monitoring::association_counters::record_released ( )

inlinenoexcept

Record an association being released normally.

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/monitoring/pacs_metrics.h.

Definition at line 238 of file pacs_metrics.h.

                                    {
        const auto prev = current_active.load(std::memory_order_relaxed);
        if (prev > 0) {
            current_active.fetch_sub(1, std::memory_order_relaxed);
        }
    }

References current_active.

Referenced by kcenon::pacs::monitoring::pacs_metrics::record_association_released().

Here is the caller graph for this function:

◆ reset()

void kcenon::pacs::monitoring::association_counters::reset ( )

inlinenoexcept

Reset all counters to zero.

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/monitoring/pacs_metrics.h.

Definition at line 260 of file pacs_metrics.h.

                          {
        total_established.store(0, std::memory_order_relaxed);
        total_rejected.store(0, std::memory_order_relaxed);
        total_aborted.store(0, std::memory_order_relaxed);
        current_active.store(0, std::memory_order_relaxed);
        peak_active.store(0, std::memory_order_relaxed);
    }