MySQL  8.0.18
Source Code Documentation
Binlog_relay_IO_delegate Class Reference

#include <rpl_handler.h>

Inheritance diagram for Binlog_relay_IO_delegate:
Delegate

Public Types

typedef Binlog_relay_IO_observer Observer
 
- Public Types inherited from Delegate
typedef List< Observer_infoObserver_info_list
 
typedef List_iterator< Observer_infoObserver_info_iterator
 

Public Member Functions

 Binlog_relay_IO_delegate ()
 
int thread_start (THD *thd, Master_info *mi)
 
int thread_stop (THD *thd, Master_info *mi)
 
int applier_start (THD *thd, Master_info *mi)
 
int applier_stop (THD *thd, Master_info *mi, bool aborted)
 
int before_request_transmit (THD *thd, Master_info *mi, ushort flags)
 
int after_read_event (THD *thd, Master_info *mi, const char *packet, ulong len, const char **event_buf, ulong *event_len)
 
int after_queue_event (THD *thd, Master_info *mi, const char *event_buf, ulong event_len, bool synced)
 
int after_reset_slave (THD *thd, Master_info *mi)
 
int applier_log_event (THD *thd, int &out)
 
- Public Member Functions inherited from Delegate
int add_observer (void *observer, st_plugin_int *plugin)
 
int remove_observer (void *observer)
 
Observer_info_iterator observer_info_iter ()
 
bool is_empty ()
 
int read_lock ()
 
int write_lock ()
 
int unlock ()
 
bool is_inited ()
 
 Delegate (PSI_rwlock_key key)
 
 ~Delegate ()
 

Private Member Functions

void init_param (Binlog_relay_IO_param *param, Master_info *mi)
 

Member Typedef Documentation

◆ Observer

Constructor & Destructor Documentation

◆ Binlog_relay_IO_delegate()

Binlog_relay_IO_delegate::Binlog_relay_IO_delegate ( )
inline

Member Function Documentation

◆ after_queue_event()

int Binlog_relay_IO_delegate::after_queue_event ( THD thd,
Master_info mi,
const char *  event_buf,
ulong  event_len,
bool  synced 
)

◆ after_read_event()

int Binlog_relay_IO_delegate::after_read_event ( THD thd,
Master_info mi,
const char *  packet,
ulong  len,
const char **  event_buf,
ulong event_len 
)

◆ after_reset_slave()

int Binlog_relay_IO_delegate::after_reset_slave ( THD thd,
Master_info mi 
)

◆ applier_log_event()

int Binlog_relay_IO_delegate::applier_log_event ( THD thd,
int &  out 
)

◆ applier_start()

int Binlog_relay_IO_delegate::applier_start ( THD thd,
Master_info mi 
)

◆ applier_stop()

int Binlog_relay_IO_delegate::applier_stop ( THD thd,
Master_info mi,
bool  aborted 
)

◆ before_request_transmit()

int Binlog_relay_IO_delegate::before_request_transmit ( THD thd,
Master_info mi,
ushort  flags 
)

◆ init_param()

void Binlog_relay_IO_delegate::init_param ( Binlog_relay_IO_param param,
Master_info mi 
)
private

◆ thread_start()

int Binlog_relay_IO_delegate::thread_start ( THD thd,
Master_info mi 
)

◆ thread_stop()

int Binlog_relay_IO_delegate::thread_stop ( THD thd,
Master_info mi 
)

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