observer_server_actions.cc File Reference

#include "plugin/group_replication/include/observer_server_actions.h"
#include "plugin/group_replication/include/observer_trans.h"

Functions
int	group_replication_reset_master_logs (Binlog_transmit_param *)
int	group_replication_transmit_start (Binlog_transmit_param *, const char *, my_off_t)
int	group_replication_transmit_stop (Binlog_transmit_param *)
int	group_replication_reserve_header (Binlog_transmit_param *, unsigned char *, unsigned long, unsigned long *)
int	group_replication_before_send_event (Binlog_transmit_param *, unsigned char *, unsigned long, const char *, my_off_t)
int	group_replication_after_send_event (Binlog_transmit_param *, const char *, unsigned long, const char *, my_off_t)

Variables
Binlog_transmit_observer	binlog_transmit_observer

Function Documentation

group_replication_after_send_event()

int group_replication_after_send_event	(	Binlog_transmit_param *	param,
		const char *	event_buf,
		unsigned long	len,
		const char *	skipped_log_file,
		my_off_t	skipped_log_pos
	)

group_replication_before_send_event()

int group_replication_before_send_event	(	Binlog_transmit_param *	param,
		unsigned char *	packet,
		unsigned long	len,
		const char *	log_file,
		my_off_t	log_pos
	)

group_replication_reserve_header()

int group_replication_reserve_header	(	Binlog_transmit_param *	param,
		unsigned char *	header,
		unsigned long	size,
		unsigned long *	len
	)

group_replication_reset_master_logs()

int group_replication_reset_master_logs

(

Binlog_transmit_param *

param

)

group_replication_transmit_start()

int group_replication_transmit_start	(	Binlog_transmit_param *	param,
		const char *	log_file,
		my_off_t	log_pos
	)

group_replication_transmit_stop()

int group_replication_transmit_stop

(

Binlog_transmit_param *

param

)

Variable Documentation

binlog_transmit_observer

Binlog_transmit_observer binlog_transmit_observer

Initial value:

= {
    sizeof(Binlog_transmit_observer),
 
    group_replication_transmit_start,     
    group_replication_transmit_stop,      
    group_replication_reserve_header,     
    group_replication_before_send_event,  
    group_replication_after_send_event,   
    group_replication_reset_master_logs   
}