xa::Transaction_cache Class Reference

Class responsible for managing a cache of Transaction_ctx objects associated with XA transactions. More...

#include <transaction_cache.h>

Public Types
using	transaction_ptr = std::shared_ptr< Transaction_ctx >
using	unordered_map = malloc_unordered_map< std::string, transaction_ptr >
using	list = std::vector< transaction_ptr >
using	filter_predicate_t = std::function< bool(transaction_ptr const &)>

Public Member Functions
virtual	~Transaction_cache ()=default
	Transaction_cache (Transaction_cache const &)=delete
	Transaction_cache (Transaction_cache &&)=delete
Transaction_cache &	operator= (Transaction_cache const &)=delete
Transaction_cache &	operator= (Transaction_cache &&)=delete

Static Public Member Functions
static bool	detach (Transaction_ctx *transaction)
	Transaction is marked in the cache as if it's recovered. More...
static void	remove (Transaction_ctx *transaction)
	Remove information about transaction from a cache. More...
static bool	insert (XID *xid, Transaction_ctx *transaction)
	Inserts a transaction context identified by a given XID. More...
static bool	insert (XID *xid)
	Creates a new transaction context for the recovering transaction identified by a given XID. More...
static transaction_ptr	find (XID *xid, filter_predicate_t filter=nullptr)
	Searches the cache for the transaction context identified by the given XID. More...
static list	get_cached_transactions ()
	Retrieves the list of transaction contexts cached. More...
static void	initialize ()
	Initializes the transaction cache underlying resources. More...
static void	dispose ()
	Disposes of the transaction cache allocated resources. More...

Private Member Functions
	Transaction_cache ()
	Class constructor. More...

Static Private Member Functions
static Transaction_cache &	instance ()
	Initialize a cache to store Transaction_ctx and a mutex to protect access to the cache. More...
static bool	create_and_insert_new_transaction (XID *xid, bool is_binlogged_arg, const Transaction_ctx *src)
	Creates a new transaction context for the transaction with the given XID and adds it to the cache. More...

Private Attributes
mysql_mutex_t	m_LOCK_transaction_cache
	A lock to serialize the access to m_transaction_cache More...
PSI_mutex_key	m_key_LOCK_transaction_cache
	The PSI key for the above lock. More...
PSI_mutex_info	m_transaction_cache_mutexes [1]
	The PSI configuration of the above lock and key. More...
unordered_map	m_transaction_cache
	A map holding the cached transaction context, indexed by XID. More...

Detailed Description

Class responsible for managing a cache of Transaction_ctx objects associated with XA transactions.

The cache is used during the recovery stage of an XA transaction.

Note

this class is a singleton class.

Member Typedef Documentation

filter_predicate_t

using xa::Transaction_cache::filter_predicate_t = std::function<bool(transaction_ptr const &)>

list

using xa::Transaction_cache::list = std::vector<transaction_ptr>

transaction_ptr

using xa::Transaction_cache::transaction_ptr = std::shared_ptr<Transaction_ctx>

unordered_map

using xa::Transaction_cache::unordered_map = malloc_unordered_map<std::string, transaction_ptr>

Constructor & Destructor Documentation

~Transaction_cache()

virtual xa::Transaction_cache::~Transaction_cache ( )

virtualdefault

Transaction_cache() [1/3]

xa::Transaction_cache::Transaction_cache ( Transaction_cache const &  )

delete

Transaction_cache() [2/3]

xa::Transaction_cache::Transaction_cache ( Transaction_cache &&  )

delete

Transaction_cache() [3/3]

xa::Transaction_cache::Transaction_cache ( )

private

Class constructor.

It's declared private since this class is a singleton class.

Member Function Documentation

create_and_insert_new_transaction()

bool xa::Transaction_cache::create_and_insert_new_transaction ( XID *  xid, bool  is_binlogged_arg, const Transaction_ctx *  src  )

staticprivate

Creates a new transaction context for the transaction with the given XID and adds it to the cache.

Parameters

xid	The XID of the transaction to create and add.
is_binlogged_arg	Whether or not the transaction has already been binlogged.
src	The transaction context and info to be added to the newly created cache item.

