MySQL  8.0.20
Source Code Documentation
Pipeline_stats_member_collector Class Reference

The pipeline collector for the local member stats. More...

#include <pipeline_stats.h>

Public Member Functions

 Pipeline_stats_member_collector ()
 Default constructor. More...
 
virtual ~Pipeline_stats_member_collector ()
 Destructor. More...
 
void increment_transactions_waiting_apply ()
 Increment transactions waiting apply counter value. More...
 
void decrement_transactions_waiting_apply ()
 Decrement transactions waiting apply counter value. More...
 
void increment_transactions_certified ()
 Increment transactions certified counter value. More...
 
void increment_transactions_applied ()
 Increment transactions applied counter value. More...
 
void increment_transactions_local ()
 Increment local transactions counter value. More...
 
void increment_transactions_local_rollback ()
 Increment local rollback transactions counter value. More...
 
void send_stats_member_message (Flow_control_mode mode)
 Send member statistics to group. More...
 
void increment_transactions_applied_during_recovery ()
 Increment local recovery transactions counter value. More...
 
uint64 get_transactions_waiting_apply_during_recovery ()
 
void increment_transactions_delivered_during_recovery ()
 Increment delivered transactions during recovery counter value. More...
 
void increment_transactions_certified_during_recovery ()
 Increment certified transactions during recovery counter value. More...
 
void increment_transactions_certified_negatively_during_recovery ()
 Increment negatively certified transactions during recovery counter value. More...
 
uint64 get_transactions_waiting_certification_during_recovery ()
 
void compute_transactions_deltas_during_recovery ()
 Compute the transactions applied during last flow-control tick while the member is in recovery. More...
 
uint64 get_delta_transactions_applied_during_recovery ()
 
int32 get_transactions_waiting_apply ()
 
int64 get_transactions_certified ()
 
int64 get_transactions_applied ()
 
int64 get_transactions_local ()
 
int64 get_transactions_local_rollback ()
 
void set_send_transaction_identifiers ()
 Send Transaction Identifiers or not. More...
 

Private Attributes

std::atomic< int32m_transactions_waiting_apply
 
std::atomic< int64m_transactions_certified
 
std::atomic< int64m_transactions_applied
 
std::atomic< int64m_transactions_local
 
std::atomic< int64m_transactions_local_rollback
 
std::atomic< uint64m_transactions_certified_during_recovery
 
std::atomic< uint64m_transactions_certified_negatively_during_recovery
 
std::atomic< uint64m_transactions_applied_during_recovery
 
uint64 m_previous_transactions_applied_during_recovery
 
std::atomic< uint64m_delta_transactions_applied_during_recovery
 
std::atomic< uint64m_transactions_delivered_during_recovery
 
bool send_transaction_identifiers
 
mysql_mutex_t m_transactions_waiting_apply_lock
 

Detailed Description

The pipeline collector for the local member stats.

Constructor & Destructor Documentation

◆ Pipeline_stats_member_collector()

Pipeline_stats_member_collector::Pipeline_stats_member_collector ( )

Default constructor.

◆ ~Pipeline_stats_member_collector()

Pipeline_stats_member_collector::~Pipeline_stats_member_collector ( )
virtual

Destructor.

Member Function Documentation

◆ compute_transactions_deltas_during_recovery()

void Pipeline_stats_member_collector::compute_transactions_deltas_during_recovery ( )

Compute the transactions applied during last flow-control tick while the member is in recovery.

◆ decrement_transactions_waiting_apply()

void Pipeline_stats_member_collector::decrement_transactions_waiting_apply ( )

Decrement transactions waiting apply counter value.

◆ get_delta_transactions_applied_during_recovery()

uint64 Pipeline_stats_member_collector::get_delta_transactions_applied_during_recovery ( )
Returns
transactions applied during last flow-control tick while the member is in recovery.

◆ get_transactions_applied()

int64 Pipeline_stats_member_collector::get_transactions_applied ( )
Returns
transactions applied of local member.

◆ get_transactions_certified()

int64 Pipeline_stats_member_collector::get_transactions_certified ( )
Returns
transactions certified.

◆ get_transactions_local()

int64 Pipeline_stats_member_collector::get_transactions_local ( )
Returns
local transactions proposed by member.

◆ get_transactions_local_rollback()

int64 Pipeline_stats_member_collector::get_transactions_local_rollback ( )
Returns
local transactions rollback due to Negative certification

