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
ReplSemiSyncSource *	repl_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

ReplSemiSyncSource* 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