#include <pfs_data_lock.h>

Inheritance diagram for PFS_data_lock_container:

Public Member Functions
	PFS_data_lock_container ()

	~PFS_data_lock_container () override

const char *	cache_string (const char *string) override
	Add a string to the container cache. More...

const char *	cache_data (const char *ptr, size_t length) override
	Add binary data to the container cache. More...

void	cache_identifier (PSI_identifier kind, const char str, size_t length, const char cached_ptr, size_t cached_length) override
	Add an identifier in the container cache. More...

bool	accept_engine (const char *engine, size_t engine_length) override
	Check if the container accepts data for a particular engine. More...

bool	accept_lock_id (const char *engine_lock_id, size_t engine_lock_id_length) override
	Check if the container accepts data for a particular lock. More...

bool	accept_transaction_id (ulonglong transaction_id) override
	Check if the container accepts data for a particular transaction. More...

bool	accept_thread_id_event_id (ulonglong thread_id, ulonglong event_id) override
	Check if the container accepts data for a particular event. More...

bool	accept_object (const char table_schema, size_t table_schema_length, const char table_name, size_t table_name_length, const char partition_name, size_t partition_name_length, const char sub_partition_name, size_t sub_partition_name_length) override
	Check if the container accepts data for a particular object. More...

void	add_lock_row (const char engine, size_t engine_length, const char engine_lock_id, size_t engine_lock_id_length, ulonglong transaction_id, ulonglong thread_id, ulonglong event_id, const char table_schema, size_t table_schema_length, const char table_name, size_t table_name_length, const char partition_name, size_t partition_name_length, const char sub_partition_name, size_t sub_partition_name_length, const char index_name, size_t index_name_length, const void identity, const char lock_mode, const char lock_type, const char lock_status, const char lock_data) override
	Add a row to table performance_schema.data_locks. More...

void	clear ()
	Clear the container. More...

void	shrink ()
	Shrink the container. More...

row_data_lock *	get_row (size_t index)

void	set_filter (PFS_index_data_locks *filter)

Public Member Functions inherited from PSI_server_data_lock_container
	PSI_server_data_lock_container ()=default

virtual	~PSI_server_data_lock_container ()=default

Private Attributes
size_t	m_logical_row_index

std::vector< row_data_lock, PFS_data_container_allocator< row_data_lock > >	m_rows

PFS_data_cache	m_cache

PFS_index_data_locks *	m_filter

Constructor & Destructor Documentation

◆ PFS_data_lock_container()

PFS_data_lock_container::PFS_data_lock_container ( )

◆ ~PFS_data_lock_container()

PFS_data_lock_container::~PFS_data_lock_container ( )

overridedefault

Member Function Documentation

◆ accept_engine()

bool PFS_data_lock_container::accept_engine	(	const char *	engine,
		size_t	engine_length
	)

overridevirtual

Check if the container accepts data for a particular engine.

This methods is used to prune data for queries like

SELECT * from performance_schema.data_locks WHERE ENGINE = ...

consts::SELECT

const std::string SELECT("SELECT")

Name of the static privileges.

WHERE

@ WHERE

Definition: sql_yacc.h:687

Implements PSI_server_data_lock_container.

◆ accept_lock_id()

bool PFS_data_lock_container::accept_lock_id	(	const char *	engine_lock_id,
		size_t	engine_lock_id_length
	)

overridevirtual

Check if the container accepts data for a particular lock.

This methods is used to prune data for queries like

SELECT * from performance_schema.data_locks WHERE ENGINE_LOCK_ID = ...

Implements PSI_server_data_lock_container.

◆ accept_object()

bool PFS_data_lock_container::accept_object	(	const char *	table_schema,
		size_t	table_schema_length,
		const char *	table_name,
		size_t	table_name_length,
		const char *	partition_name,
		size_t	partition_name_length,
		const char *	sub_partition_name,
		size_t	sub_partition_name_length
	)

overridevirtual

Check if the container accepts data for a particular object.

This methods is used to prune data for queries like

 SELECT * from performance_schema.data_locks
WHERE OBJECT_SCHEMA = ...
AND OBJECT_NAME = ...
AND PARTITION_NAME = ...
AND SUBPARTITION_NAME = ... 

Implements PSI_server_data_lock_container.

◆ accept_thread_id_event_id()

bool PFS_data_lock_container::accept_thread_id_event_id	(	ulonglong	thread_id,
		ulonglong	event_id
	)

