gcs_xcom_control_interface.cc File Reference

#include "plugin/group_replication/libmysqlgcs/src/bindings/xcom/gcs_xcom_control_interface.h"
#include "plugin/group_replication/libmysqlgcs/include/mysql/gcs/gcs_logging_system.h"
#include "plugin/group_replication/libmysqlgcs/src/bindings/xcom/gcs_xcom_communication_interface.h"
#include "plugin/group_replication/libmysqlgcs/src/bindings/xcom/gcs_xcom_group_member_information.h"
#include "plugin/group_replication/libmysqlgcs/src/bindings/xcom/gcs_xcom_interface.h"
#include "plugin/group_replication/libmysqlgcs/src/bindings/xcom/gcs_xcom_notification.h"
#include "plugin/group_replication/libmysqlgcs/src/bindings/xcom/gcs_xcom_utils.h"
#include "plugin/group_replication/libmysqlgcs/src/bindings/xcom/gcs_xcom_view_identifier.h"
#include "plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/node_no.h"
#include "plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/synode_no.h"
#include <assert.h>
#include <algorithm>
#include <iostream>
#include <iterator>
#include <list>

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)
static constexpr const char *	get_signaling_error ()
static const std::string	get_connection_test_error (const std::string &address, int port)
void	do_function_leave (Gcs_control_interface *control_if)
uint32_t	get_my_xcom_id ()

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

)

get_connection_test_error()

static const std::string get_connection_test_error ( const std::string &  address, int  port  )

static

get_my_xcom_id()

uint32_t get_my_xcom_id

(

)

get_signaling_error()

static constexpr const char * get_signaling_error ( )

staticconstexpr

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

extern

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