MySQL 8.4.3
Source Code Documentation
|
#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 [] |
MYSQL_RES_TUPLE execute_query | ( | const Mysql_connection * | conn, |
enum_sql_query_tag | qtag | ||
) |
|
static |
|
static |
Restart the IO thread of the given channel.
[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. |
|
static |