after_send_hook(const char *log_file, my_off_t log_pos) | Binlog_sender | inlineprivate |
before_send_hook(const char *log_file, my_off_t log_pos) | Binlog_sender | inlineprivate |
Binlog_sender(THD *thd, const char *start_file, my_off_t start_pos, Gtid_set *exclude_gtids, uint32 flag) | Binlog_sender | |
calc_event_checksum(uchar *event_ptr, size_t event_len) | Binlog_sender | inlineprivate |
calc_grow_buffer_size(size_t current_size, size_t min_size) | Binlog_sender | inlineprivate |
calc_shrink_buffer_size(size_t current_size) | Binlog_sender | private |
check_event_count() | Binlog_sender | inlineprivate |
check_event_type(binary_log::Log_event_type type, const char *log_file, my_off_t log_pos) | Binlog_sender | private |
check_start_file() | Binlog_sender | private |
cleanup() | Binlog_sender | private |
event_checksum_on() | Binlog_sender | inlineprivate |
fake_rotate_event(const char *next_log_file, my_off_t log_pos) | Binlog_sender | private |
File_reader typedef | Binlog_sender | private |
flush_net() | Binlog_sender | inlineprivate |
get_binlog_end_pos(File_reader &reader) | Binlog_sender | private |
grow_packet(size_t extra_size) | Binlog_sender | inlineprivate |
has_error() | Binlog_sender | inlineprivate |
has_previous_gtid_log_event(File_reader &reader, bool *found) | Binlog_sender | private |
init() | Binlog_sender | private |
init_checksum_alg() | Binlog_sender | private |
init_heartbeat_period() | Binlog_sender | private |
is_fatal_error() | Binlog_sender | inlineprivate |
log_read_error_msg(Binlog_read_error::Error_type error) | Binlog_sender | private |
m_check_previous_gtid_event | Binlog_sender | private |
m_diag_area | Binlog_sender | private |
m_errmsg | Binlog_sender | private |
m_errmsg_buf | Binlog_sender | private |
m_errno | Binlog_sender | private |
m_event_checksum_alg | Binlog_sender | private |
m_event_count | Binlog_sender | private |
m_exclude_gtid | Binlog_sender | private |
m_flag | Binlog_sender | private |
m_gtid_clear_fd_created_flag | Binlog_sender | private |
m_half_buffer_size_req_counter | Binlog_sender | private |
m_heartbeat_period | Binlog_sender | private |
m_last_event_sent_ts | Binlog_sender | private |
m_last_file | Binlog_sender | private |
m_last_file_buf | Binlog_sender | private |
m_last_pos | Binlog_sender | private |
m_linfo | Binlog_sender | private |
m_new_shrink_size | Binlog_sender | private |
m_observe_transmission | Binlog_sender | private |
m_packet | Binlog_sender | private |
m_prev_event_type | Binlog_sender | private |
m_slave_checksum_alg | Binlog_sender | private |
m_start_file | Binlog_sender | private |
m_start_pos | Binlog_sender | private |
m_thd | Binlog_sender | private |
m_transmit_started | Binlog_sender | private |
m_using_gtid_protocol | Binlog_sender | private |
m_wait_new_events | Binlog_sender | private |
PACKET_GROW_FACTOR | Binlog_sender | privatestatic |
PACKET_MAX_SIZE | Binlog_sender | privatestatic |
PACKET_MIN_SIZE | Binlog_sender | privatestatic |
PACKET_SHRINK_COUNTER_THRESHOLD | Binlog_sender | privatestatic |
PACKET_SHRINK_FACTOR | Binlog_sender | privatestatic |
read_event(File_reader &reader, uchar **event_ptr, uint32 *event_len) | Binlog_sender | inlineprivate |
reset_transmit_packet(ushort flags, size_t event_len=0) | Binlog_sender | inlineprivate |
run() | Binlog_sender | |
send_binlog(File_reader &reader, my_off_t start_pos) | Binlog_sender | private |
send_events(File_reader &reader, my_off_t end_pos) | Binlog_sender | private |
send_format_description_event(File_reader &reader, my_off_t start_pos) | Binlog_sender | private |
send_heartbeat_event(my_off_t log_pos) | Binlog_sender | private |
send_heartbeat_event_v1(my_off_t log_pos) | Binlog_sender | private |
send_heartbeat_event_v2(my_off_t log_pos) | Binlog_sender | private |
send_packet() | Binlog_sender | inlineprivate |
send_packet_and_flush() | Binlog_sender | inlineprivate |
set_error(int errorno, const char *errmsg) | Binlog_sender | inlineprivate |
set_fatal_error(const char *errmsg) | Binlog_sender | inlineprivate |
set_last_file(const char *log_file) | Binlog_sender | inlineprivate |
set_last_pos(my_off_t log_pos) | Binlog_sender | inlineprivate |
set_prev_event_type(binary_log::Log_event_type type) | Binlog_sender | inline |
set_unknown_error(const char *errmsg) | Binlog_sender | inlineprivate |
shrink_packet() | Binlog_sender | inlineprivate |
skip_event(const uchar *event_ptr, bool in_exclude_group) | Binlog_sender | inlineprivate |
stop_waiting_for_update(my_off_t log_pos) const | Binlog_sender | private |
wait_new_events(my_off_t log_pos) | Binlog_sender | private |
wait_with_heartbeat(my_off_t log_pos) | Binlog_sender | inlineprivate |
wait_without_heartbeat(my_off_t log_pos) | Binlog_sender | inlineprivate |
~Binlog_sender()=default | Binlog_sender | |