observer_trans.cc File Reference

#include <assert.h>
#include <mysql/components/services/log_builtins.h>
#include <mysql/service_rpl_transaction_ctx.h>
#include <mysql/service_rpl_transaction_write_set.h>
#include <stddef.h>
#include <string>
#include <vector>
#include "base64.h"
#include "my_byteorder.h"
#include "my_dbug.h"
#include "my_inttypes.h"
#include "plugin/group_replication/include/consistency_manager.h"
#include "plugin/group_replication/include/observer_trans.h"
#include "plugin/group_replication/include/plugin.h"
#include "plugin/group_replication/include/plugin_messages/transaction_message.h"
#include "plugin/group_replication/include/plugin_messages/transaction_with_guarantee_message.h"
#include "plugin/group_replication/include/plugin_observers/group_transaction_observation_manager.h"
#include "plugin/group_replication/include/sql_service/sql_command_test.h"
#include "string_with_len.h"

Macros
#define	BUFFER_READ_PKE   8

Functions
int	add_write_set (Transaction_context_log_event *tcle, std::vector< uint64 > *set, const THD *thd)
int	group_replication_trans_before_dml (Trans_param *param, int &out)
int	group_replication_trans_before_commit (Trans_param *param)
int	group_replication_trans_before_rollback (Trans_param *)
int	group_replication_trans_after_commit (Trans_param *param)
int	group_replication_trans_after_rollback (Trans_param *param)
int	group_replication_trans_begin (Trans_param *param, int &out)

Variables
Trans_observer	trans_observer

Macro Definition Documentation

BUFFER_READ_PKE

#define BUFFER_READ_PKE   8

Function Documentation

add_write_set()

int add_write_set	(	Transaction_context_log_event *	tcle,
		std::vector< uint64 > *	set,
		const THD *	thd
	)

group_replication_trans_after_commit()

int group_replication_trans_after_commit

(

Trans_param *

param

)

We don't use locks here as observers are unregistered before the classes used here disappear. Unregistration also avoids usage vs removal scenarios.

group_replication_trans_after_rollback()

int group_replication_trans_after_rollback

(

Trans_param *

param

)

group_replication_trans_before_commit()

int group_replication_trans_before_commit

(

Trans_param *

param

)

group_replication_trans_before_dml()

int group_replication_trans_before_dml	(	Trans_param *	param,
		int &	out
	)

group_replication_trans_before_rollback()

int group_replication_trans_before_rollback

(

Trans_param *

param

)

group_replication_trans_begin()

int group_replication_trans_begin	(	Trans_param *	param,
		int &	out
	)

Variable Documentation

trans_observer

Trans_observer trans_observer

Initial value:

= {
    sizeof(Trans_observer),
 
    group_replication_trans_before_dml,
    group_replication_trans_before_commit,
    group_replication_trans_before_rollback,
    group_replication_trans_after_commit,
    group_replication_trans_after_rollback,
    group_replication_trans_begin,
}