monitoring.hpp

Go to the documentation of this file.

// SPDX-FileCopyrightText: 2020-2025 European Southern Observatory (ESO)
//
// SPDX-License-Identifier: LGPL-3.0-only

 
#ifndef HLCC_TELIF_ELTPK_MONITORING_HPP
#define HLCC_TELIF_ELTPK_MONITORING_HPP
 
#include <chrono>
#include <string>
 
#include <hlcc/oldbmux/observablePublisher.hpp>
 
namespace hlcc::eltpk {
 

class ElapsedTimeStats {
 
public:
    ElapsedTimeStats();
    void SetIterationStart();
 
    void AddTotalElapsed(std::chrono::nanoseconds elapsed);
    void AddMalPubElapsed(std::chrono::nanoseconds elapsed);
    void AddOldbWriteElapsed(std::chrono::nanoseconds elapsed);
    void AddObservablePublisherElapsed(const hlcc::oldbmux::PublishingTimeElapsed& pte);
 
    std::chrono::nanoseconds GetTimeSinceReset() const;
    std::string PrintStatsAndReset();
 
private:
 
    std::chrono::nanoseconds m_dur_it_total;   // current iteration
    std::chrono::nanoseconds m_dur_cum_total;  // cumulative since last reset
    std::chrono::nanoseconds m_dur_max_total;  // max since last reset
 
    std::chrono::nanoseconds m_dur_it_mal_pub;
    std::chrono::nanoseconds m_dur_cum_mal_pub;
    std::chrono::nanoseconds m_dur_max_mal_pub;
 
    std::chrono::nanoseconds m_dur_it_oldb_write;
    std::chrono::nanoseconds m_dur_cum_oldb_write;
    std::chrono::nanoseconds m_dur_max_oldb_write;
 
    std::chrono::steady_clock::time_point m_last_reset_t;
    std::size_t m_iteration_count;
 
    void AddIterationValues();
    void ResetIteration();
};
 
}  // namespace hlcc::eltpk
#endif  // HLCC_TELIF_ELTPK_MONITORING_HPP