#include <assert.h>
#include <mysql/components/my_service.h>
#include <mysql/components/services/log_builtins.h>
#include <mysql/group_replication_priv.h>
#include <mysql/plugin.h>
#include <mysql/service_rpl_transaction_ctx.h>
#include <mysqld_error.h>
#include <sys/types.h>
#include "plugin/replication_observers_example/gr_message_service_example.h"
#include "plugin/replication_observers_example/src/binlog/service/iterator/tests/pfs.h"
#include "plugin/replication_observers_example/src/binlog/service/iterator/tests/status_vars.h"
#include <mysql/components/services/ongoing_transaction_query_service.h>
#include "my_dbug.h"
#include "my_inttypes.h"
#include "sql/current_thd.h"
#include "sql/sql_class.h"
#include "string_with_len.h"

Typedefs
typedef enum enum_before_commit_test_cases	before_commit_test_cases

Enumerations
enum	enum_before_commit_test_cases { NEGATIVE_CERTIFICATION , POSITIVE_CERTIFICATION_WITH_GTID , POSITIVE_CERTIFICATION_WITHOUT_GTID , INVALID_CERTIFICATION_OUTCOME }

Functions
int	validate_plugin_server_requirements (Trans_param *param)

int	test_channel_service_interface_initialization ()

int	test_channel_service_interface ()

int	test_channel_service_interface_io_thread ()

bool	test_channel_service_interface_is_io_stopping ()

bool	test_channel_service_interface_is_sql_stopping ()

bool	test_channel_service_interface_relay_log_renamed ()

bool	test_server_count_transactions ()

static void	dump_server_state_calls ()

static int	before_handle_connection (Server_state_param *)

static int	before_recovery (Server_state_param *)

static int	after_engine_recovery (Server_state_param *)

static int	after_recovery (Server_state_param *)

static int	before_server_shutdown (Server_state_param *)

static int	after_server_shutdown (Server_state_param *)

static int	after_dd_upgrade (Server_state_param *)

static void	dump_transaction_calls ()

static int	trans_before_dml (Trans_param *, int &out_val)

static int	before_commit_tests (Trans_param *param, before_commit_test_cases test_case)

static int	trans_before_commit (Trans_param *param)

static int	trans_before_rollback (Trans_param *)

static int	trans_after_commit (Trans_param *)

static int	trans_after_rollback (Trans_param *param)

static int	trans_begin (Trans_param *param, int &out_val)

static void	dump_binlog_relay_calls ()

static int	binlog_relay_thread_start (Binlog_relay_IO_param *)

static int	binlog_relay_thread_stop (Binlog_relay_IO_param *)

int	binlog_relay_applier_start (Binlog_relay_IO_param *)

static int	binlog_relay_applier_stop (Binlog_relay_IO_param *, bool aborted)

static int	binlog_relay_before_request_transmit (Binlog_relay_IO_param *, uint32)

static int	binlog_relay_after_read_event (Binlog_relay_IO_param , const char , unsigned long, const char *, unsigned long )

static int	binlog_relay_after_queue_event (Binlog_relay_IO_param , const char , unsigned long, uint32)

static int	binlog_relay_after_reset_slave (Binlog_relay_IO_param *)

static int	binlog_relay_applier_log_event (Binlog_relay_IO_param , Trans_param , int &)

static int	replication_observers_example_plugin_init (MYSQL_PLUGIN plugin_info)

static int	replication_observers_example_plugin_deinit (void *p)

	mysql_declare_plugin (replication_observers_example)

Variables
static MYSQL_PLUGIN	plugin_info_ptr

static const mysql_service_registry_t *	reg_srv = nullptr

const mysql_service_log_builtins_t *	log_bi = nullptr
	accessor built-ins More...

const mysql_service_log_builtins_string_t *	log_bs = nullptr
	string built-ins More...

static int	before_handle_connection_call = 0

static int	before_recovery_call = 0

static int	after_engine_recovery_call = 0

static int	after_recovery_call = 0

static int	before_server_shutdown_call = 0

