Group_transaction_listener Class Reference

Listener for transaction life cycle events. More...

#include <group_transaction_observation_manager.h>

Inheritance diagram for Group_transaction_listener:

Public Types
enum	enum_transaction_origin { GROUP_APPLIER_TRANSACTION = 0 , GROUP_RECOVERY_TRANSACTION = 1 , GROUP_LOCAL_TRANSACTION = 2 }
	Enum for transaction origins. More...

Public Member Functions
virtual	~Group_transaction_listener ()
	Class destructor. More...
virtual int	before_transaction_begin (my_thread_id thread_id, ulong gr_consistency_level, ulong hold_timeout, enum_rpl_channel_type channel_type, const THD *thd)=0
	Executed before a transaction begins. More...
virtual int	before_commit (my_thread_id thread_id, enum_transaction_origin origin)=0
	Executed before commit. More...
virtual int	before_rollback (my_thread_id thread_id, enum_transaction_origin origin)=0
	Executed before rollback. More...
virtual int	after_commit (my_thread_id thread_id, rpl_sidno sidno, rpl_gno gno)=0
	Executed after commit. More...
virtual int	after_rollback (my_thread_id thread_id)=0
	Executed after rollback. More...

Detailed Description

Listener for transaction life cycle events.

Member Enumeration Documentation

enum_transaction_origin

enum Group_transaction_listener::enum_transaction_origin

Enum for transaction origins.

Enumerator
GROUP_APPLIER_TRANSACTION
GROUP_RECOVERY_TRANSACTION
GROUP_LOCAL_TRANSACTION

Constructor & Destructor Documentation

~Group_transaction_listener()

Group_transaction_listener::~Group_transaction_listener ( )

virtualdefault

Class destructor.

Member Function Documentation

after_commit()

virtual int Group_transaction_listener::after_commit ( my_thread_id  thread_id, rpl_sidno  sidno, rpl_gno  gno  )

pure virtual

Executed after commit.

Parameters

thread_id	the transaction thread id
sidno	the transaction sidno
gno	the transaction gno

Implemented in Transaction_consistency_manager, and Server_ongoing_transactions_handler.

after_rollback()

virtual int Group_transaction_listener::after_rollback ( my_thread_id  thread_id )

pure virtual

Executed after rollback.

Parameters

thread_id

the transaction thread id

Implemented in Transaction_consistency_manager, and Server_ongoing_transactions_handler.

before_commit()

virtual int Group_transaction_listener::before_commit ( my_thread_id  thread_id, enum_transaction_origin  origin  )

pure virtual

Executed before commit.

Parameters

thread_id	the transaction thread id
origin	who applied it

Implemented in Transaction_consistency_manager, and Server_ongoing_transactions_handler.

before_rollback()

virtual int Group_transaction_listener::before_rollback ( my_thread_id  thread_id, enum_transaction_origin  origin  )

pure virtual

Executed before rollback.

Parameters

thread_id	the transaction thread id
origin	who applied it

Implemented in Transaction_consistency_manager, and Server_ongoing_transactions_handler.

before_transaction_begin()

virtual int Group_transaction_listener::before_transaction_begin ( my_thread_id  thread_id, ulong  gr_consistency_level, ulong  hold_timeout, enum_rpl_channel_type  channel_type, const THD *  thd  )

pure virtual

Executed before a transaction begins.

Parameters

thread_id	the transaction thread id
gr_consistency_level	the current consistency level for this session
hold_timeout	the max time to execute an action on this transaction
channel_type	type channel that receives transaction
thd	server thd that represents client session

Implemented in Server_ongoing_transactions_handler, and Transaction_consistency_manager.

---

The documentation for this class was generated from the following files:

• plugin/group_replication/include/plugin_observers/group_transaction_observation_manager.h
• plugin/group_replication/src/plugin_observers/group_transaction_observation_manager.cc