MySQL  8.0.23
Source Code Documentation
Pipeline_member_stats Class Reference

#include <pipeline_stats.h>

Public Member Functions

 Pipeline_member_stats ()
 Default constructor. More...
 
 Pipeline_member_stats (Pipeline_stats_member_message &msg)
 Constructor. More...
 
 Pipeline_member_stats (Pipeline_stats_member_collector *pipeline_stats, ulonglong applier_queue, ulonglong negative_certified, ulonglong certificatin_size)
 Constructor. More...
 
void update_member_stats (Pipeline_stats_member_message &msg, uint64 stamp)
 Updates member statistics with a new message from the network. More...
 
bool is_flow_control_needed ()
 Returns true if the node is behind on some user-defined criteria. More...
 
int32 get_transactions_waiting_certification ()
 Get transactions waiting certification counter value. More...
 
int32 get_transactions_waiting_apply ()
 Get transactions waiting apply counter value. More...
 
int64 get_transactions_certified ()
 Get transactions certified counter value. More...
 
int64 get_transactions_applied ()
 Get transactions applied counter value. More...
 
int64 get_transactions_local ()
 Get local member transactions proposed counter value. More...
 
int64 get_transactions_negative_certified ()
 Get transactions negatively certified. More...
 
int64 get_transactions_rows_validating ()
 Get certification database counter value. More...
 
void get_transaction_committed_all_members (std::string &value)
 Get the stable group transactions. More...
 
void set_transaction_committed_all_members (char *str, size_t len)
 Set the stable group transactions. More...
 
void get_transaction_last_conflict_free (std::string &value)
 Get the last positive certified transaction. More...
 
void set_transaction_last_conflict_free (std::string &value)
 Set the last positive certified transaction. More...
 
int64 get_transactions_local_rollback ()
 Get local member transactions negatively certified. More...
 
int64 get_delta_transactions_certified ()
 Get transactions certified since last stats message. More...
 
int64 get_delta_transactions_applied ()
 Get transactions applied since last stats message. More...
 
int64 get_delta_transactions_local ()
 Get local transactions that member tried to commmit since last stats message. More...
 
Flow_control_mode get_flow_control_mode ()
 Get flow_control_mode of a member. More...
 
uint64 get_stamp ()
 Get the last stats update stamp. More...
 
void debug (const char *member, int64 quota_size, int64 quota_used)
 

Private Attributes

int32 m_transactions_waiting_certification
 
int32 m_transactions_waiting_apply
 
int64 m_transactions_certified
 
int64 m_delta_transactions_certified
 
int64 m_transactions_applied
 
int64 m_delta_transactions_applied
 
int64 m_transactions_local
 
int64 m_delta_transactions_local
 
int64 m_transactions_negative_certified
 
int64 m_transactions_rows_validating
 
std::string m_transactions_committed_all_members
 
std::string m_transaction_last_conflict_free
 
int64 m_transactions_local_rollback
 
Flow_control_mode m_flow_control_mode
 
uint64 m_stamp
 

Detailed Description

Computed statistics per member.

Constructor & Destructor Documentation

◆ Pipeline_member_stats() [1/3]

Pipeline_member_stats::Pipeline_member_stats ( )

Default constructor.

◆ Pipeline_member_stats() [2/3]

Pipeline_member_stats::Pipeline_member_stats ( Pipeline_stats_member_message msg)

Constructor.

◆ Pipeline_member_stats() [3/3]

Pipeline_member_stats::Pipeline_member_stats ( Pipeline_stats_member_collector pipeline_stats,
ulonglong  applier_queue,
ulonglong  negative_certified,
ulonglong  certificatin_size 
)

Constructor.

Member Function Documentation

◆ debug()

void Pipeline_member_stats::debug ( const char *  member,
int64  quota_size,
int64  quota_used 
)

◆ get_delta_transactions_applied()

int64 Pipeline_member_stats::get_delta_transactions_applied ( )

Get transactions applied since last stats message.

Returns
the counter value

◆ get_delta_transactions_certified()

int64 Pipeline_member_stats::get_delta_transactions_certified ( )

Get transactions certified since last stats message.

Returns
the counter value

◆ get_delta_transactions_local()

int64 Pipeline_member_stats::get_delta_transactions_local ( )

