MySQL 8.3.0
Source Code Documentation
semisync_source_ack_receiver.cc File Reference
#include "plugin/semisync/semisync_source_ack_receiver.h"
#include "my_config.h"
#include <errno.h>
#include "my_compiler.h"
#include "my_dbug.h"
#include "my_psi_config.h"
#include "mysql/psi/mysql_stage.h"
#include "mysqld_error.h"
#include "plugin/semisync/semisync.h"
#include "plugin/semisync/semisync_source.h"
#include "plugin/semisync/semisync_source_socket_listener.h"
#include "sql/protocol_classic.h"
#include "sql/sql_class.h"

Functions

static void * ack_receive_handler (void *arg)
 
static void init_net (NET *net, unsigned char *buff, unsigned int buff_len)
 

Variables

ReplSemiSyncMasterrepl_semisync
 
PSI_stage_info stage_waiting_for_semi_sync_ack_from_replica
 
PSI_stage_info stage_waiting_for_semi_sync_replica
 
PSI_stage_info stage_reading_semi_sync_ack
 
PSI_mutex_key key_ss_mutex_Ack_receiver_mutex
 
PSI_cond_key key_ss_cond_Ack_receiver_cond
 
PSI_thread_key key_ss_thread_Ack_receiver_thread
 

Function Documentation

◆ ack_receive_handler()

static void * ack_receive_handler ( void *  arg)
static

◆ init_net()

static void init_net ( NET net,
unsigned char *  buff,
unsigned int  buff_len 
)
static

Variable Documentation

◆ key_ss_cond_Ack_receiver_cond

PSI_cond_key key_ss_cond_Ack_receiver_cond
extern

◆ key_ss_mutex_Ack_receiver_mutex

PSI_mutex_key key_ss_mutex_Ack_receiver_mutex
extern

◆ key_ss_thread_Ack_receiver_thread

PSI_thread_key key_ss_thread_Ack_receiver_thread
extern

◆ repl_semisync

ReplSemiSyncMaster* repl_semisync
extern

◆ stage_reading_semi_sync_ack

PSI_stage_info stage_reading_semi_sync_ack
extern

◆ stage_waiting_for_semi_sync_ack_from_replica

PSI_stage_info stage_waiting_for_semi_sync_ack_from_replica
extern

◆ stage_waiting_for_semi_sync_replica

PSI_stage_info stage_waiting_for_semi_sync_replica
extern