static int	after_server_shutdown_call = 0

static int	after_dd_upgrade_call = 0

static bool	thread_aborted = false

Server_state_observer	server_state_observer

static int	trans_before_dml_call = 0

static int	trans_before_commit_call = 0

static int	trans_before_rollback_call = 0

static int	trans_after_commit_call = 0

static int	trans_after_rollback_call = 0

static int	trans_begin_call = 0

Trans_observer	trans_observer

static int	binlog_relay_thread_start_call = 0

static int	binlog_relay_thread_stop_call = 0

static int	binlog_relay_applier_start_call = 0

static int	binlog_relay_applier_stop_call = 0

static int	binlog_relay_before_request_transmit_call = 0

static int	binlog_relay_after_read_event_call = 0

static int	binlog_relay_after_queue_event_call = 0

static int	binlog_relay_after_reset_slave_call = 0

Binlog_relay_IO_observer	relay_io_observer

struct Mysql_replication	replication_observers_example_plugin

	mysql_declare_plugin_end

Typedef Documentation

◆ before_commit_test_cases

typedef enum enum_before_commit_test_cases before_commit_test_cases

Enumeration Type Documentation

◆ enum_before_commit_test_cases

enum enum_before_commit_test_cases

Enumerator
NEGATIVE_CERTIFICATION
POSITIVE_CERTIFICATION_WITH_GTID
POSITIVE_CERTIFICATION_WITHOUT_GTID
INVALID_CERTIFICATION_OUTCOME

Function Documentation

◆ after_dd_upgrade()

static int after_dd_upgrade ( Server_state_param * )

static

◆ after_engine_recovery()

static int after_engine_recovery ( Server_state_param * )

static

◆ after_recovery()

static int after_recovery ( Server_state_param * )

static

◆ after_server_shutdown()

static int after_server_shutdown ( Server_state_param * )

static

◆ before_commit_tests()

static int before_commit_tests	(	Trans_param *	param,
		before_commit_test_cases	test_case
	)

static

◆ before_handle_connection()

static int before_handle_connection ( Server_state_param * )

static

◆ before_recovery()

static int before_recovery ( Server_state_param * )

static

◆ before_server_shutdown()

static int before_server_shutdown ( Server_state_param * )

static

◆ binlog_relay_after_queue_event()

static int binlog_relay_after_queue_event	(	Binlog_relay_IO_param *	,
		const char *	,
		unsigned long	,
		uint32
	)

static

◆ binlog_relay_after_read_event()

static int binlog_relay_after_read_event	(	Binlog_relay_IO_param *	,
		const char *	,
		unsigned long	,
		const char **	,
		unsigned long *
	)

static

◆ binlog_relay_after_reset_slave()

static int binlog_relay_after_reset_slave ( Binlog_relay_IO_param * )

static

◆ binlog_relay_applier_log_event()

static int binlog_relay_applier_log_event	(	Binlog_relay_IO_param *	,
		Trans_param *	,
		int &
	)

static

◆ binlog_relay_applier_start()

int binlog_relay_applier_start ( Binlog_relay_IO_param * )

◆ binlog_relay_applier_stop()

static int binlog_relay_applier_stop	(	Binlog_relay_IO_param *	,
		bool	aborted
	)

static

◆ binlog_relay_before_request_transmit()

static int binlog_relay_before_request_transmit	(	Binlog_relay_IO_param *	,
		uint32
	)

static

◆ binlog_relay_thread_start()

static int binlog_relay_thread_start ( Binlog_relay_IO_param * )

static

◆ binlog_relay_thread_stop()

static int binlog_relay_thread_stop ( Binlog_relay_IO_param * )

static

◆ dump_binlog_relay_calls()

static void dump_binlog_relay_calls ( )

static

◆ dump_server_state_calls()

static void dump_server_state_calls ( )

static

◆ dump_transaction_calls()

static void dump_transaction_calls ( )

static

◆ mysql_declare_plugin()

mysql_declare_plugin ( replication_observers_example )

◆ replication_observers_example_plugin_deinit()