Get local transactions that member tried to commmit since last stats message.

Returns
the counter value

◆ get_flow_control_mode()

Flow_control_mode Pipeline_member_stats::get_flow_control_mode ( )

Get flow_control_mode of a member.

Returns
the mode value

◆ get_stamp()

uint64 Pipeline_member_stats::get_stamp ( )

Get the last stats update stamp.

Returns
the counter value

◆ get_transaction_committed_all_members()

void Pipeline_member_stats::get_transaction_committed_all_members ( std::string &  value)

Get the stable group transactions.

◆ get_transaction_last_conflict_free()

void Pipeline_member_stats::get_transaction_last_conflict_free ( std::string &  value)

Get the last positive certified transaction.

◆ get_transactions_applied()

int64 Pipeline_member_stats::get_transactions_applied ( )

Get transactions applied counter value.

Returns
the counter value

◆ get_transactions_certified()

int64 Pipeline_member_stats::get_transactions_certified ( )

Get transactions certified counter value.

Returns
the counter value

◆ get_transactions_local()

int64 Pipeline_member_stats::get_transactions_local ( )

Get local member transactions proposed counter value.

Returns
the counter value

◆ get_transactions_local_rollback()

int64 Pipeline_member_stats::get_transactions_local_rollback ( )

Get local member transactions negatively certified.

Returns
the counter value

◆ get_transactions_negative_certified()

int64 Pipeline_member_stats::get_transactions_negative_certified ( )

Get transactions negatively certified.

Returns
the counter value

◆ get_transactions_rows_validating()

int64 Pipeline_member_stats::get_transactions_rows_validating ( )

Get certification database counter value.

Returns
the counter value

◆ get_transactions_waiting_apply()

int32 Pipeline_member_stats::get_transactions_waiting_apply ( )

Get transactions waiting apply counter value.

Returns
the counter value

◆ get_transactions_waiting_certification()

int32 Pipeline_member_stats::get_transactions_waiting_certification ( )

Get transactions waiting certification counter value.

Returns
the counter value

◆ is_flow_control_needed()

bool Pipeline_member_stats::is_flow_control_needed ( )

Returns true if the node is behind on some user-defined criteria.

◆ set_transaction_committed_all_members()

void Pipeline_member_stats::set_transaction_committed_all_members ( char *  str,
size_t  len 
)

Set the stable group transactions.

◆ set_transaction_last_conflict_free()

void Pipeline_member_stats::set_transaction_last_conflict_free ( std::string &  value)

Set the last positive certified transaction.

◆ update_member_stats()

void Pipeline_member_stats::update_member_stats ( Pipeline_stats_member_message msg,
uint64  stamp 
)

Updates member statistics with a new message from the network.

Member Data Documentation

◆ m_delta_transactions_applied

int64 Pipeline_member_stats::m_delta_transactions_applied
private

◆ m_delta_transactions_certified

int64 Pipeline_member_stats::m_delta_transactions_certified
private

◆ m_delta_transactions_local

int64 Pipeline_member_stats::m_delta_transactions_local
private

◆ m_flow_control_mode

Flow_control_mode Pipeline_member_stats::m_flow_control_mode
private

◆ m_stamp

uint64 Pipeline_member_stats::m_stamp
private

◆ m_transaction_last_conflict_free

std::string Pipeline_member_stats::m_transaction_last_conflict_free
private

◆ m_transactions_applied

int64 Pipeline_member_stats::m_transactions_applied
private

◆ m_transactions_certified

int64 Pipeline_member_stats::m_transactions_certified
private

◆ m_transactions_committed_all_members

std::string Pipeline_member_stats::m_transactions_committed_all_members
private

◆ m_transactions_local

int64 Pipeline_member_stats::m_transactions_local
private

◆ m_transactions_local_rollback

int64 Pipeline_member_stats::m_transactions_local_rollback
private

◆ m_transactions_negative_certified

int64 Pipeline_member_stats::m_transactions_negative_certified
private

◆ m_transactions_rows_validating

int64 Pipeline_member_stats::m_transactions_rows_validating
private

◆ m_transactions_waiting_apply

int32 Pipeline_member_stats::m_transactions_waiting_apply
private

◆ m_transactions_waiting_certification

int32 Pipeline_member_stats::m_transactions_waiting_certification
private

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