rpl_rli_pdb.h File Reference

#include <stdarg.h>
#include <sys/types.h>
#include <time.h>
#include <atomic>
#include <tuple>
#include "my_bitmap.h"
#include "my_compiler.h"
#include "my_dbug.h"
#include "my_inttypes.h"
#include "my_io.h"
#include "my_psi_config.h"
#include "mysql/binlog/event/binlog_event.h"
#include "mysql/components/services/bits/mysql_cond_bits.h"
#include "mysql/components/services/bits/mysql_mutex_bits.h"
#include "mysql/components/services/bits/psi_bits.h"
#include "mysql/components/services/bits/psi_mutex_bits.h"
#include "mysql/my_loglevel.h"
#include "mysql/service_mysql_alloc.h"
#include "prealloced_array.h"
#include "sql/changestreams/apply/metrics/applier_metrics.h"
#include "sql/changestreams/apply/metrics/dummy_worker_metrics.h"
#include "sql/changestreams/apply/metrics/mta_worker_metrics.h"
#include "sql/log_event.h"
#include "sql/rpl_gtid.h"
#include "sql/rpl_mta_submode.h"
#include "sql/rpl_replica.h"
#include "sql/rpl_rli.h"
#include "sql/sql_class.h"
#include "sql/system_variables.h"

Go to the source code of this file.

Classes
struct	Slave_job_group
class	circular_buffer_queue< Element_type >
	The class defines a type of queue with a predefined max capacity that is implemented using the circular memory buffer. More...
class	Slave_committed_queue
	Group Assigned Queue whose first element identifies first gap in committed sequence. More...
class	Slave_jobs_queue
class	Slave_worker

Functions
Slave_worker *	get_least_occupied_worker (Relay_log_info *rli, Slave_worker_array *workers, Log_event *ev)
	Legends running throughout the module: More...
bool	handle_slave_worker_stop (Slave_worker *worker, Slave_job_item *job_item)
	This function is called by both coordinator and workers. More...
bool	set_max_updated_index_on_stop (Slave_worker *worker, Slave_job_item *job_item)
	This function is called by both coordinator and workers. More...
TABLE *	mts_move_temp_tables_to_thd (THD *, TABLE *)
	Relocation of the list of temporary tables to thd->temporary_tables. More...
TABLE *	mts_move_temp_tables_to_thd (THD *, TABLE *, enum_mts_parallel_type)
bool	append_item_to_jobs (slave_job_item *job_item, Slave_worker *w, Relay_log_info *rli)
	Coordinator enqueues a job item into a Worker private queue. More...
Slave_worker *	get_thd_worker (const THD *thd)
int	slave_worker_exec_job_group (Slave_worker *w, Relay_log_info *rli)
	apply one job group. More...

Variables
ulong	w_rr

Function Documentation

append_item_to_jobs()

bool append_item_to_jobs	(	slave_job_item *	job_item,
		Slave_worker *	worker,
		Relay_log_info *	rli
	)

Coordinator enqueues a job item into a Worker private queue.

Parameters

job_item	a pointer to struct carrying a reference to an event
worker	a pointer to the assigned Worker struct
rli	a pointer to Relay_log_info of Coordinator

Returns

false Success. true Thread killed or worker stopped while waiting for successful enqueue.

get_least_occupied_worker()

Slave_worker * get_least_occupied_worker	(	Relay_log_info *	rli,
		Slave_worker_array *	ws,
		Log_event *	ev
	)

Legends running throughout the module:

C - Coordinator CP - checkpoint W - Worker

B-event event that Begins a group (a transaction) T-event event that Terminates a group (a transaction)

Legends running throughout the module:

Parameters

rli	pointer to Relay_log_info of Coordinator
ws	dynarray of pointers to Slave_worker
ev	event for which we are searching for a worker

Returns

a pointer to chosen Slave_worker instance

get_thd_worker()

Slave_worker * get_thd_worker ( const THD *  thd )

inline

handle_slave_worker_stop()

bool handle_slave_worker_stop	(	Slave_worker *	worker,
		Slave_job_item *	job_item
	)

This function is called by both coordinator and workers.

Upon receiving the STOP command, the workers will identify a maximum group index already executed (or under execution).

All groups whose index are below or equal to the maximum group index will be applied by the workers before stopping.

The workers with groups above the maximum group index will exit without applying these groups by setting their running status to "STOP_ACCEPTED".

Parameters

worker	a pointer to the waiting Worker struct
job_item	a pointer to struct carrying a reference to an event

Returns

true if STOP command gets accepted otherwise false is returned.

mts_move_temp_tables_to_thd() [1/2]

TABLE * mts_move_temp_tables_to_thd	(	THD *	thd,
		TABLE *	temporary_tables
	)

Relocation of the list of temporary tables to thd->temporary_tables.

Parameters

thd	THD instance pointer of the destination
temporary_tables	the source temporary_tables list

Note

destroying references to the source list, if necessary, is left to the caller.

Returns

the post-merge value of thd->temporary_tables.

mts_move_temp_tables_to_thd() [2/2]

TABLE * mts_move_temp_tables_to_thd	(	THD *	,
		TABLE *	,
		enum_mts_parallel_type
	)

set_max_updated_index_on_stop()

bool set_max_updated_index_on_stop	(	Slave_worker *	worker,
		Slave_job_item *	job_item
	)

This function is called by both coordinator and workers.

Both coordinator and workers contribute to max_updated_index.

Parameters

worker	a pointer to the waiting Worker struct
job_item	a pointer to struct carrying a reference to an event

Returns

true if STOP command gets accepted otherwise false is returned.

slave_worker_exec_job_group()

int slave_worker_exec_job_group	(	Slave_worker *	worker,
		Relay_log_info *	rli
	)

apply one job group.

Note

the function maintains worker's CGEP and modifies APH, updates the current group item in GAQ via slave_worker_ends_group().

param[in] worker the worker which calls it. param[in] rli slave's relay log info object.

return returns 0 if the group of jobs are applied successfully, otherwise returns an error code.

Variable Documentation

w_rr

ulong w_rr

extern