Structure to store the GTID and timing information. More...

#include <rpl_gtid.h>

Public Member Functions
	Trx_monitoring_info ()
	Constructor. More...

	Trx_monitoring_info (const Trx_monitoring_info &info)
	Copy constructor. More...

Trx_monitoring_info &	operator= (const Trx_monitoring_info &)=default

void	clear ()
	Clear all fields of the structure. More...

void	copy_to_ps_table (Tsid_map tsid_map, char gtid_arg, uint gtid_length_arg, ulonglong original_commit_ts_arg, ulonglong immediate_commit_ts_arg, ulonglong start_time_arg) const
	Copies this transaction monitoring information to the output parameters passed as input, which are the corresponding fields in a replication performance schema table. More...

void	copy_to_ps_table (Tsid_map tsid_map, char gtid_arg, uint gtid_length_arg, ulonglong original_commit_ts_arg, ulonglong immediate_commit_ts_arg, ulonglong start_time_arg, ulonglong *end_time_arg) const
	Copies this transaction monitoring information to the output parameters passed as input, which are the corresponding fields in a replication performance schema table. More...

void	copy_to_ps_table (Tsid_map tsid_map, char gtid_arg, uint gtid_length_arg, ulonglong original_commit_ts_arg, ulonglong immediate_commit_ts_arg, ulonglong start_time_arg, uint last_transient_errno_arg, char last_transient_errmsg_arg, uint last_transient_errmsg_length_arg, ulonglong last_transient_timestamp_arg, ulong *retries_count_arg) const
	Copies this transaction monitoring information to the output parameters passed as input, which are the corresponding fields in a replication performance schema table. More...

void	copy_to_ps_table (Tsid_map tsid_map, char gtid_arg, uint gtid_length_arg, ulonglong original_commit_ts_arg, ulonglong immediate_commit_ts_arg, ulonglong start_time_arg, ulonglong end_time_arg, uint last_transient_errno_arg, char last_transient_errmsg_arg, uint last_transient_errmsg_length_arg, ulonglong last_transient_timestamp_arg, ulong retries_count_arg) const
	Copies this transaction monitoring information to the output parameters passed as input, which are the corresponding fields in a replication performance schema table. More...

Public Attributes
Gtid	gtid
	GTID being monitored. More...

ulonglong	original_commit_timestamp
	OCT of the GTID being monitored. More...

ulonglong	immediate_commit_timestamp
	ICT of the GTID being monitored. More...

ulonglong	start_time
	When the GTID transaction started to be processed. More...

ulonglong	end_time
	When the GTID transaction finished to be processed. More...

bool	skipped
	True if the GTID is being applied but will be skipped. More...

bool	is_info_set
	True when this information contains useful data. More...

uint	last_transient_error_number
	Number of the last transient error of this transaction. More...

char	last_transient_error_message [MAX_SLAVE_ERRMSG]
	Message of the last transient error of this transaction. More...

ulonglong	last_transient_error_timestamp
	Timestamp in microseconds of the last transient error of this transaction. More...

ulong	transaction_retries
	Number of times this transaction was retried. More...

bool	is_retrying
	True when the transaction is retrying. More...

mysql::binlog::event::compression::type	compression_type
	The compression type. More...

ulonglong	compressed_bytes
	The compressed bytes. More...

ulonglong	uncompressed_bytes
	The uncompressed bytes. More...

Detailed Description

Structure to store the GTID and timing information.

Constructor & Destructor Documentation

◆ Trx_monitoring_info() [1/2]

Trx_monitoring_info::Trx_monitoring_info ( )

Constructor.

◆ Trx_monitoring_info() [2/2]

Trx_monitoring_info::Trx_monitoring_info ( const Trx_monitoring_info & info )

Copy constructor.

Member Function Documentation

◆ clear()

void Trx_monitoring_info::clear ( )

Clear all fields of the structure.

◆ copy_to_ps_table() [1/4]

void Trx_monitoring_info::copy_to_ps_table	(	Tsid_map *	tsid_map,
		char *	gtid_arg,
		uint *	gtid_length_arg,
		ulonglong *	original_commit_ts_arg,
		ulonglong *	immediate_commit_ts_arg,
		ulonglong *	start_time_arg
	)		const

Copies this transaction monitoring information to the output parameters passed as input, which are the corresponding fields in a replication performance schema table.

Parameters

[in]	tsid_map	The TSID map for the GTID.
[out]	gtid_arg	GTID field in the PS table.
[out]	gtid_length_arg	Length of the GTID as string.
[out]	original_commit_ts_arg	The original commit timestamp.
[out]	immediate_commit_ts_arg	The immediate commit timestamp.
[out]	start_time_arg	The start time field.

◆ copy_to_ps_table() [2/4]

void Trx_monitoring_info::copy_to_ps_table	(	Tsid_map *	tsid_map,
		char *	gtid_arg,
		uint *	gtid_length_arg,
		ulonglong *	original_commit_ts_arg,
		ulonglong *	immediate_commit_ts_arg,
		ulonglong *	start_time_arg,
		uint *	last_transient_errno_arg,
		char *	last_transient_errmsg_arg,
		uint *	last_transient_errmsg_length_arg,
		ulonglong *	last_transient_timestamp_arg,
		ulong *	retries_count_arg
	)		const

Copies this transaction monitoring information to the output parameters passed as input, which are the corresponding fields in a replication performance schema table.

Parameters

