Pipeline_member_stats Class Reference

Computed statistics per member. More...

#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 commit 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 commit 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:

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