Report.hpp

Go to the documentation of this file.

 
#pragma once
 
#include <array>
#include <atomic>
#include <chrono>
#include <cstdint>
#include <ostream>
#include <string>
 
#include <ifw/fnd/defs/iCommAdapter.hpp>
 
namespace eso::uatools::uastresstest {
 
  class Report {
  public:
    Report();

    void Record(std::chrono::nanoseconds latency,
                ifw::fnd::defs::Status status);

    void RecordConnectionEvent(ifw::fnd::defs::ConnectionState state);

    std::uint64_t TotalOps() const noexcept;

    void Print(std::ostream& os, std::chrono::seconds duration) const;
 
  private:
    // ---- Per-status counters ----
    // ifw::fnd::defs::Status is a small enum; we map each value to
    // a fixed index so the hot path is a single fetch_add. Status
    // values not in the enum (which shouldn't exist) bucket into
    // index 0 ("Ok").
    static constexpr std::size_t kStatusCount = 16;
    std::array<std::atomic<std::uint64_t>, kStatusCount> m_status_counts{};
 
    // ---- Connection-state counters ----
    std::atomic<std::uint64_t> m_connected_events{0};
    std::atomic<std::uint64_t> m_reconnecting_events{0};
    std::atomic<std::uint64_t> m_faulted_events{0};
    std::atomic<std::uint64_t> m_disconnected_events{0};
 
    // ---- Latency histogram ----
    // Log-spaced buckets covering 1 us .. ~10 s. Bucket i covers
    // [10^((i-6)/2) seconds, 10^((i-5)/2) seconds), so e.g.:
    //   bucket 0  = [-inf, 1 us)
    //   bucket 6  = [1 us, ~3 us)
    //   bucket 18 = [~1 ms, ~3 ms)
    //   bucket 30 = [~1 s, ~3 s)
    // Anything > 10 s lands in the final bucket as "overflow".
    static constexpr std::size_t kBuckets = 32;
    std::array<std::atomic<std::uint64_t>, kBuckets> m_latency_buckets{};
 
    static std::size_t BucketIndex(std::chrono::nanoseconds latency);
 
    // For percentile reporting.
    std::uint64_t Percentile(double p) const;
    double        BucketUpperBoundUs(std::size_t idx) const;
  };
 
}  // namespace eso::uatools::uastresstest