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

#include <Handler.hpp>

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

Public Member Functions

 Handler (App *control, std::size_t n_lines=1)
 Handler (const Handler &)=delete
 Handler (Handler &&)=delete
Handler & operator= (const Handler &)=delete
Handler & operator= (Handler &&)=delete
 ~Handler ()
void read_data_once (std::span< BufferElementType > read_data)
void abort ()
void start ()
auto get_read_data_bytes () const -> uint64_t
auto get_processed_hit_number () const -> uint64_t
auto get_drop_data_bytes () const -> uint64_t
auto get_frame_counts () const -> uint64_t
auto get_data_monitor () const -> const auto &
auto get_data_workflow () const -> const TaskDiagram &
auto get_app () -> auto &
auto get_n_lines () const -> auto
auto get_writer () -> auto *
void set_n_pipelines (std::size_t n_lines)
void set_print_mode (common::DataPrintMode mode)
void set_show_data_speed (bool val=true)
void set_monitor_display_period (std::chrono::milliseconds duration)
void set_output_filenames (const std::vector< std::string > &filenames)
void stop ()

Private Member Functions

void clear_data_buffer ()

Private Attributes

std::size_t n_lines_ = 1
std::atomic< bool > is_stopped_ { true }
std::size_t received_data_size_ {}
common::DataPrintMode print_mode_ = common::DataPrintMode::print_speed
std::atomic< uint64_t > total_read_data_bytes_ = 0
std::atomic< uint64_t > total_drop_data_bytes_ = 0
std::atomic< uint64_t > total_processed_hit_numer_ = 0
std::atomic< uint64_t > total_frame_counts_ = 0
gsl::not_null< App * > app_
writer::Manager writers_ { this }
DataMonitor monitor_
tbb::concurrent_bounded_queue< process::SerializableMsgBuffer > data_queue_
std::unique_ptr< TaskDiagram > task_diagram_ = nullptr

Detailed Description

Definition at line 77 of file Handler.hpp.

Constructor & Destructor Documentation

◆ Handler() [1/3]

srs::workflow::Handler::Handler ( App * control,
std::size_t n_lines = 1 )
explicit

Definition at line 121 of file Handler.cpp.

◆ Handler() [2/3]

srs::workflow::Handler::Handler ( const Handler & )
delete

◆ Handler() [3/3]

srs::workflow::Handler::Handler ( Handler && )
delete

◆ ~Handler()

srs::workflow::Handler::~Handler ( )

Definition at line 153 of file Handler.cpp.

Member Function Documentation

◆ abort()

void srs::workflow::Handler::abort ( )
inline

Definition at line 91 of file Handler.hpp.

◆ clear_data_buffer()

void srs::workflow::Handler::clear_data_buffer ( )
private

◆ get_app()

auto srs::workflow::Handler::get_app ( ) ->auto &
inlinenodiscard

Definition at line 102 of file Handler.hpp.

◆ get_data_monitor()

auto srs::workflow::Handler::get_data_monitor ( ) const->constauto &
inlinenodiscard

Definition at line 100 of file Handler.hpp.

◆ get_data_workflow()

auto srs::workflow::Handler::get_data_workflow ( ) const->constTaskDiagram &
nodiscard

Definition at line 181 of file Handler.cpp.

◆ get_drop_data_bytes()

auto srs::workflow::Handler::get_drop_data_bytes ( ) const->uint64_t
inlinenodiscard

Definition at line 98 of file Handler.hpp.

◆ get_frame_counts()

auto srs::workflow::Handler::get_frame_counts ( ) const->uint64_t
inlinenodiscard

Definition at line 99 of file Handler.hpp.

◆ get_n_lines()

auto srs::workflow::Handler::get_n_lines ( ) const->auto
inlinenodiscard

Definition at line 103 of file Handler.hpp.

◆ get_processed_hit_number()

auto srs::workflow::Handler::get_processed_hit_number ( ) const->uint64_t
inlinenodiscard

