Table PERFORMANCE_SCHEMA.TABLE_REPLICATION_ASYNCHRONOUS_CONNECTION_FAILOVER. More...

#include <table_replication_asynchronous_connection_failover.h>

Inheritance diagram for table_replication_asynchronous_connection_failover:

Public Member Functions
	~table_replication_asynchronous_connection_failover () override

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

int	rnd_init (bool scan) override
	Initialize table for random read or scan. More...

int	rnd_next () override
	Read next row via random scan. More...

int	rnd_pos (const void *pos) override
	Read row via random scan from position. 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	index_init (uint idx, bool sorted)

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 ()
	Find key in index, read record. More...

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 *tbs)
	Open table function. More...

static ha_rows	get_row_count ()
	Get the current number of rows read. More...

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_asynchronous_connection_failover ()

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 PFS_simple_index	pos_t
	Position of a cursor, for simple iterations. More...

Private Member Functions
int	make_row (uint index)
	Stores current row (i.e.index) values for the table into m_row struct members. More...

Private Attributes
st_row_rpl_async_conn_failover	m_row
	Current row. More...

pos_t	m_pos
	Current position. More...

pos_t	m_next_pos
	Next position. More...

RPL_FAILOVER_SOURCE_LIST	m_source_conn_detail {}

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

static Plugin_table	m_table_def
	Table definition. More...

static ha_rows	num_rows = 0

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.TABLE_REPLICATION_ASYNCHRONOUS_CONNECTION_FAILOVER.

Member Typedef Documentation

◆ pos_t

typedef PFS_simple_index table_replication_asynchronous_connection_failover::pos_t

private

Position of a cursor, for simple iterations.

Constructor & Destructor Documentation

◆ table_replication_asynchronous_connection_failover()

table_replication_asynchronous_connection_failover::table_replication_asynchronous_connection_failover ( )

protected

◆ ~table_replication_asynchronous_connection_failover()

table_replication_asynchronous_connection_failover::~table_replication_asynchronous_connection_failover ( )

overridedefault

Member Function Documentation

◆ create()

PFS_engine_table * table_replication_asynchronous_connection_failover::create ( PFS_engine_table_share * tbs )

static

Open table function.

Parameters

[in] tbs Table share object

◆ get_row_count()

ha_rows table_replication_asynchronous_connection_failover::get_row_count ( )

static

Get the current number of rows read.

Returns: number of rows read.

◆ make_row()

int table_replication_asynchronous_connection_failover::make_row ( uint index )

private

Stores current row (i.e.index) values for the table into m_row struct members.

This stored data is read later through read_row_values().

Parameters

[in] index current row position.

Returns: Operation status

Return values

0	Success
!=	0 Error (error code returned)

◆ read_row_values()

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

overrideprotectedvirtual

Read the current row values.

Parameters

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

channel_name

host

port

network_namespace

weight

managed_name

Implements PFS_engine_table.

◆ reset_position()

void table_replication_asynchronous_connection_failover::reset_position ( )

overridevirtual

Reset the cursor position to the beginning of the table.

Implements PFS_engine_table.

◆ rnd_init()

int table_replication_asynchronous_connection_failover::rnd_init ( bool scan )

overridevirtual

Initialize table for random read or scan.

Parameters

[in] scan if true: Initialize for random scans through rnd_next() if false: Initialize for random reads through rnd_pos()

Returns: Operation status

Return values

0	Success
!=	0 Error (error code returned)

Reimplemented from PFS_engine_table.

◆ rnd_next()

int table_replication_asynchronous_connection_failover::rnd_next ( )

overridevirtual

◆ rnd_pos()

int table_replication_asynchronous_connection_failover::rnd_pos ( const void * pos )

overridevirtual

Read row via random scan from position.

Parameters

[in] pos Position from position() call

Returns: Operation status

Return values

0	Success
!=	0 Error (error code returned)

Implements PFS_engine_table.

Member Data Documentation

◆ m_next_pos

pos_t table_replication_asynchronous_connection_failover::m_next_pos

private

Next position.

◆ m_pos

pos_t table_replication_asynchronous_connection_failover::m_pos

private

Current position.

◆ m_row

st_row_rpl_async_conn_failover table_replication_asynchronous_connection_failover::m_row

private

Current row.

◆ m_share

PFS_engine_table_share table_replication_asynchronous_connection_failover::m_share

static

Initial value:

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

Table share.

◆ m_source_conn_detail

RPL_FAILOVER_SOURCE_LIST table_replication_asynchronous_connection_failover::m_source_conn_detail {}

private

◆ m_table_def

Plugin_table table_replication_asynchronous_connection_failover::m_table_def

staticprivate

Table definition.

◆ m_table_lock

THR_LOCK table_replication_asynchronous_connection_failover::m_table_lock

staticprivate

Table share lock.

◆ num_rows

ha_rows table_replication_asynchronous_connection_failover::num_rows = 0

staticprivate

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

storage/perfschema/table_replication_asynchronous_connection_failover.h
storage/perfschema/table_replication_asynchronous_connection_failover.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_asynchronous_connection_failover()

◆ ~table_replication_asynchronous_connection_failover()

Member Function Documentation

◆ create()

◆ get_row_count()

◆ make_row()

◆ read_row_values()

◆ reset_position()

◆ rnd_init()

◆ rnd_next()

◆ rnd_pos()

Member Data Documentation

◆ m_next_pos

◆ m_pos

◆ m_row

◆ m_share

◆ m_source_conn_detail

◆ m_table_def

◆ m_table_lock

◆ num_rows