MySQL 8.4.3
Source Code Documentation
rpl_binlog_sender.cc File Reference
#include "sql/rpl_binlog_sender.h"
#include "mysql/binlog/event/codecs/factory.h"
#include <stdio.h>
#include <algorithm>
#include <atomic>
#include <memory>
#include <unordered_map>
#include <utility>
#include "lex_string.h"
#include "map_helpers.h"
#include "my_byteorder.h"
#include "my_compiler.h"
#include "my_dbug.h"
#include "my_pointer_arithmetic.h"
#include "my_sys.h"
#include "my_thread.h"
#include "mysql.h"
#include "mysql/binlog/event/binlog_event.h"
#include "mysql/components/services/bits/psi_stage_bits.h"
#include "mysql/components/services/log_builtins.h"
#include "mysql/my_loglevel.h"
#include "mysql/psi/mysql_file.h"
#include "mysql/psi/mysql_mutex.h"
#include "scope_guard.h"
#include "sql/binlog_reader.h"
#include "sql/debug_sync.h"
#include "sql/derror.h"
#include "sql/item_func.h"
#include "sql/log.h"
#include "sql/mdl.h"
#include "sql/mysqld.h"
#include "sql/protocol.h"
#include "sql/protocol_classic.h"
#include "sql/rpl_constants.h"
#include "sql/rpl_gtid.h"
#include "sql/rpl_handler.h"
#include "sql/rpl_reporting.h"
#include "sql/rpl_source.h"
#include "sql/sql_class.h"
#include "sql/system_variables.h"
#include "sql_string.h"
#include "string_with_len.h"
#include "typelib.h"
#include "unsafe_string_append.h"

Classes

class  Observe_transmission_guard
 Sentry class to guard the transitions for Delegate::m_observe_transmission flag within given contexts. More...
 
class  Sender_context_guard
 Sentry class that guards the Binlog_sender context and, at destruction, will prepare it for the next event to be processed. More...
 
class  Binlog_sender::Event_allocator
 Binlog_sender reads events one by one. More...
 

Functions

static std::chrono::nanoseconds now_in_nanosecs ()
 Simple function to help readability w.r.t. More...
 

Variables

static uint binlog_dump_count = 0
 
TYPELIB binlog_checksum_typelib
 
int max_binlog_dump_events
 

Function Documentation

◆ now_in_nanosecs()

static std::chrono::nanoseconds now_in_nanosecs ( )
static

Simple function to help readability w.r.t.

chrono operations.

This function SHALL return a nanoseconds duration representing the current time. It is just a convenience function to interface with std::chrono::high_resolution_clock::now().

Returns
a std::chrono::nanoseconds duration since the epoch.

Variable Documentation

◆ binlog_dump_count

uint binlog_dump_count = 0
static

◆ max_binlog_dump_events

int max_binlog_dump_events
extern