time_period_packets_stats.hpp

Go to the documentation of this file.

#pragma once
 
#include "common/types.hpp"
#include "logger/logger.hpp"
#include "network/tarcap/stats/max_stats.hpp"
#include "network/tarcap/stats/packets_stats.hpp"
 
namespace taraxa::network::tarcap {
 
class PeersState;
class TaraxaPeer;
 
class TimePeriodPacketsStats {
 public:
  TimePeriodPacketsStats(std::chrono::milliseconds reset_time_period, const addr_t& node_addr = {});
 
  void addReceivedPacket(const std::string& packet_type, const dev::p2p::NodeID& node, const PacketStats& packet);
  void addSentPacket(const std::string& packet_type, const dev::p2p::NodeID& node, const PacketStats& packet);
 
  void processStats(const std::vector<std::shared_ptr<TaraxaPeer>>& all_peers);
 
 private:
  std::pair<bool, std::chrono::milliseconds> validMaxStatsTimePeriod(
      const std::chrono::system_clock::time_point& start_time) const;
 
 private:
  // Interval during which are the peer stats supposed to be collected
  const std::chrono::milliseconds kResetTimePeriod;
 
  // Collected packets stats during time period
  PacketsStats sent_packets_stats_;
  PacketsStats received_packets_stats_;
 
  // Max stats for all received packets combined per peer
  MaxStats peer_max_stats_;
 
  // Declare logger instances
  LOG_OBJECTS_DEFINE
};
 
}  // namespace taraxa::network::tarcap