Table PERFORMANCE_SCHEMA.replication_applier_filters. More...

#include <table_replication_applier_filters.h>

Inheritance diagram for table_replication_applier_filters:

Public Member Functions
	~table_replication_applier_filters () override

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

void	reset_position () override
	Reset the cursor position to the beginning of the table. 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_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 *)

static ha_rows	get_row_count ()
	Get the table count. 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_applier_filters ()

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

Private Member Functions
void	make_row (Rpl_pfs_filter *rpl_pfs_filter)
	Make a row by an object of Rpl_pfs_filter. More...

Private Attributes
st_row_applier_filters	m_row
	Current row. More...

bool	m_row_exists
	True is the current row exists. More...

pos_t	m_pos
	Current position. More...

pos_t	m_next_pos
	Next position. More...

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

Member Typedef Documentation

◆ pos_t

typedef PFS_simple_index table_replication_applier_filters::pos_t

private

Constructor & Destructor Documentation

◆ table_replication_applier_filters()

table_replication_applier_filters::table_replication_applier_filters ( )

protected

◆ ~table_replication_applier_filters()

table_replication_applier_filters::~table_replication_applier_filters ( )

overridedefault

Member Function Documentation

◆ create()

PFS_engine_table * table_replication_applier_filters::create ( PFS_engine_table_share * )

static

◆ get_row_count()

ha_rows table_replication_applier_filters::get_row_count ( )

static

Get the table count.

Return values

return the table count.

◆ make_row()

void table_replication_applier_filters::make_row ( Rpl_pfs_filter * rpl_pfs_filter )

private

Make a row by an object of Rpl_pfs_filter.

Parameters

rpl_pfs_filter a pointer to a Rpl_pfs_filter object.

◆ read_row_values()

int table_replication_applier_filters::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.

Return values

0	if HAVE_REPLICATION is defined, else HA_ERR_RECORD_DELETED.

Implements PFS_engine_table.

◆ reset_position()

void table_replication_applier_filters::reset_position ( )

overridevirtual

Reset the cursor position to the beginning of the table.

Implements PFS_engine_table.

◆ rnd_next()

int table_replication_applier_filters::rnd_next ( )

overridevirtual

Fetch the next row in this cursor.

Return values

0	Did not reach the end of the table. HA_ERR_END_OF_FILE reached the end of the table.

Implements PFS_engine_table.

◆ rnd_pos()

int table_replication_applier_filters::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_filters::m_next_pos

private

Next position.

◆ m_pos

pos_t table_replication_applier_filters::m_pos

private

Current position.

◆ m_row

st_row_applier_filters table_replication_applier_filters::m_row

private

Current row.

◆ m_row_exists

bool table_replication_applier_filters::m_row_exists

private

True is the current row exists.

◆ m_share

PFS_engine_table_share table_replication_applier_filters::m_share

static

Initial value:

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

Table share.

◆ m_table_def

Plugin_table table_replication_applier_filters::m_table_def

staticprivate

Table definition.

◆ m_table_lock

THR_LOCK table_replication_applier_filters::m_table_lock

staticprivate

Table share lock.

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

storage/perfschema/table_replication_applier_filters.h
storage/perfschema/table_replication_applier_filters.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_filters()

◆ ~table_replication_applier_filters()

Member Function Documentation

◆ create()

◆ get_row_count()

◆ make_row()

◆ read_row_values()

◆ reset_position()

◆ rnd_next()

◆ rnd_pos()

Member Data Documentation

◆ m_next_pos

◆ m_pos

◆ m_row

◆ m_row_exists

◆ m_share

◆ m_table_def

◆ m_table_lock