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	clear_transactions_waiting_apply ()
	Set transactions waiting apply counter to 0. 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< int32 >	m_transactions_waiting_apply
std::atomic< int64 >	m_transactions_certified
std::atomic< int64 >	m_transactions_applied
std::atomic< int64 >	m_transactions_local
std::atomic< int64 >	m_transactions_local_rollback
std::atomic< uint64 >	m_transactions_certified_during_recovery
std::atomic< uint64 >	m_transactions_certified_negatively_during_recovery
std::atomic< uint64 >	m_transactions_applied_during_recovery
uint64	m_previous_transactions_applied_during_recovery
std::atomic< uint64 >	m_delta_transactions_applied_during_recovery
std::atomic< uint64 >	m_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

clear_transactions_waiting_apply()

void Pipeline_stats_member_collector::clear_transactions_waiting_apply

(

)

Set transactions waiting apply counter to 0.

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:

• plugin/group_replication/include/pipeline_stats.h
• plugin/group_replication/src/pipeline_stats.cc