JANA2
C++ framework for multi-threaded data processing
|
Public Types | |
enum class | Status { KeepGoing , ComeBackLater , Finished , NotRunYet , Error } |
using | duration_t = std::chrono::steady_clock::duration |
Public Member Functions | |
void | clear () |
void | take (JArrowMetrics &other) |
void | update (const JArrowMetrics &other) |
void | update_finished () |
void | update (const Status &last_status, const size_t &message_count_delta, const size_t &queue_visit_delta, const duration_t &latency_delta, const duration_t &queue_latency_delta) |
void | get (Status &last_status, size_t &total_message_count, size_t &last_message_count, size_t &total_queue_visits, size_t &last_queue_visits, duration_t &total_latency, duration_t &last_latency, duration_t &total_queue_latency, duration_t &last_queue_latency) |
size_t | get_total_message_count () |
Status | get_last_status () |
void | summarize () |