Table PERFORMANCE_SCHEMA.replication_applier_status_by_worker. More...

#include <table_replication_applier_status_by_worker.h>

Inheritance diagram for table_replication_applier_status_by_worker:

Public Member Functions
	~table_replication_applier_status_by_worker () override

void	reset_position () override
	Reset the cursor position to the beginning of the table. More...

int	rnd_next () override
	Fetch the next row in this cursor. More...

int	rnd_pos (const void *pos) override
	Fetch a row by position. More...

int	index_init (uint idx, bool sorted) override

int	index_next () override
	Find key in index, read record. More...

Public Member Functions inherited from PFS_engine_table
int	read_row (TABLE table, unsigned char buf, Field **fields)
	Read a table row. More...

int	update_row (TABLE table, const unsigned char old_buf, unsigned char new_buf, Field *fields)
	Update a table row. More...

int	delete_row (TABLE table, const unsigned char buf, Field **fields)
	Delete a row from this table. More...

virtual int	rnd_init (bool scan)
	Initialize table scan. More...

virtual int	index_read (KEY key_infos, uint index, const uchar key, uint key_len, enum ha_rkey_function find_flag)
	Positions an index cursor to the index specified in the handle. More...

virtual int	index_read_last (KEY key_infos, const uchar key, uint key_len)

virtual int	index_next_same (const uchar *key, uint key_len)
	Reads the next row matching the given key value. More...

virtual int	index_prev ()

virtual int	index_first ()

virtual int	index_last ()

void	get_position (void *ref)
	Get the position of the current row. More...

void	set_position (const void *ref)
	Set the table cursor at a given position. More...

virtual	~PFS_engine_table ()=default
	Destructor. More...

Static Public Member Functions
static PFS_engine_table *	create (PFS_engine_table_share *)

static ha_rows	get_row_count ()

Static Public Member Functions inherited from PFS_engine_table
static PFS_engine_table_share *	find_engine_table_share (const char *name)
	Find a table share by name. More...

Static Public Attributes
static PFS_engine_table_share	m_share
	Table share. More...

Protected Member Functions
int	read_row_values (TABLE table, unsigned char buf, Field **fields, bool read_all) override
	Read the current row values. More...

	table_replication_applier_status_by_worker ()

Protected Member Functions inherited from PFS_engine_table
virtual int	update_row_values (TABLE table, const unsigned char old_buf, unsigned char new_buf, Field *fields)
	Update the current row values. More...

virtual int	delete_row_values (TABLE table, const unsigned char buf, Field **fields)
	Delete a row. More...

	PFS_engine_table (const PFS_engine_table_share share, void pos)
	Constructor. More...

Private Types
typedef pos_replication_applier_status_by_worker	pos_t

Private Member Functions
int	make_row (Slave_worker *)

int	make_row (Master_info *)
	Function to display SQL Thread's status as part of 'replication_applier_status_by_worker' in single threaded slave mode. More...

void	populate_trx_info (Trx_monitoring_info const &applying_trx, Trx_monitoring_info const &last_applied_trx)
	Auxiliary function to populate the transaction information fields. More...

Private Attributes
st_row_worker	m_row
	current row. More...

pos_t	m_pos
	Current position. More...

pos_t	m_next_pos
	Next position. More...

PFS_index_rpl_applier_status_by_worker *	m_opened_index

Static Private Attributes
static THR_LOCK	m_table_lock
	Table share lock. More...

static Plugin_table	m_table_def
	Table definition. More...

Additional Inherited Members
Protected Attributes inherited from PFS_engine_table
const PFS_engine_table_share *	m_share_ptr
	Table share. More...

void *	m_pos_ptr
	Opaque pointer to the `m_pos` position of this cursor. More...

time_normalizer *	m_normalizer
	Current normalizer. More...

PFS_engine_index_abstract *	m_index
	Current index. More...

Detailed Description

Table PERFORMANCE_SCHEMA.replication_applier_status_by_worker.

Member Typedef Documentation

◆ pos_t

typedef pos_replication_applier_status_by_worker table_replication_applier_status_by_worker::pos_t

private

Constructor & Destructor Documentation

◆ table_replication_applier_status_by_worker()

table_replication_applier_status_by_worker::table_replication_applier_status_by_worker ( )

protected

◆ ~table_replication_applier_status_by_worker()

table_replication_applier_status_by_worker::~table_replication_applier_status_by_worker ( )

overridedefault

Member Function Documentation

◆ create()

PFS_engine_table * table_replication_applier_status_by_worker::create ( PFS_engine_table_share * )