static int replication_observers_example_plugin_deinit ( void * p )

static

◆ replication_observers_example_plugin_init()

static int replication_observers_example_plugin_init ( MYSQL_PLUGIN plugin_info )

static

◆ test_channel_service_interface()

int test_channel_service_interface ( )

◆ test_channel_service_interface_initialization()

int test_channel_service_interface_initialization ( )

◆ test_channel_service_interface_io_thread()

int test_channel_service_interface_io_thread ( )

◆ test_channel_service_interface_is_io_stopping()

bool test_channel_service_interface_is_io_stopping ( )

◆ test_channel_service_interface_is_sql_stopping()

bool test_channel_service_interface_is_sql_stopping ( )

◆ test_channel_service_interface_relay_log_renamed()

bool test_channel_service_interface_relay_log_renamed ( )

◆ test_server_count_transactions()

bool test_server_count_transactions ( )

◆ trans_after_commit()

static int trans_after_commit ( Trans_param * )

static

◆ trans_after_rollback()

static int trans_after_rollback ( Trans_param * param )

static

◆ trans_before_commit()

static int trans_before_commit ( Trans_param * param )

static

◆ trans_before_dml()

static int trans_before_dml	(	Trans_param *	,
		int &	out_val
	)

static

◆ trans_before_rollback()

static int trans_before_rollback ( Trans_param * )

static

◆ trans_begin()

static int trans_begin	(	Trans_param *	param,
		int &	out_val
	)

static

◆ validate_plugin_server_requirements()

int validate_plugin_server_requirements ( Trans_param * param )

Variable Documentation

◆ after_dd_upgrade_call

int after_dd_upgrade_call = 0

static

◆ after_engine_recovery_call

int after_engine_recovery_call = 0

static

◆ after_recovery_call

int after_recovery_call = 0

static

◆ after_server_shutdown_call

int after_server_shutdown_call = 0

static

◆ before_handle_connection_call

int before_handle_connection_call = 0

static

◆ before_recovery_call

int before_recovery_call = 0

static

◆ before_server_shutdown_call

int before_server_shutdown_call = 0

static

◆ binlog_relay_after_queue_event_call

int binlog_relay_after_queue_event_call = 0

static

◆ binlog_relay_after_read_event_call

int binlog_relay_after_read_event_call = 0

static

◆ binlog_relay_after_reset_slave_call

int binlog_relay_after_reset_slave_call = 0

static

◆ binlog_relay_applier_start_call

int binlog_relay_applier_start_call = 0

static

◆ binlog_relay_applier_stop_call

int binlog_relay_applier_stop_call = 0

static

◆ binlog_relay_before_request_transmit_call

int binlog_relay_before_request_transmit_call = 0

static

◆ binlog_relay_thread_start_call

int binlog_relay_thread_start_call = 0

static

◆ binlog_relay_thread_stop_call

int binlog_relay_thread_stop_call = 0

static

◆ log_bi

const mysql_service_log_builtins_t* log_bi = nullptr

accessor built-ins

◆ log_bs

const mysql_service_log_builtins_string_t* log_bs = nullptr

string built-ins

◆ mysql_declare_plugin_end

mysql_declare_plugin_end

◆ plugin_info_ptr

MYSQL_PLUGIN plugin_info_ptr

static

◆ reg_srv

const mysql_service_registry_t* reg_srv = nullptr

static

◆ relay_io_observer

Binlog_relay_IO_observer relay_io_observer

Initial value:

= {
    sizeof(Binlog_relay_IO_observer),
 
    binlog_relay_thread_start,
    binlog_relay_thread_stop,
    binlog_relay_applier_start,
    binlog_relay_applier_stop,
    binlog_relay_before_request_transmit,
    binlog_relay_after_read_event,
    binlog_relay_after_queue_event,
    binlog_relay_after_reset_slave,
    binlog_relay_applier_log_event}

◆ replication_observers_example_plugin

struct Mysql_replication replication_observers_example_plugin

Initial value:

= {

MYSQL_REPLICATION_INTERFACE_VERSION}

MYSQL_REPLICATION_INTERFACE_VERSION

#define MYSQL_REPLICATION_INTERFACE_VERSION

Definition: plugin.h:682

◆ server_state_observer

Server_state_observer server_state_observer

Initial value:

= {
    sizeof(Server_state_observer),
 
    before_handle_connection,  
    before_recovery,           
    after_engine_recovery,     
    after_recovery,            
    before_server_shutdown,    
    after_server_shutdown,     
    after_dd_upgrade,          
}

◆ thread_aborted

bool thread_aborted = false

static

◆ trans_after_commit_call

int trans_after_commit_call = 0

static

◆ trans_after_rollback_call

int trans_after_rollback_call = 0

static

◆ trans_before_commit_call

int trans_before_commit_call = 0

static

◆ trans_before_dml_call

int trans_before_dml_call = 0

static

◆ trans_before_rollback_call

int trans_before_rollback_call = 0

static

◆ trans_begin_call

int trans_begin_call = 0

static

◆ trans_observer

Trans_observer trans_observer

Initial value:

= {
    sizeof(Trans_observer),
 
    trans_before_dml,       trans_before_commit,  trans_before_rollback,
    trans_after_commit,     trans_after_rollback, trans_begin,
}

Typedefs

Enumerations

Functions

Variables

Typedef Documentation

◆ before_commit_test_cases

Enumeration Type Documentation

◆ enum_before_commit_test_cases

Function Documentation

◆ after_dd_upgrade()

◆ after_engine_recovery()

◆ after_recovery()

◆ after_server_shutdown()

◆ before_commit_tests()

◆ before_handle_connection()

◆ before_recovery()

◆ before_server_shutdown()

◆ binlog_relay_after_queue_event()

◆ binlog_relay_after_read_event()

◆ binlog_relay_after_reset_slave()

◆ binlog_relay_applier_log_event()

◆ binlog_relay_applier_start()

◆ binlog_relay_applier_stop()

◆ binlog_relay_before_request_transmit()

◆ binlog_relay_thread_start()

◆ binlog_relay_thread_stop()

◆ dump_binlog_relay_calls()

◆ dump_server_state_calls()

◆ dump_transaction_calls()

◆ mysql_declare_plugin()

◆ replication_observers_example_plugin_deinit()

◆ replication_observers_example_plugin_init()

◆ test_channel_service_interface()

◆ test_channel_service_interface_initialization()

◆ test_channel_service_interface_io_thread()

◆ test_channel_service_interface_is_io_stopping()

◆ test_channel_service_interface_is_sql_stopping()

◆ test_channel_service_interface_relay_log_renamed()

◆ test_server_count_transactions()

◆ trans_after_commit()

◆ trans_after_rollback()

◆ trans_before_commit()

◆ trans_before_dml()

◆ trans_before_rollback()

◆ trans_begin()

◆ validate_plugin_server_requirements()

Variable Documentation

◆ after_dd_upgrade_call

◆ after_engine_recovery_call

◆ after_recovery_call

◆ after_server_shutdown_call

◆ before_handle_connection_call

◆ before_recovery_call

◆ before_server_shutdown_call

◆ binlog_relay_after_queue_event_call

◆ binlog_relay_after_read_event_call

◆ binlog_relay_after_reset_slave_call

◆ binlog_relay_applier_start_call

◆ binlog_relay_applier_stop_call

◆ binlog_relay_before_request_transmit_call

◆ binlog_relay_thread_start_call

◆ binlog_relay_thread_stop_call

◆ log_bi

◆ log_bs

◆ mysql_declare_plugin_end

◆ plugin_info_ptr

◆ reg_srv

◆ relay_io_observer

◆ replication_observers_example_plugin

◆ server_state_observer

◆ thread_aborted

◆ trans_after_commit_call

◆ trans_after_rollback_call

◆ trans_before_commit_call

◆ trans_before_dml_call

◆ trans_before_rollback_call

◆ trans_begin_call

◆ trans_observer