SRS-control 0.1.4
Loading...
Searching...
No Matches
srs::workflow::DataMonitor Class Reference

#include <Handler.hpp>

Collaboration diagram for srs::workflow::DataMonitor:
Collaboration graph
[legend]

Public Member Functions

 DataMonitor (Handler *processor, io_context_type *io_context)
void show_data_speed (bool val=true)
void set_display_period (std::chrono::milliseconds duration)
void start ()
void stop ()
void http_server_loop ()
auto get_received_bytes_MBps () const -> double
auto get_processed_hit_rate () const -> double

Private Member Functions

void set_speed_string ()
auto print_cycle () -> asio::awaitable< void >

Private Attributes

bool is_shown_ = true
gsl::not_null< Handler * > processor_
gsl::not_null< io_context_type * > io_context_
std::shared_ptr< spdlog::logger > console_
asio::steady_timer clock_
std::chrono::time_point< std::chrono::steady_clock > last_print_time_ = std::chrono::steady_clock::now()
std::chrono::milliseconds period_ = common::DEFAULT_DISPLAY_PERIOD
uint64_t last_read_data_bytes_ = 0
uint64_t last_write_data_bytes_ = 0
uint64_t last_drop_data_bytes_ = 0
uint64_t last_processed_hit_num_ = 0
uint64_t last_frame_counts_ = 0
double current_received_bytes_MBps_ = 0.
double current_write_bytes_MBps_ = 0.
double current_drop_bytes_MBps_ = 0.
double current_hits_ps_ = 0.
std::string read_speed_string_
std::string write_speed_string_
std::string drop_speed_string_
std::string unit_string_

Detailed Description

Definition at line 36 of file Handler.hpp.

Constructor & Destructor Documentation

◆ DataMonitor()

srs::workflow::DataMonitor::DataMonitor ( Handler * processor,
io_context_type * io_context )
explicit

Definition at line 32 of file Handler.cpp.

Member Function Documentation

◆ get_processed_hit_rate()

auto srs::workflow::DataMonitor::get_processed_hit_rate ( ) const->double
inlinenodiscard

Definition at line 49 of file Handler.hpp.

◆ get_received_bytes_MBps()

auto srs::workflow::DataMonitor::get_received_bytes_MBps ( ) const->double
inlinenodiscard

Definition at line 48 of file Handler.hpp.

◆ http_server_loop()

void srs::workflow::DataMonitor::http_server_loop ( )

◆ print_cycle()

auto srs::workflow::DataMonitor::print_cycle ( ) ->asio::awaitable< void >
private

Definition at line 39 of file Handler.cpp.

◆ set_display_period()

void srs::workflow::DataMonitor::set_display_period ( std::chrono::milliseconds duration)
inline

Definition at line 41 of file Handler.hpp.

◆ set_speed_string()

void srs::workflow::DataMonitor::set_speed_string ( )
private

Definition at line 96 of file Handler.cpp.

◆ show_data_speed()

void srs::workflow::DataMonitor::show_data_speed ( bool val = true)
inline

Definition at line 40 of file Handler.hpp.

◆ start()

void srs::workflow::DataMonitor::start ( )

Definition at line 113 of file Handler.cpp.

◆ stop()

void srs::workflow::DataMonitor::stop ( )

Definition at line 115 of file Handler.cpp.

Member Data Documentation

◆ clock_

asio::steady_timer srs::workflow::DataMonitor::clock_
private

Definition at line 56 of file Handler.hpp.

◆ console_

std::shared_ptr<spdlog::logger> srs::workflow::DataMonitor::console_
private

Definition at line 55 of file Handler.hpp.

◆ current_drop_bytes_MBps_

double srs::workflow::DataMonitor::current_drop_bytes_MBps_ = 0.
private

Definition at line 66 of file Handler.hpp.

◆ current_hits_ps_

double srs::workflow::DataMonitor::current_hits_ps_ = 0.
private

Definition at line 67 of file Handler.hpp.

◆ current_received_bytes_MBps_

double srs::workflow::DataMonitor::current_received_bytes_MBps_ = 0.
private

Definition at line 64 of file Handler.hpp.

◆ current_write_bytes_MBps_

double srs::workflow::DataMonitor::current_write_bytes_MBps_ = 0.
private

Definition at line 65 of file Handler.hpp.

◆ drop_speed_string_

std::string srs::workflow::DataMonitor::drop_speed_string_
private

Definition at line 70 of file Handler.hpp.

◆ io_context_

gsl::not_null<io_context_type*> srs::workflow::DataMonitor::io_context_
private

Definition at line 54 of file Handler.hpp.

◆ is_shown_

bool srs::workflow::DataMonitor::is_shown_ = true
private

Definition at line 52 of file Handler.hpp.

◆ last_drop_data_bytes_

uint64_t srs::workflow::DataMonitor::last_drop_data_bytes_ = 0
private

Definition at line 61 of file Handler.hpp.

◆ last_frame_counts_

uint64_t srs::workflow::DataMonitor::last_frame_counts_ = 0
private

Definition at line 63 of file Handler.hpp.

◆ last_print_time_

std::chrono::time_point<std::chrono::steady_clock> srs::workflow::DataMonitor::last_print_time_ = std::chrono::steady_clock::now()
private

Definition at line 57 of file Handler.hpp.

◆ last_processed_hit_num_

uint64_t srs::workflow::DataMonitor::last_processed_hit_num_ = 0
private

Definition at line 62 of file Handler.hpp.

◆ last_read_data_bytes_

uint64_t srs::workflow::DataMonitor::last_read_data_bytes_ = 0
private

Definition at line 59 of file Handler.hpp.

◆ last_write_data_bytes_

uint64_t srs::workflow::DataMonitor::last_write_data_bytes_ = 0
private

Definition at line 60 of file Handler.hpp.

◆ period_

std::chrono::milliseconds srs::workflow::DataMonitor::period_ = common::DEFAULT_DISPLAY_PERIOD
private

Definition at line 58 of file Handler.hpp.

◆ processor_

gsl::not_null<Handler*> srs::workflow::DataMonitor::processor_
private

Definition at line 53 of file Handler.hpp.

◆ read_speed_string_

std::string srs::workflow::DataMonitor::read_speed_string_
private

Definition at line 68 of file Handler.hpp.

◆ unit_string_

std::string srs::workflow::DataMonitor::unit_string_
private

Definition at line 71 of file Handler.hpp.

◆ write_speed_string_

std::string srs::workflow::DataMonitor::write_speed_string_
private

Definition at line 69 of file Handler.hpp.

The documentation for this class was generated from the following files: