MySQL  8.0.22
Source Code Documentation
gcs_xcom_control_interface.cc File Reference

Classes

struct  Gcs_member_identifier_pointer_comparator
 

Functions

static void set_terminate_suspicion_thread (bool val)
 
static bool is_terminate_suspicion_thread ()
 
static void * suspicions_processing_thread (void *ptr)
 
static void * xcom_taskmain_startup (void *ptr)
 
void do_function_join (Gcs_control_interface *control_if)
 
static bool skip_own_peer_address (std::map< std::string, int > const &my_own_addresses, int my_own_port, std::string &peer_address, int peer_port)
 
void do_function_leave (Gcs_control_interface *control_if)
 

Variables

int ARBITRATOR_HACK
 
static const uint64_t NON_MEMBER_EXPEL_TIMEOUT = 60 * 10000000
 
static const unsigned int SUSPICION_PROCESSING_THREAD_PERIOD = 15
 
static bool terminate_suspicion_thread = false
 

Function Documentation

◆ do_function_join()

void do_function_join ( Gcs_control_interface control_if)

◆ do_function_leave()

void do_function_leave ( Gcs_control_interface control_if)

◆ is_terminate_suspicion_thread()

static bool is_terminate_suspicion_thread ( )
static

◆ set_terminate_suspicion_thread()

static void set_terminate_suspicion_thread ( bool  val)
static

◆ skip_own_peer_address()

static bool skip_own_peer_address ( std::map< std::string, int > const &  my_own_addresses,
int  my_own_port,
std::string &  peer_address,
int  peer_port 
)
static

◆ suspicions_processing_thread()

static void* suspicions_processing_thread ( void *  ptr)
static

◆ xcom_taskmain_startup()

static void* xcom_taskmain_startup ( void *  ptr)
static

Variable Documentation

◆ ARBITRATOR_HACK

int ARBITRATOR_HACK

◆ NON_MEMBER_EXPEL_TIMEOUT

const uint64_t NON_MEMBER_EXPEL_TIMEOUT = 60 * 10000000
static

◆ SUSPICION_PROCESSING_THREAD_PERIOD

const unsigned int SUSPICION_PROCESSING_THREAD_PERIOD = 15
static

◆ terminate_suspicion_thread

bool terminate_suspicion_thread = false
static