MySQL 9.1.0
Source Code Documentation
site_def.cc File Reference
#include "xcom/site_def.h"
#include <assert.h>
#include <stdlib.h>
#include <algorithm>
#include <iterator>
#include "xcom/bitset.h"
#include "xcom/node_list.h"
#include "xcom/node_no.h"
#include "xcom/node_set.h"
#include "xcom/server_struct.h"
#include "xcom/simset.h"
#include "xcom/site_struct.h"
#include "xcom/synode_no.h"
#include "xcom/task.h"
#include "xcom/task_debug.h"
#include "xcom/x_platform.h"
#include "xcom/xcom_base.h"
#include "xcom/xcom_common.h"
#include "xcom/xcom_detector.h"
#include "xcom/xcom_memory.h"
#include "xcom/xcom_profile.h"
#include "xcom/xcom_transport.h"
#include "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 (site_def_ptr) free_xdr_array(site_def_ptr) set_xdr_array(site_def_ptr) static site_def_ptr_array site_defs
 
static node_no _get_maxnodes (site_def const *site)
 
void get_all_site_defs (site_def ***s, uint32_t *n)
 
void init_site_vars ()
 
void free_site_def_body (site_def *s)
 
void free_site_def (site_def *s)
 
void free_site_defs ()
 
site_defpush_site_def (site_def *s)
 
static site_def const * _get_site_def ()
 
site_defget_site_def_rw ()
 
static site_def const * _get_prev_site_def ()
 
site_def const * get_site_def ()
 
site_def const * get_prev_site_def ()
 
static int match_def (site_def const *site, synode_no synode)
 
site_def const * find_site_def (synode_no synode)
 
site_deffind_site_def_rw (synode_no synode)
 
static int start_gt (site_def const *site, synode_no synode)
 
site_def const * find_next_site_def (synode_no synode)
 
static int prev_def (site_def const *site, synode_no synode)
 
site_def const * find_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 ()
 
static void clone_leader (leader *l, leader const *x)
 
leader_array alloc_leader_array (u_int n)
 
leader_array clone_leader_array (leader_array const x)
 
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)
 
uint32_t get_group_id (site_def const *site)
 
node_no get_maxnodes (site_def const *site)
 
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)
 
static synode_no get_conf_max ()
 
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)
 
synode_no get_highest_boot_key (gcs_snapshot *gcs_snap)
 

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 site_def const * _get_prev_site_def ( )
inlinestatic

◆ _get_site_def()

static site_def const * _get_site_def ( )
inlinestatic

◆ add_site_def()

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

◆ alloc_leader_array()

leader_array alloc_leader_array ( u_int  n)

◆ clone_leader()

static void clone_leader ( leader *  l,
leader const *  x 
)
static

◆ clone_leader_array()

leader_array clone_leader_array ( leader_array const  x)

◆ 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)

◆ export_config()

gcs_snapshot * export_config ( )

◆ find_next_site_def()

site_def const * find_next_site_def ( synode_no  synode)

◆ find_nodeno()

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

◆ find_prev_site_def()

site_def const * find_prev_site_def ( synode_no  synode)

◆ find_site_def()

site_def const * 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_def_body()

void free_site_def_body ( 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_conf_max()

static synode_no get_conf_max ( )
static

◆ get_group_id()

uint32_t get_group_id ( site_def const *  site)

◆ get_highest_boot_key()

synode_no get_highest_boot_key ( gcs_snapshot *  gcs_snap)

◆ 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_nodeno()

node_no get_prev_nodeno ( )

◆ get_prev_site_def()

site_def const * get_prev_site_def ( )

◆ get_site_def()

site_def const * 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 ( 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 
)

◆ 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
extern