[in]	tsid_map	The TSID map for the GTID.
[out]	gtid_arg	GTID field in the PS table.
[out]	gtid_length_arg	Length of the GTID as string.
[out]	original_commit_ts_arg	The original commit timestamp.
[out]	immediate_commit_ts_arg	The immediate commit timestamp.
[out]	start_time_arg	The start time field.
[out]	last_transient_errno_arg	The last transient error number.
[out]	last_transient_errmsg_arg	The last transient error message.
[out]	last_transient_errmsg_length_arg	Length of the last transient error message.
[out]	last_transient_timestamp_arg	The last transient error timestamp.
[out]	retries_count_arg	The total number of retries for this transaction.

◆ copy_to_ps_table() [3/4]

void Trx_monitoring_info::copy_to_ps_table	(	Tsid_map *	tsid_map,
		char *	gtid_arg,
		uint *	gtid_length_arg,
		ulonglong *	original_commit_ts_arg,
		ulonglong *	immediate_commit_ts_arg,
		ulonglong *	start_time_arg,
		ulonglong *	end_time_arg
	)		const

Copies this transaction monitoring information to the output parameters passed as input, which are the corresponding fields in a replication performance schema table.

Parameters

[in]	tsid_map	The TSID map for the GTID.
[out]	gtid_arg	GTID field in the PS table.
[out]	gtid_length_arg	Length of the GTID as string.
[out]	original_commit_ts_arg	The original commit timestamp.
[out]	immediate_commit_ts_arg	The immediate commit timestamp.
[out]	start_time_arg	The start time field.
[out]	end_time_arg	The end time field. This can be null when the PS table fields are for the "still processing" information.

◆ copy_to_ps_table() [4/4]

void Trx_monitoring_info::copy_to_ps_table	(	Tsid_map *	tsid_map,
		char *	gtid_arg,
		uint *	gtid_length_arg,
		ulonglong *	original_commit_ts_arg,
		ulonglong *	immediate_commit_ts_arg,
		ulonglong *	start_time_arg,
		ulonglong *	end_time_arg,
		uint *	last_transient_errno_arg,
		char *	last_transient_errmsg_arg,
		uint *	last_transient_errmsg_length_arg,
		ulonglong *	last_transient_timestamp_arg,
		ulong *	retries_count_arg
	)		const

Copies this transaction monitoring information to the output parameters passed as input, which are the corresponding fields in a replication performance schema table.

Parameters

[in]	tsid_map	The TSID map for the GTID.
[out]	gtid_arg	GTID field in the PS table.
[out]	gtid_length_arg	Length of the GTID as string.
[out]	original_commit_ts_arg	The original commit timestamp.
[out]	immediate_commit_ts_arg	The immediate commit timestamp.
[out]	start_time_arg	The start time field.
[out]	end_time_arg	The end time field. This can be null when the PS table fields are for the "still processing" information.
[out]	last_transient_errno_arg	The last transient error number.
[out]	last_transient_errmsg_arg	The last transient error message.
[out]	last_transient_errmsg_length_arg	Length of the last transient error message.
[out]	last_transient_timestamp_arg	The last transient error timestamp.
[out]	retries_count_arg	The total number of retries for this transaction.

◆ operator=()

Trx_monitoring_info & Trx_monitoring_info::operator= ( const Trx_monitoring_info & )

default

Member Data Documentation

◆ compressed_bytes

ulonglong Trx_monitoring_info::compressed_bytes

The compressed bytes.

◆ compression_type

mysql::binlog::event::compression::type Trx_monitoring_info::compression_type

The compression type.

◆ end_time

ulonglong Trx_monitoring_info::end_time

When the GTID transaction finished to be processed.

◆ gtid

Gtid Trx_monitoring_info::gtid

GTID being monitored.

◆ immediate_commit_timestamp

ulonglong Trx_monitoring_info::immediate_commit_timestamp

ICT of the GTID being monitored.

◆ is_info_set

bool Trx_monitoring_info::is_info_set

True when this information contains useful data.

◆ is_retrying

bool Trx_monitoring_info::is_retrying

True when the transaction is retrying.

◆ last_transient_error_message

char Trx_monitoring_info::last_transient_error_message[MAX_SLAVE_ERRMSG]

Message of the last transient error of this transaction.

◆ last_transient_error_number

uint Trx_monitoring_info::last_transient_error_number

Number of the last transient error of this transaction.

◆ last_transient_error_timestamp

ulonglong Trx_monitoring_info::last_transient_error_timestamp

Timestamp in microseconds of the last transient error of this transaction.

◆ original_commit_timestamp

ulonglong Trx_monitoring_info::original_commit_timestamp

OCT of the GTID being monitored.

◆ skipped

bool Trx_monitoring_info::skipped

True if the GTID is being applied but will be skipped.

◆ start_time

ulonglong Trx_monitoring_info::start_time

When the GTID transaction started to be processed.

◆ transaction_retries

ulong Trx_monitoring_info::transaction_retries

Number of times this transaction was retried.

◆ uncompressed_bytes

ulonglong Trx_monitoring_info::uncompressed_bytes

The uncompressed bytes.

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

sql/rpl_gtid.h
sql/rpl_gtid_misc.cc

Public Member Functions

Public Attributes

Detailed Description

Constructor & Destructor Documentation

◆ Trx_monitoring_info() [1/2]

◆ Trx_monitoring_info() [2/2]

Member Function Documentation

◆ clear()

◆ copy_to_ps_table() [1/4]

◆ copy_to_ps_table() [2/4]

◆ copy_to_ps_table() [3/4]

◆ copy_to_ps_table() [4/4]

◆ operator=()

Member Data Documentation

◆ compressed_bytes

◆ compression_type

◆ end_time

◆ gtid

◆ immediate_commit_timestamp

◆ is_info_set

◆ is_retrying

◆ last_transient_error_message

◆ last_transient_error_number

◆ last_transient_error_timestamp

◆ original_commit_timestamp

◆ skipped

◆ start_time

◆ transaction_retries

◆ uncompressed_bytes