24#ifndef TABLE_REPLICATION_ASYNCHRONOUS_CONNECTION_FAILOVER_H
25#define TABLE_REPLICATION_ASYNCHRONOUS_CONNECTION_FAILOVER_H
118 bool read_all)
override;
175 int rnd_pos(
const void *pos)
override;
An abstract PERFORMANCE_SCHEMA table.
Definition: pfs_engine_table.h:69
Class to hold information regarding a table to be created on behalf of a plugin.
Definition: plugin_table.h:39
Table PERFORMANCE_SCHEMA.TABLE_REPLICATION_ASYNCHRONOUS_CONNECTION_FAILOVER.
Definition: table_replication_asynchronous_connection_failover.h:76
~table_replication_asynchronous_connection_failover() override
pos_t m_pos
Current position.
Definition: table_replication_asynchronous_connection_failover.h:103
static ha_rows num_rows
Definition: table_replication_asynchronous_connection_failover.h:182
PFS_simple_index pos_t
Position of a cursor, for simple iterations.
Definition: table_replication_asynchronous_connection_failover.h:78
RPL_FAILOVER_SOURCE_LIST m_source_conn_detail
Definition: table_replication_asynchronous_connection_failover.h:179
static THR_LOCK m_table_lock
Table share lock.
Definition: table_replication_asynchronous_connection_failover.h:94
int rnd_init(bool scan) override
Initialize table for random read or scan.
Definition: table_replication_asynchronous_connection_failover.cc:124
static PFS_engine_table_share m_share
Table share.
Definition: table_replication_asynchronous_connection_failover.h:126
int rnd_pos(const void *pos) override
Read row via random scan from position.
Definition: table_replication_asynchronous_connection_failover.cc:153
static Plugin_table m_table_def
Table definition.
Definition: table_replication_asynchronous_connection_failover.h:97
int make_row(uint index)
Stores current row (i.e.index) values for the table into m_row struct members.
Definition: table_replication_asynchronous_connection_failover.cc:166
static ha_rows get_row_count()
Get the current number of rows read.
Definition: table_replication_asynchronous_connection_failover.cc:119
int rnd_next() override
Read next row via random scan.
Definition: table_replication_asynchronous_connection_failover.cc:141
int read_row_values(TABLE *table, unsigned char *buf, Field **fields, bool read_all) override
Read the current row values.
Definition: table_replication_asynchronous_connection_failover.cc:218
static PFS_engine_table * create(PFS_engine_table_share *tbs)
Open table function.
Definition: table_replication_asynchronous_connection_failover.cc:99
table_replication_asynchronous_connection_failover()
Definition: table_replication_asynchronous_connection_failover.cc:105
pos_t m_next_pos
Next position.
Definition: table_replication_asynchronous_connection_failover.h:106
void reset_position() override
Reset the cursor position to the beginning of the table.
Definition: table_replication_asynchronous_connection_failover.cc:111
st_row_rpl_async_conn_failover m_row
Current row.
Definition: table_replication_asynchronous_connection_failover.h:100
This file includes constants used by all storage engines.
my_off_t ha_rows
Definition: my_base.h:1139
static constexpr int HOSTNAME_LENGTH
Definition: my_hostname.h:42
Common #defines and includes for file and socket I/O.
Common definition between mysql server & client.
#define NAME_LEN
Definition: mysql_com.h:66
static PFS_engine_table_share_proxy table
Definition: pfs.cc:60
Definition: buf0block_hint.cc:29
Performance schema tables (declarations).
std::vector< RPL_FAILOVER_SOURCE_TUPLE > RPL_FAILOVER_SOURCE_LIST
Definition: rpl_async_conn_failover_table_operations.h:52
#define CHANNEL_NAME_LENGTH
Definition: rpl_info.h:40
A PERFORMANCE_SCHEMA table share.
Definition: pfs_engine_table.h:357
Position of a cursor, for simple iterations.
Definition: pfs_engine_table.h:557
Definition: thr_lock.h:138
A row in the table.
Definition: table_replication_asynchronous_connection_failover.h:58
char managed_name[HOSTNAME_LENGTH]
Definition: table_replication_asynchronous_connection_failover.h:67
uint weight
Definition: table_replication_asynchronous_connection_failover.h:66
char network_namespace[NAME_LEN]
Definition: table_replication_asynchronous_connection_failover.h:64
char channel_name[CHANNEL_NAME_LENGTH]
Definition: table_replication_asynchronous_connection_failover.h:59
uint host_length
Definition: table_replication_asynchronous_connection_failover.h:62
uint channel_name_length
Definition: table_replication_asynchronous_connection_failover.h:60
long port
Definition: table_replication_asynchronous_connection_failover.h:63
uint network_namespace_length
Definition: table_replication_asynchronous_connection_failover.h:65
uint managed_name_length
Definition: table_replication_asynchronous_connection_failover.h:68
char host[HOSTNAME_LENGTH]
Definition: table_replication_asynchronous_connection_failover.h:61
Helpers to implement a performance schema table.