Returns

false if the pair was successfully inserted, true otherwise.

detach()

bool xa::Transaction_cache::detach ( Transaction_ctx *  transaction )

static

Transaction is marked in the cache as if it's recovered.

The method allows to sustain prepared transaction disconnection.

Parameters

transaction

Pointer to Transaction object that is replaced.

Returns

operation result

Return values

false	success or a cache already contains XID_STATE for this XID value
true	failure

dispose()

void xa::Transaction_cache::dispose ( )

static

Disposes of the transaction cache allocated resources.

find()

std::shared_ptr< Transaction_ctx > xa::Transaction_cache::find ( XID *  xid, filter_predicate_t  filter = nullptr  )

static

Searches the cache for the transaction context identified by the given XID.

An additional filtering predicate can be provided, to allow for further validations on values for mathching XID. The predicate is evaluated while holding the necessary locks to ensure the validaty of the Transaction_ctx shared pointer.

A non-null value is returned if and only if:

1. The value is found in the underlying map
2. The found value underlying XID (Transaction_ctx::xid_state()get_xid()) equals to the parameter xid. This validation is necessary since the XID representation for the key used in the underlying map isn't an exact match for the full XID representation.
3. If a predicate parameter is provided, the evaluation of passing the value as a predicate parameter must be true.

Parameters

xid	The XID of the transaction to search the context for.
filter	A predicate to be evaluated when an value for xid is found. If predicate returns false, the found element is filtered out.

Returns

The transaction context if found and valid, nullptr otherwise.

get_cached_transactions()

xa::Transaction_cache::list xa::Transaction_cache::get_cached_transactions ( )

static

Retrieves the list of transaction contexts cached.

Returns

A vector with all transaction contexts cached so far.

initialize()

void xa::Transaction_cache::initialize ( )

static

Initializes the transaction cache underlying resources.

insert() [1/2]

bool xa::Transaction_cache::insert ( XID *  xid )

static

Creates a new transaction context for the recovering transaction identified by a given XID.

Parameters

xid	The XID of the transaction being recovered.

Returns

false if the pair was successfully inserted, true otherwise.

insert() [2/2]

bool xa::Transaction_cache::insert ( XID *  xid, Transaction_ctx *  transaction  )

static

Inserts a transaction context identified by a given XID.

Parameters

xid	The XID of the transaction.
transaction	The object containing the context of the transaction.

Returns

false if the pair was successfully inserted, true otherwise.

instance()

xa::Transaction_cache & xa::Transaction_cache::instance ( )

staticprivate

Initialize a cache to store Transaction_ctx and a mutex to protect access to the cache.

Returns

The initialized class instance.

operator=() [1/2]

Transaction_cache & xa::Transaction_cache::operator= ( Transaction_cache &&  )

delete

operator=() [2/2]

Transaction_cache & xa::Transaction_cache::operator= ( Transaction_cache const &  )

delete

remove()

void xa::Transaction_cache::remove ( Transaction_ctx *  transaction )

static

Remove information about transaction from a cache.

Parameters

transaction

Pointer to a Transaction_ctx that has to be removed from a cache.

Member Data Documentation

m_key_LOCK_transaction_cache

PSI_mutex_key xa::Transaction_cache::m_key_LOCK_transaction_cache

private

The PSI key for the above lock.

m_LOCK_transaction_cache

mysql_mutex_t xa::Transaction_cache::m_LOCK_transaction_cache

private

A lock to serialize the access to m_transaction_cache

m_transaction_cache

unordered_map xa::Transaction_cache::m_transaction_cache

private

A map holding the cached transaction context, indexed by XID.

m_transaction_cache_mutexes

PSI_mutex_info xa::Transaction_cache::m_transaction_cache_mutexes[1]

private

Initial value:

= {
      {&m_key_LOCK_transaction_cache, "LOCK_transaction_cache",
       PSI_FLAG_SINGLETON, 0, PSI_DOCUMENT_ME}}

The PSI configuration of the above lock and key.

---

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

• sql/xa/transaction_cache.h
• sql/xa/transaction_cache.cc