MySQL  8.0.19
Source Code Documentation
site_def.c File Reference
#include "plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/site_def.h"
#include <assert.h>
#include <stdlib.h>
#include "plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/bitset.h"
#include "plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/node_list.h"
#include "plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/node_no.h"
#include "plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/node_set.h"
#include "plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/server_struct.h"
#include "plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/simset.h"
#include "plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/site_struct.h"
#include "plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/synode_no.h"
#include "plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/task.h"
#include "plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/task_debug.h"
#include "plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/x_platform.h"
#include "plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/xcom_base.h"
#include "plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/xcom_common.h"
#include "plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/xcom_detector.h"
#include "plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/xcom_memory.h"
#include "plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/xcom_profile.h"
#include "plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/xcom_transport.h"
#include "plugin/group_replication/libmysqlgcs/xdr_gen/xcom_vp.h"

Classes

struct  site_def_ptr_array
 

Typedefs

typedef site_defsite_def_ptr
 
typedef struct site_def_ptr_array site_def_ptr_array
 

Functions

 init_xdr_array (free_xdr_array() set_xdr_array(site_def_ptr) static site_def_ptr_array site_defs site_def_ptr)
 
site_defend_site_def (synode_no start)
 
void get_all_site_defs (site_def ***s, uint32_t *n)
 
void init_site_vars ()
 
void free_site_def (site_def *s)
 
void free_site_defs ()
 
site_defpush_site_def (site_def *s)
 
static const site_def_get_site_def ()
 
site_defget_site_def_rw ()
 
static const site_def_get_prev_site_def ()
 
const site_defget_site_def ()
 
const site_defget_prev_site_def ()
 
static int match_def (site_def const *site, synode_no synode)
 
const site_deffind_site_def (synode_no synode)
 
site_deffind_site_def_rw (synode_no synode)
 
static int start_gt (site_def const *site, synode_no synode)
 
const site_deffind_next_site_def (synode_no synode)
 
static int prev_def (site_def const *site, synode_no synode)
 
const site_deffind_prev_site_def (synode_no synode)
 
void garbage_collect_site_defs (synode_no x)
 
char * dbg_site_def (site_def const *site)
 
site_defnew_site_def ()
 
site_defclone_site_def (site_def const *site)
 
void init_site_def (u_int n, node_address *names, site_def *site)
 
void add_site_def (u_int n, node_address *names, site_def *site)
 
void remove_site_def (u_int n, node_address *names, site_def *site)
 
synode_no get_boot_key ()
 
void set_boot_key (synode_no const x)
 
uint32_t get_group_id (site_def const *site)
 
static node_no _get_maxnodes (site_def const *site)
 
node_no get_maxnodes (site_def const *site)
 
node_no get_prev_maxnodes ()
 
static node_no _get_nodeno (site_def const *site)
 
node_no get_nodeno (site_def const *site)
 
node_no find_nodeno (site_def const *site, const char *address)
 
node_no get_prev_nodeno ()
 
synode_no config_max_boot_key (gcs_snapshot const *gcs_snap)
 
void import_config (gcs_snapshot *gcs_snap)
 
gcs_snapshot * export_config ()
 
synode_no get_min_delivered_msg (site_def const *s)
 
void update_delivered (site_def *s, node_no node, synode_no msgno)
 

Variables

synode_no executed_msg
 

Typedef Documentation

◆ site_def_ptr

◆ site_def_ptr_array

Function Documentation

◆ _get_maxnodes()

static node_no _get_maxnodes ( site_def const *  site)
inlinestatic

◆ _get_nodeno()

static node_no _get_nodeno ( site_def const *  site)
inlinestatic

◆ _get_prev_site_def()

static const site_def* _get_prev_site_def ( )
inlinestatic

◆ _get_site_def()

static const site_def* _get_site_def ( )
inlinestatic

◆ add_site_def()

void add_site_def ( u_int  n,
node_address *  names,
site_def site 
)

◆ clone_site_def()

site_def* clone_site_def ( site_def const *  site)

◆ config_max_boot_key()

synode_no config_max_boot_key ( gcs_snapshot const *  gcs_snap)

◆ dbg_site_def()

char* dbg_site_def ( site_def const *  site)

◆ end_site_def()

site_def* end_site_def ( synode_no  start)

◆ export_config()

gcs_snapshot* export_config ( )

◆ find_next_site_def()

const site_def* find_next_site_def ( synode_no  synode)

◆ find_nodeno()

node_no find_nodeno ( site_def const *  site,
const char *  address 
)

◆ find_prev_site_def()

const site_def* find_prev_site_def ( synode_no  synode)

◆ find_site_def()

const site_def* find_site_def ( synode_no  synode)

◆ find_site_def_rw()

site_def* find_site_def_rw ( synode_no  synode)

◆ free_site_def()

void free_site_def ( site_def s)

◆ free_site_defs()

void free_site_defs ( )

◆ garbage_collect_site_defs()

void garbage_collect_site_defs ( synode_no  x)

◆ get_all_site_defs()

void get_all_site_defs ( site_def ***  s,
uint32_t *  n 
)

◆ get_boot_key()

synode_no get_boot_key ( )

◆ get_group_id()

uint32_t get_group_id ( site_def const *  site)

◆ get_maxnodes()

node_no get_maxnodes ( site_def const *  site)

◆ get_min_delivered_msg()

synode_no get_min_delivered_msg ( site_def const *  s)

◆ get_nodeno()

node_no get_nodeno ( site_def const *  site)

◆ get_prev_maxnodes()

node_no get_prev_maxnodes ( )

◆ get_prev_nodeno()

node_no get_prev_nodeno ( )

◆ get_prev_site_def()

const site_def* get_prev_site_def ( )

◆ get_site_def()

const site_def* get_site_def ( )

◆ get_site_def_rw()

site_def* get_site_def_rw ( )

◆ import_config()

void import_config ( gcs_snapshot *  gcs_snap)

◆ init_site_def()

void init_site_def ( u_int  n,
node_address *  names,
site_def site 
)

◆ init_site_vars()

void init_site_vars ( )

◆ init_xdr_array()

init_xdr_array ( free_xdr_array() set_xdr_array(site_def_ptr) static site_def_ptr_array site_defs  site_def_ptr)

◆ match_def()

static int match_def ( site_def const *  site,
synode_no  synode 
)
inlinestatic

◆ new_site_def()

site_def* new_site_def ( )

◆ prev_def()

static int prev_def ( site_def const *  site,
synode_no  synode 
)
inlinestatic

◆ push_site_def()

site_def* push_site_def ( site_def s)

◆ remove_site_def()

void remove_site_def ( u_int  n,
node_address *  names,
site_def site 
)

◆ set_boot_key()

void set_boot_key ( synode_no const  x)

◆ start_gt()

static int start_gt ( site_def const *  site,
synode_no  synode 
)
inlinestatic

◆ update_delivered()

void update_delivered ( site_def s,
node_no  node,
synode_no  msgno 
)

Variable Documentation

◆ executed_msg

synode_no executed_msg