◆ get_transactions_waiting_apply()

int32 Pipeline_stats_member_collector::get_transactions_waiting_apply ( )
Returns
transactions waiting to be applied.

◆ get_transactions_waiting_apply_during_recovery()

uint64 Pipeline_stats_member_collector::get_transactions_waiting_apply_during_recovery ( )
Returns
transactions waiting to be applied during recovery.

◆ get_transactions_waiting_certification_during_recovery()

uint64 Pipeline_stats_member_collector::get_transactions_waiting_certification_during_recovery ( )
Returns
transactions waiting to be certified during recovery.

◆ increment_transactions_applied()

void Pipeline_stats_member_collector::increment_transactions_applied ( )

Increment transactions applied counter value.

◆ increment_transactions_applied_during_recovery()

void Pipeline_stats_member_collector::increment_transactions_applied_during_recovery ( )

Increment local recovery transactions counter value.

◆ increment_transactions_certified()

void Pipeline_stats_member_collector::increment_transactions_certified ( )

Increment transactions certified counter value.

◆ increment_transactions_certified_during_recovery()

void Pipeline_stats_member_collector::increment_transactions_certified_during_recovery ( )

Increment certified transactions during recovery counter value.

◆ increment_transactions_certified_negatively_during_recovery()

void Pipeline_stats_member_collector::increment_transactions_certified_negatively_during_recovery ( )

Increment negatively certified transactions during recovery counter value.

◆ increment_transactions_delivered_during_recovery()

void Pipeline_stats_member_collector::increment_transactions_delivered_during_recovery ( )

Increment delivered transactions during recovery counter value.

◆ increment_transactions_local()

void Pipeline_stats_member_collector::increment_transactions_local ( )

Increment local transactions counter value.

◆ increment_transactions_local_rollback()

void Pipeline_stats_member_collector::increment_transactions_local_rollback ( )

Increment local rollback transactions counter value.

◆ increment_transactions_waiting_apply()

void Pipeline_stats_member_collector::increment_transactions_waiting_apply ( )

Increment transactions waiting apply counter value.

◆ send_stats_member_message()

void Pipeline_stats_member_collector::send_stats_member_message ( Flow_control_mode  mode)

Send member statistics to group.

◆ set_send_transaction_identifiers()

void Pipeline_stats_member_collector::set_send_transaction_identifiers ( )

Send Transaction Identifiers or not.

Once Transactions identifiers are sent, variable will be reset to FALSE So need to set each time Transactions identifiers needs to be transmitted

Member Data Documentation

◆ m_delta_transactions_applied_during_recovery

std::atomic<uint64> Pipeline_stats_member_collector::m_delta_transactions_applied_during_recovery
private

◆ m_previous_transactions_applied_during_recovery

uint64 Pipeline_stats_member_collector::m_previous_transactions_applied_during_recovery
private

◆ m_transactions_applied

std::atomic<int64> Pipeline_stats_member_collector::m_transactions_applied
private

◆ m_transactions_applied_during_recovery

std::atomic<uint64> Pipeline_stats_member_collector::m_transactions_applied_during_recovery
private

◆ m_transactions_certified

std::atomic<int64> Pipeline_stats_member_collector::m_transactions_certified
private

◆ m_transactions_certified_during_recovery

std::atomic<uint64> Pipeline_stats_member_collector::m_transactions_certified_during_recovery
private

◆ m_transactions_certified_negatively_during_recovery

std::atomic<uint64> Pipeline_stats_member_collector::m_transactions_certified_negatively_during_recovery
private

◆ m_transactions_delivered_during_recovery

std::atomic<uint64> Pipeline_stats_member_collector::m_transactions_delivered_during_recovery
private

◆ m_transactions_local

std::atomic<int64> Pipeline_stats_member_collector::m_transactions_local
private

◆ m_transactions_local_rollback

std::atomic<int64> Pipeline_stats_member_collector::m_transactions_local_rollback
private

◆ m_transactions_waiting_apply

std::atomic<int32> Pipeline_stats_member_collector::m_transactions_waiting_apply
private

◆ m_transactions_waiting_apply_lock

mysql_mutex_t Pipeline_stats_member_collector::m_transactions_waiting_apply_lock
private

◆ send_transaction_identifiers

bool Pipeline_stats_member_collector::send_transaction_identifiers
private

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