40#define CHANNEL_NAME_LENGTH NAME_LEN
69#ifdef HAVE_PSI_INTERFACE
113 return (
handler->update_is_transactional());
117 return (
handler->get_description_info());
181 uint param_id,
const char *param_channel);
Definition: rpl_info_handler.h:57
Definition: rpl_info.h:42
PSI_mutex_key * key_info_sleep_cond
Definition: rpl_info.h:74
virtual bool set_info_search_keys(Rpl_info_handler *to)=0
To search in the slave repositories, each slave info object (mi, rli or worker) should use a primary ...
char * get_description_info() const
Definition: rpl_info.h:116
Rpl_info_handler * handler
Pointer to the repository's handler.
Definition: rpl_info.h:148
Rpl_info(const char *type, PSI_mutex_key *param_key_info_run_lock, PSI_mutex_key *param_key_info_data_lock, PSI_mutex_key *param_key_info_sleep_lock, PSI_mutex_key *param_key_info_thd_lock, PSI_mutex_key *param_key_info_data_cond, PSI_mutex_key *param_key_info_start_cond, PSI_mutex_key *param_key_info_stop_cond, PSI_mutex_key *param_key_info_sleep_cond, uint param_id, const char *param_channel)
Definition: rpl_info.cc:30
~Rpl_info() override
Definition: rpl_info.cc:87
Rpl_info & operator=(const Rpl_info &info)
std::atomic< bool > abort_slave
Definition: rpl_info.h:80
void set_rpl_info_handler(Rpl_info_handler *param_handler)
Sets the persistency component/handler.
Definition: rpl_info.h:93
PSI_mutex_key * key_info_sleep_lock
Definition: rpl_info.h:70
uint internal_id
Uniquely and internally identifies an info entry (.e.g.
Definition: rpl_info.h:162
virtual bool read_info(Rpl_info_handler *from)=0
bool inited
Definition: rpl_info.h:79
mysql_cond_t sleep_cond
Definition: rpl_info.h:67
mysql_mutex_t info_thd_lock
Definition: rpl_info.h:57
char * get_channel() const
Definition: rpl_info.h:128
bool copy_info(Rpl_info_handler *from, Rpl_info_handler *to)
Definition: rpl_info.h:120
mysql_cond_t start_cond
Definition: rpl_info.h:67
std::atomic< bool > atomic_is_stopping
Definition: rpl_info.h:192
int remove_info()
Definition: rpl_info.h:106
PSI_mutex_key * key_info_run_lock
Definition: rpl_info.h:70
std::atomic< ulong > slave_run_id
Definition: rpl_info.h:82
Rpl_info(const Rpl_info &info)
PSI_mutex_key * key_info_stop_cond
Definition: rpl_info.h:73
Rpl_info_handler * get_rpl_info_handler()
Gets the persistency component/handler.
Definition: rpl_info.h:102
mysql_mutex_t sleep_lock
Definition: rpl_info.h:57
bool update_is_transactional()
Definition: rpl_info.h:112
mysql_cond_t data_cond
Definition: rpl_info.h:67
PSI_mutex_key * key_info_start_cond
Definition: rpl_info.h:73
mysql_mutex_t run_lock
Definition: rpl_info.h:57
uint get_internal_id() const
Definition: rpl_info.h:126
mysql_mutex_t data_lock
Definition: rpl_info.h:57
bool is_transactional() const
Definition: rpl_info.h:110
mysql_cond_t stop_cond
Definition: rpl_info.h:67
PSI_mutex_key * key_info_data_lock
Definition: rpl_info.h:70
PSI_mutex_key * key_info_thd_lock
Definition: rpl_info.h:71
char channel[CHANNEL_NAME_LENGTH+1]
Every slave info object acts on a particular channel in Multisource Replication.
Definition: rpl_info.h:168
PSI_mutex_key * key_info_data_cond
Definition: rpl_info.h:73
std::atomic< uint > slave_running
Definition: rpl_info.h:81
int events_until_exit
Definition: rpl_info.h:85
THD * info_thd
Definition: rpl_info.h:77
int clean_info()
Definition: rpl_info.h:108
enum_return_check check_info() const
Definition: rpl_info.h:104
virtual bool write_info(Rpl_info_handler *to)=0
Mix-in to handle the message logging and reporting for relay log info and master log info structures.
Definition: rpl_reporting.h:52
For each client connection we create a separate thread with THD serving as a thread/connection descri...
Definition: sql_lexer_thd.h:33
The handler class is the interface for dynamically loadable storage engines.
Definition: handler.h:4460
unsigned int PSI_mutex_key
Instrumented mutex key.
Definition: psi_mutex_bits.h:51
Some integer typedefs for easier portability.
Defines various enable/disable and HAVE_ macros related to the performance schema instrumentation sys...
#define HAVE_PSI_INTERFACE
Definition: my_psi_config.h:38
Common definition between mysql server & client.
Instrumentation helpers for conditions.
ABI for instrumented mutexes.
Instrumentation helpers for mutexes.
required string type
Definition: replication_group_member_actions.proto:33
#define CHANNEL_NAME_LENGTH
Definition: rpl_info.h:40
enum_return_check
Definition: rpl_info_handler.h:50
An instrumented cond structure.
Definition: mysql_cond_bits.h:49
An instrumented mutex structure.
Definition: mysql_mutex_bits.h:49