Definition at line 97 of file Handler.hpp.

◆ get_read_data_bytes()

auto srs::workflow::Handler::get_read_data_bytes ( ) const->uint64_t
inlinenodiscard

Definition at line 96 of file Handler.hpp.

◆ get_writer()

auto srs::workflow::Handler::get_writer ( ) ->auto *
inline

Definition at line 104 of file Handler.hpp.

◆ operator=() [1/2]

Handler & srs::workflow::Handler::operator= ( const Handler & )
delete

◆ operator=() [2/2]

Handler & srs::workflow::Handler::operator= ( Handler && )
delete

◆ read_data_once()

void srs::workflow::Handler::read_data_once ( std::span< BufferElementType > read_data)

Definition at line 190 of file Handler.cpp.

◆ set_monitor_display_period()

void srs::workflow::Handler::set_monitor_display_period ( std::chrono::milliseconds duration)
inline

Definition at line 110 of file Handler.hpp.

◆ set_n_pipelines()

void srs::workflow::Handler::set_n_pipelines ( std::size_t n_lines)
inline

Definition at line 107 of file Handler.hpp.

◆ set_output_filenames()

void srs::workflow::Handler::set_output_filenames ( const std::vector< std::string > & filenames)
inline

Definition at line 111 of file Handler.hpp.

◆ set_print_mode()

void srs::workflow::Handler::set_print_mode ( common::DataPrintMode mode)
inline

Definition at line 108 of file Handler.hpp.

◆ set_show_data_speed()

void srs::workflow::Handler::set_show_data_speed ( bool val = true)
inline

Definition at line 109 of file Handler.hpp.

◆ start()

void srs::workflow::Handler::start ( )

Definition at line 129 of file Handler.cpp.

◆ stop()

void srs::workflow::Handler::stop ( )

Definition at line 161 of file Handler.cpp.

Member Data Documentation

◆ app_

gsl::not_null<App*> srs::workflow::Handler::app_
private

Definition at line 129 of file Handler.hpp.

◆ data_queue_

tbb::concurrent_bounded_queue<process::SerializableMsgBuffer> srs::workflow::Handler::data_queue_
private

Definition at line 134 of file Handler.hpp.

◆ is_stopped_

std::atomic<bool> srs::workflow::Handler::is_stopped_ { true }
private

Definition at line 122 of file Handler.hpp.

◆ monitor_

DataMonitor srs::workflow::Handler::monitor_
private

Definition at line 131 of file Handler.hpp.

◆ n_lines_

std::size_t srs::workflow::Handler::n_lines_ = 1
private

Definition at line 121 of file Handler.hpp.

◆ print_mode_

common::DataPrintMode srs::workflow::Handler::print_mode_ = common::DataPrintMode::print_speed
private

Definition at line 124 of file Handler.hpp.

◆ received_data_size_

std::size_t srs::workflow::Handler::received_data_size_ {}
private

Definition at line 123 of file Handler.hpp.

◆ task_diagram_

std::unique_ptr<TaskDiagram> srs::workflow::Handler::task_diagram_ = nullptr
private

Definition at line 135 of file Handler.hpp.

◆ total_drop_data_bytes_

std::atomic<uint64_t> srs::workflow::Handler::total_drop_data_bytes_ = 0
private

Definition at line 126 of file Handler.hpp.

◆ total_frame_counts_

std::atomic<uint64_t> srs::workflow::Handler::total_frame_counts_ = 0
private

Definition at line 128 of file Handler.hpp.

◆ total_processed_hit_numer_

std::atomic<uint64_t> srs::workflow::Handler::total_processed_hit_numer_ = 0
private

Definition at line 127 of file Handler.hpp.

◆ total_read_data_bytes_

std::atomic<uint64_t> srs::workflow::Handler::total_read_data_bytes_ = 0
private

Definition at line 125 of file Handler.hpp.

◆ writers_

writer::Manager srs::workflow::Handler::writers_ { this }
private

Definition at line 130 of file Handler.hpp.

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