overridevirtual

Check if the container accepts data for a particular event.

This methods is used to prune data for queries like

SELECT * from performance_schema.data_locks

WHERE THREAD_ID = ... AND EVENT_ID = ...

Implements PSI_server_data_lock_container.

◆ accept_transaction_id()

bool PFS_data_lock_container::accept_transaction_id ( ulonglong transaction_id )

overridevirtual

Check if the container accepts data for a particular transaction.

This methods is used to prune data for queries like

SELECT * from performance_schema.data_locks WHERE

ENGINE_TRANSACTION_ID = ...

Implements PSI_server_data_lock_container.

◆ add_lock_row()

void PFS_data_lock_container::add_lock_row	(	const char *	engine,
		size_t	engine_length,
		const char *	engine_lock_id,
		size_t	engine_lock_id_length,
		ulonglong	transaction_id,
		ulonglong	thread_id,
		ulonglong	event_id,
		const char *	table_schema,
		size_t	table_schema_length,
		const char *	table_name,
		size_t	table_name_length,
		const char *	partition_name,
		size_t	partition_name_length,
		const char *	sub_partition_name,
		size_t	sub_partition_name_length,
		const char *	index_name,
		size_t	index_name_length,
		const void *	identity,
		const char *	lock_mode,
		const char *	lock_type,
		const char *	lock_status,
		const char *	lock_data
	)

overridevirtual

Add a row to table performance_schema.data_locks.

Implements PSI_server_data_lock_container.

◆ cache_data()

const char * PFS_data_lock_container::cache_data	(	const char *	ptr,
		size_t	length
	)

overridevirtual

Add binary data to the container cache.

See also: cache_string

Implements PSI_server_data_lock_container.

◆ cache_identifier()

void PFS_data_lock_container::cache_identifier	(	PSI_identifier	kind,
		const char *	str,
		size_t	length,
		const char **	cached_ptr,
		size_t *	cached_length
	)

overridevirtual

Add an identifier in the container cache.

Depending on the identifier kind, the string given may be normalized, to comply with lower_case_table_names, before adding the string into the cache. Beware that the normalized string length may differ from the input string length.

Parameters

[in]	kind	Identifier kind, used for string normalization
[in]	str	Identifier input string
[in]	length	Identifier input string length
[out]	cached_ptr	Cached, possibly normalized, identifier string
[out]	cached_length	Cached identifier string length

Implements PSI_server_data_lock_container.

◆ cache_string()

const char * PFS_data_lock_container::cache_string ( const char * string )

overridevirtual

Add a string to the container cache.

Cached strings have the same life cycle as the data container, and are freed when the container is destroyed. Also, duplicated strings value are cached with the same copy, avoiding memory duplication. This is useful in particular to cache table schema or table names, which are duplicated a lot for different row locks on the same table.

Implements PSI_server_data_lock_container.

◆ clear()

void PFS_data_lock_container::clear ( )

Clear the container.

New rows added will start at index 0.

◆ get_row()

row_data_lock * PFS_data_lock_container::get_row ( size_t index )

◆ set_filter()

void PFS_data_lock_container::set_filter ( PFS_index_data_locks * filter )

inline

◆ shrink()

void PFS_data_lock_container::shrink ( )

Shrink the container.

New rows added will continue to use the current index.

Member Data Documentation

◆ m_cache

PFS_data_cache PFS_data_lock_container::m_cache

private

◆ m_filter

PFS_index_data_locks* PFS_data_lock_container::m_filter

private

◆ m_logical_row_index

size_t PFS_data_lock_container::m_logical_row_index

private

◆ m_rows

std::vector<row_data_lock, PFS_data_container_allocator<row_data_lock> > PFS_data_lock_container::m_rows

private

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

storage/perfschema/pfs_data_lock.h
storage/perfschema/pfs_data_lock.cc

Public Member Functions

Private Attributes

Constructor & Destructor Documentation

◆ PFS_data_lock_container()

◆ ~PFS_data_lock_container()

Member Function Documentation

◆ accept_engine()

◆ accept_lock_id()

◆ accept_object()

◆ accept_thread_id_event_id()

◆ accept_transaction_id()

◆ add_lock_row()

◆ cache_data()

◆ cache_identifier()

◆ cache_string()

◆ clear()

◆ get_row()

◆ set_filter()

◆ shrink()

Member Data Documentation

◆ m_cache

◆ m_filter

◆ m_logical_row_index

◆ m_rows