rpl_io_monitor.cc File Reference

#include "sql/rpl_io_monitor.h"
#include <mysql/components/my_service.h>
#include <mysql/components/services/group_replication_status_service.h>
#include "mysql/components/services/log_builtins.h"
#include "sql-common/json_dom.h"
#include "sql/changestreams/apply/replication_thread_status.h"
#include "sql/mysqld.h"
#include "sql/mysqld_thd_manager.h"
#include "sql/protocol_classic.h"
#include "sql/rpl_async_conn_failover.h"
#include "sql/rpl_async_conn_failover_configuration_propagation.h"
#include "sql/rpl_group_replication.h"
#include "sql/rpl_msr.h"
#include "sql/rpl_replica.h"
#include "sql/rpl_sys_key_access.h"
#include "sql/rpl_sys_table_access.h"
#include "sql/sql_class.h"
#include "sql/udf_service_util.h"
#include "my_dbug.h"
#include "my_systime.h"
#include <string>

Functions
static bool	restart_io_thread (THD *thd, const std::string &channel_name, bool force_sender_with_highest_weight)
	Restart the IO thread of the given channel. More...
MYSQL_RES_TUPLE	execute_query (const Mysql_connection *conn, enum_sql_query_tag qtag)
static void *	launch_handler_thread (void *arg)

Variables
static const char *	SQL_QUERIES []

Function Documentation

execute_query()

MYSQL_RES_TUPLE execute_query	(	const Mysql_connection *	conn,
		enum_sql_query_tag	qtag
	)

launch_handler_thread()

static void * launch_handler_thread ( void *  arg )

static

restart_io_thread()

static bool restart_io_thread ( THD *  thd, const std::string &  channel_name, bool  force_sender_with_highest_weight  )

static

Restart the IO thread of the given channel.

Parameters

[in]	thd	The running thread.
[in]	channel_name	the channel IO thread to restart.
[in]	force_sender_with_highest_weight	When true, sender with highest weight is chosen, otherwise the next sender from the current one is chosen.

Returns

true if IO thread was restarted, false otherwise.

Variable Documentation

SQL_QUERIES

const char* SQL_QUERIES[]

static