static

◆ get_row_count()

ha_rows table_replication_applier_status_by_worker::get_row_count ( )

static

◆ index_init()

int table_replication_applier_status_by_worker::index_init	(	uint	idx,
		bool	sorted
	)

overridevirtual

Reimplemented from PFS_engine_table.

◆ index_next()

int table_replication_applier_status_by_worker::index_next ( )

overridevirtual

Find key in index, read record.

Reimplemented from PFS_engine_table.

◆ make_row() [1/2]

int table_replication_applier_status_by_worker::make_row ( Master_info * mi )

private

Function to display SQL Thread's status as part of 'replication_applier_status_by_worker' in single threaded slave mode.

Parameters

[in] mi Master_info

Returns: 0 or HA_ERR_RECORD_DELETED

if error, set error message and timestamp

time in microsecond since epoch

◆ make_row() [2/2]

int table_replication_applier_status_by_worker::make_row ( Slave_worker * w )

private

if error, set error message and timestamp

time in microsecond since epoch

◆ populate_trx_info()

void table_replication_applier_status_by_worker::populate_trx_info	(	Trx_monitoring_info const &	applying_trx,
		Trx_monitoring_info const &	last_applied_trx
	)

private

Auxiliary function to populate the transaction information fields.

Parameters

[in]	applying_trx	info on the transaction being applied
[in]	last_applied_trx	info on the last applied transaction

◆ read_row_values()

int table_replication_applier_status_by_worker::read_row_values	(	TABLE *	table,
		unsigned char *	buf,
		Field **	fields,
		bool	read_all
	)

overrideprotectedvirtual

Read the current row values.

Parameters

table	Table handle
buf	row buffer
fields	Table fields
read_all	true if all columns are read.

channel_name

Implements PFS_engine_table.

◆ reset_position()

void table_replication_applier_status_by_worker::reset_position ( )

overridevirtual

Reset the cursor position to the beginning of the table.

Implements PFS_engine_table.

◆ rnd_next()

int table_replication_applier_status_by_worker::rnd_next ( )

overridevirtual

Fetch the next row in this cursor.

Implements PFS_engine_table.

◆ rnd_pos()

int table_replication_applier_status_by_worker::rnd_pos ( const void * pos )

overridevirtual

Fetch a row by position.

Parameters

pos	position to fetch

Implements PFS_engine_table.

Member Data Documentation

◆ m_next_pos

pos_t table_replication_applier_status_by_worker::m_next_pos

private

Next position.

◆ m_opened_index

PFS_index_rpl_applier_status_by_worker* table_replication_applier_status_by_worker::m_opened_index

private

◆ m_pos

pos_t table_replication_applier_status_by_worker::m_pos

private

Current position.

◆ m_row

st_row_worker table_replication_applier_status_by_worker::m_row

private

current row.

◆ m_share

PFS_engine_table_share table_replication_applier_status_by_worker::m_share

static

Initial value:

= {
    &pfs_readonly_acl,
    table_replication_applier_status_by_worker::create,
    nullptr, 
    nullptr, 
    table_replication_applier_status_by_worker::get_row_count, 
    sizeof(pos_t),                                             
    &m_table_lock,
    &m_table_def,
    true, 
    PFS_engine_table_proxy(),
    {0},
    false 
}

Table share.

◆ m_table_def

Plugin_table table_replication_applier_status_by_worker::m_table_def

staticprivate

Table definition.

◆ m_table_lock

THR_LOCK table_replication_applier_status_by_worker::m_table_lock

staticprivate

Table share lock.

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

storage/perfschema/table_replication_applier_status_by_worker.h
storage/perfschema/table_replication_applier_status_by_worker.cc

Public Member Functions

Static Public Member Functions

Static Public Attributes

Protected Member Functions

Private Types

Private Member Functions

Private Attributes

Static Private Attributes

Additional Inherited Members

Detailed Description

Member Typedef Documentation

◆ pos_t

Constructor & Destructor Documentation

◆ table_replication_applier_status_by_worker()

◆ ~table_replication_applier_status_by_worker()

Member Function Documentation

◆ create()

◆ get_row_count()

◆ index_init()

◆ index_next()

◆ make_row() [1/2]

◆ make_row() [2/2]

◆ populate_trx_info()

◆ read_row_values()

◆ reset_position()

◆ rnd_next()

◆ rnd_pos()

Member Data Documentation

◆ m_next_pos

◆ m_opened_index

◆ m_pos

◆ m_row

◆ m_share

◆ m_table_def

◆ m_table_lock