observer_server_channels.cc File Reference

#include "plugin/group_replication/include/observer_server_channels.h"
#include <stddef.h>
#include "plugin/group_replication/include/plugin.h"

Functions
int	group_replication_thread_start (Binlog_relay_IO_param *param)
int	group_replication_thread_stop (Binlog_relay_IO_param *param)
int	group_replication_applier_start (Binlog_relay_IO_param *param)
int	group_replication_applier_stop (Binlog_relay_IO_param *param, bool aborted)
int	group_replication_before_request_transmit (Binlog_relay_IO_param *param, uint32 flags)
int	group_replication_after_read_event (Binlog_relay_IO_param *param, const char *packet, unsigned long len, const char **event_buf, unsigned long *event_len)
int	group_replication_after_queue_event (Binlog_relay_IO_param *param, const char *event_buf, unsigned long event_len, uint32 flags)
int	group_replication_after_reset_slave (Binlog_relay_IO_param *param)
int	group_replication_applier_log_event (Binlog_relay_IO_param *param, Trans_param *trans_param, int &out)

Variables
Binlog_relay_IO_observer	binlog_IO_observer

Function Documentation

group_replication_after_queue_event()

int group_replication_after_queue_event	(	Binlog_relay_IO_param *	param,
		const char *	event_buf,
		unsigned long	event_len,
		uint32	flags
	)

group_replication_after_read_event()

int group_replication_after_read_event	(	Binlog_relay_IO_param *	param,
		const char *	packet,
		unsigned long	len,
		const char **	event_buf,
		unsigned long *	event_len
	)

group_replication_after_reset_slave()

int group_replication_after_reset_slave

(

Binlog_relay_IO_param *

param

)

group_replication_applier_log_event()

int group_replication_applier_log_event	(	Binlog_relay_IO_param *	param,
		Trans_param *	trans_param,
		int &	out
	)

group_replication_applier_start()

int group_replication_applier_start

(

Binlog_relay_IO_param *

param

)

group_replication_applier_stop()

int group_replication_applier_stop	(	Binlog_relay_IO_param *	param,
		bool	aborted
	)

group_replication_before_request_transmit()

int group_replication_before_request_transmit	(	Binlog_relay_IO_param *	param,
		uint32	flags
	)

group_replication_thread_start()

int group_replication_thread_start

(

Binlog_relay_IO_param *

param

)

group_replication_thread_stop()

int group_replication_thread_stop

(

Binlog_relay_IO_param *

param

)

Variable Documentation

binlog_IO_observer

Binlog_relay_IO_observer binlog_IO_observer

Initial value:

= {
    sizeof(Binlog_relay_IO_observer),
 
    group_replication_thread_start,
    group_replication_thread_stop,
    group_replication_applier_start,
    group_replication_applier_stop,
    group_replication_before_request_transmit,
    group_replication_after_read_event,
    group_replication_after_queue_event,
    group_replication_after_reset_slave,
    group_replication_applier_log_event}