replication_thread_status.cc File Reference

#include "sql/changestreams/apply/replication_thread_status.h"
#include "sql/changestreams/apply/constants.h"
#include "sql/rpl_io_monitor.h"

Functions
void	lock_slave_threads (Master_info *mi)
	This method locks both (in this order) mi->run_lock rli->run_lock. More...
void	unlock_slave_threads (Master_info *mi)
	Unlock replica master and relay log info locks. More...
void	init_thread_mask (int *mask, Master_info *mi, bool inverse, bool ignore_monitor_thread)
	Find out which replications threads are running. More...

Function Documentation

init_thread_mask()

void init_thread_mask	(	int *	mask,
		Master_info *	mi,
		bool	inverse,
		bool	ignore_monitor_thread = false
	)

Find out which replications threads are running.

Parameters

mask	Return value here
mi	master_info for slave
inverse	If set, returns which threads are not running
ignore_monitor_thread	If set, ignores monitor io thread

IMPLEMENTATION Get a bit mask for which threads are running.

lock_slave_threads()

void lock_slave_threads

(

Master_info *

mi

)

This method locks both (in this order) mi->run_lock rli->run_lock.

Parameters

mi	The associated master info object

Note

this method shall be invoked while locking mi->m_channel_lock for writes. This is due to the mixed order in which these locks are released and acquired in such method as the slave threads start and stop methods.

unlock_slave_threads()

void unlock_slave_threads

(

Master_info *

mi

)

Unlock replica master and relay log info locks.

Parameters

mi	the repo info object that contains the lock