rpl_binlog_sender.cc File Reference

#include "sql/rpl_binlog_sender.h"
#include "libbinlogevents/include/codecs/factory.h"
#include <stdio.h>
#include <algorithm>
#include <atomic>
#include <memory>
#include <unordered_map>
#include <utility>
#include "lex_string.h"
#include "libbinlogevents/include/binlog_event.h"
#include "m_string.h"
#include "map_helpers.h"
#include "my_byteorder.h"
#include "my_compiler.h"
#include "my_dbug.h"
#include "my_loglevel.h"
#include "my_pointer_arithmetic.h"
#include "my_sys.h"
#include "my_thread.h"
#include "mysql.h"
#include "mysql/components/services/bits/psi_stage_bits.h"
#include "mysql/components/services/log_builtins.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 "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