ClimbingTelemetry.h

浏览该文件的文档.

#pragma once
#include "common/Export.h"
 
 
#include "climbing/ClimbingPrimitives.h"
#include "common/Time.h"
 
#include <array>
#include <cstddef>
#include <cstdint>
#include <span>
 
namespace eve::climbing {
 
enum class ClimbingWorkload : std::uint8_t { Ordinary, CandidateProbe, Active };
 
enum class ClimbingQueryBudgetState : std::uint8_t { WithinBudget, Exceeded };
 
struct ClimbingQueryBudgets {
    static constexpr std::uint32_t Ordinary = 4;
    static constexpr std::uint32_t CandidateProbe = 16;
    static constexpr std::uint32_t Active = 8;
 
    [[nodiscard]] static constexpr std::uint32_t forWorkload(ClimbingWorkload workload) noexcept {
        switch (workload) {
            case ClimbingWorkload::Ordinary: return Ordinary;
            case ClimbingWorkload::CandidateProbe: return CandidateProbe;
            case ClimbingWorkload::Active: return Active;
        }
        return 0;
    }
};
 
struct ClimbingRuntimeCounters {
    ClimbingWorkload         workload = ClimbingWorkload::Ordinary;
    std::uint32_t            broadPhaseQueryCount = 0;
    std::uint32_t            broadPhaseHitCount = 0;
    std::uint32_t            queryCount = 0;
    std::uint32_t            rejectCount = 0;
    std::int64_t             selectedCost = 0;
    Vec3                     warpResidual;
    std::uint32_t            moverIterations = 0;
    std::uint32_t            queryBudget = ClimbingQueryBudgets::Ordinary;
    ClimbingQueryBudgetState budgetState = ClimbingQueryBudgetState::WithinBudget;
};
 
struct ClimbingTelemetrySample {
    eve::SimulationTick     tick = eve::SimulationTick::zero();
    std::uint64_t           elapsedNanoseconds = 0;
    ClimbingRuntimeCounters counters;
};
 
struct ClimbingTelemetrySummary {
    ClimbingWorkload workload = ClimbingWorkload::Ordinary;
    std::uint32_t    sampleCount = 0;
    std::uint64_t    p50Nanoseconds = 0;
    std::uint64_t    p95Nanoseconds = 0;
    std::uint32_t    p50QueryCount = 0;
    std::uint32_t    p95QueryCount = 0;
    std::uint32_t    maxQueryCount = 0;
    std::uint32_t    budgetExceededCount = 0;
};
 
class EVENGINE_API_DOMAINS ClimbingTelemetryBuffer {
public:
    static constexpr std::size_t Capacity = 256;
 
    void record(ClimbingTelemetrySample sample) noexcept;
    void updateLatestCounters(ClimbingRuntimeCounters counters) noexcept;
    [[nodiscard]] std::span<const ClimbingTelemetrySample> samples() const noexcept {
        return {samples_.data(), size_};
    }
    [[nodiscard]] ClimbingTelemetrySummary summarize(ClimbingWorkload workload) const noexcept;
    void clear() noexcept {
        size_ = 0;
        next_ = 0;
    }
 
private:
    std::array<ClimbingTelemetrySample, Capacity> samples_{};
    std::size_t                                   size_ = 0;
    std::size_t                                   next_ = 0;
};
 
}  // namespace eve::climbing