corosync  2.4.4
Data Structures | Macros | Typedefs | Enumerations | Functions
totempg.h File Reference

Totem Single Ring Protocol. More...

#include <sys/types.h>
#include <netinet/in.h>
#include "totem.h"
#include <qb/qbloop.h>
Include dependency graph for totempg.h:
This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Data Structures

struct  totempg_group
 

Macros

#define TOTEMPG_AGREED   0
 
#define TOTEMPG_SAFE   1
 

Typedefs

typedef void(* totem_queue_level_changed_fn) (enum totem_q_level level)
 

Enumerations

enum  totem_q_level { TOTEM_Q_LEVEL_LOW, TOTEM_Q_LEVEL_GOOD, TOTEM_Q_LEVEL_HIGH, TOTEM_Q_LEVEL_CRITICAL }
 

Functions

int totempg_initialize (qb_loop_t *poll_handle, struct totem_config *totem_config)
 Initialize the totem process groups abstraction. More...
 
void totempg_finalize (void)
 
int totempg_callback_token_create (void **handle_out, enum totem_callback_token_type type, int delete, int(*callback_fn)(enum totem_callback_token_type type, const void *), const void *data)
 
void totempg_callback_token_destroy (void *handle)
 
int totempg_groups_initialize (void **instance, void(*deliver_fn)(unsigned int nodeid, const void *msg, unsigned int msg_len, int endian_conversion_required), void(*confchg_fn)(enum totem_configuration_type configuration_type, const unsigned int *member_list, size_t member_list_entries, const unsigned int *left_list, size_t left_list_entries, const unsigned int *joined_list, size_t joined_list_entries, const struct memb_ring_id *ring_id))
 Initialize a groups instance. More...
 
int totempg_groups_finalize (void *instance)
 
int totempg_groups_join (void *instance, const struct totempg_group *groups, size_t group_cnt)
 
int totempg_groups_leave (void *instance, const struct totempg_group *groups, size_t group_cnt)
 
int totempg_groups_mcast_joined (void *instance, const struct iovec *iovec, unsigned int iov_len, int guarantee)
 
int totempg_groups_joined_reserve (void *instance, const struct iovec *iovec, unsigned int iov_len)
 
int totempg_groups_joined_release (int msg_count)
 
int totempg_groups_mcast_groups (void *instance, int guarantee, const struct totempg_group *groups, size_t groups_cnt, const struct iovec *iovec, unsigned int iov_len)
 
int totempg_groups_send_ok_groups (void *instance, const struct totempg_group *groups, size_t groups_cnt, const struct iovec *iovec, unsigned int iov_len)
 
int totempg_ifaces_get (unsigned int nodeid, struct totem_ip_address *interfaces, unsigned int interfaces_size, char ***status, unsigned int *iface_count)
 
void * totempg_get_stats (void)
 
void totempg_event_signal (enum totem_event_type type, int value)
 
const char * totempg_ifaces_print (unsigned int nodeid)
 
unsigned int totempg_my_nodeid_get (void)
 
int totempg_my_family_get (void)
 
int totempg_crypto_set (const char *cipher_type, const char *hash_type)
 
int totempg_ring_reenable (void)
 
void totempg_service_ready_register (void(*totem_service_ready)(void))
 
int totempg_member_add (const struct totem_ip_address *member, int ring_no)
 
int totempg_member_remove (const struct totem_ip_address *member, int ring_no)
 
void totempg_check_q_level (void *instance)
 
void totempg_queue_level_register_callback (totem_queue_level_changed_fn)
 
void totempg_threaded_mode_enable (void)
 
void totempg_trans_ack (void)
 

Detailed Description

Totem Single Ring Protocol.

depends on poll abstraction, POSIX, IPV4

Definition in file totempg.h.

Macro Definition Documentation

◆ TOTEMPG_AGREED

#define TOTEMPG_AGREED   0

Definition at line 60 of file totempg.h.

◆ TOTEMPG_SAFE

#define TOTEMPG_SAFE   1

Definition at line 61 of file totempg.h.

Typedef Documentation

◆ totem_queue_level_changed_fn

typedef void(* totem_queue_level_changed_fn) (enum totem_q_level level)

Definition at line 182 of file totempg.h.

Enumeration Type Documentation

◆ totem_q_level

Enumerator
TOTEM_Q_LEVEL_LOW 
TOTEM_Q_LEVEL_GOOD 
TOTEM_Q_LEVEL_HIGH 
TOTEM_Q_LEVEL_CRITICAL 

Definition at line 173 of file totempg.h.

Function Documentation

◆ totempg_callback_token_create()

int totempg_callback_token_create ( void **  handle_out,
enum totem_callback_token_type  type,
int  delete,
int(*)(enum totem_callback_token_type type, const void *)  callback_fn,
const void *  data 
)

Definition at line 1080 of file totempg.c.

◆ totempg_callback_token_destroy()

void totempg_callback_token_destroy ( void *  handle)

Definition at line 1099 of file totempg.c.

◆ totempg_check_q_level()

void totempg_check_q_level ( void *  instance)

Definition at line 1275 of file totempg.c.

Referenced by corosync_recheck_the_q_level().

◆ totempg_crypto_set()

int totempg_crypto_set ( const char *  cipher_type,
const char *  hash_type 
)

Definition at line 1444 of file totempg.c.

References totemmrp_crypto_set().

◆ totempg_event_signal()

void totempg_event_signal ( enum totem_event_type  type,
int  value 
)

Definition at line 1434 of file totempg.c.

References totemmrp_event_signal().

◆ totempg_finalize()

void totempg_finalize ( void  )

Definition at line 838 of file totempg.c.

◆ totempg_get_stats()

void* totempg_get_stats ( void  )

Definition at line 1439 of file totempg.c.

◆ totempg_groups_finalize()

int totempg_groups_finalize ( void *  instance)

◆ totempg_groups_initialize()

int totempg_groups_initialize ( void **  instance,
void(*)(unsigned int nodeid, const void *msg, unsigned int msg_len, int endian_conversion_required)  deliver_fn,
void(*)(enum totem_configuration_type configuration_type, const unsigned int *member_list, size_t member_list_entries, const unsigned int *left_list, size_t left_list_entries, const unsigned int *joined_list, size_t joined_list_entries, const struct memb_ring_id *ring_id confchg_fn 
)

Initialize a groups instance.

Definition at line 1115 of file totempg.c.

Referenced by sync_init().

◆ totempg_groups_join()

int totempg_groups_join ( void *  instance,
const struct totempg_group groups,
size_t  group_cnt 
)

Definition at line 1163 of file totempg.c.

◆ totempg_groups_joined_release()

int totempg_groups_joined_release ( int  msg_count)

Definition at line 1327 of file totempg.c.

Referenced by corosync_sending_allowed_release().

◆ totempg_groups_joined_reserve()

int totempg_groups_joined_reserve ( void *  instance,
const struct iovec *  iovec,
unsigned int  iov_len 
)

Definition at line 1283 of file totempg.c.

Referenced by corosync_sending_allowed().

◆ totempg_groups_leave()

int totempg_groups_leave ( void *  instance,
const struct totempg_group groups,
size_t  group_cnt 
)

Definition at line 1195 of file totempg.c.

◆ totempg_groups_mcast_groups()

int totempg_groups_mcast_groups ( void *  instance,
int  guarantee,
const struct totempg_group groups,
size_t  groups_cnt,
const struct iovec *  iovec,
unsigned int  iov_len 
)

Definition at line 1341 of file totempg.c.

References MAX_GROUPS_PER_MSG.

◆ totempg_groups_mcast_joined()

int totempg_groups_mcast_joined ( void *  instance,
const struct iovec *  iovec,
unsigned int  iov_len,
int  guarantee 
)

Definition at line 1213 of file totempg.c.

References MAX_GROUPS_PER_MSG.

Referenced by main_mcast().

◆ totempg_groups_send_ok_groups()

int totempg_groups_send_ok_groups ( void *  instance,
const struct totempg_group groups,
size_t  groups_cnt,
const struct iovec *  iovec,
unsigned int  iov_len 
)

Definition at line 1385 of file totempg.c.

◆ totempg_ifaces_get()

int totempg_ifaces_get ( unsigned int  nodeid,
struct totem_ip_address interfaces,
unsigned int  interfaces_size,
char ***  status,
unsigned int *  iface_count 
)

Definition at line 1415 of file totempg.c.

References totemmrp_ifaces_get().

Referenced by totempg_ifaces_print().

◆ totempg_ifaces_print()

const char* totempg_ifaces_print ( unsigned int  nodeid)

Definition at line 1465 of file totempg.c.

References INTERFACE_MAX, ONE_IFACE_LEN, totemip_print(), and totempg_ifaces_get().

◆ totempg_initialize()

int totempg_initialize ( qb_loop_t *  poll_handle,
struct totem_config totem_config 
)

Initialize the totem process groups abstraction.

Definition at line 787 of file totempg.c.

◆ totempg_member_add()

int totempg_member_add ( const struct totem_ip_address member,
int  ring_no 
)

Definition at line 1513 of file totempg.c.

References totemmrp_member_add().

◆ totempg_member_remove()

int totempg_member_remove ( const struct totem_ip_address member,
int  ring_no 
)

Definition at line 1520 of file totempg.c.

References totemmrp_member_remove().

◆ totempg_my_family_get()

int totempg_my_family_get ( void  )

Definition at line 1498 of file totempg.c.

References totemmrp_my_family_get().

◆ totempg_my_nodeid_get()

unsigned int totempg_my_nodeid_get ( void  )

Definition at line 1493 of file totempg.c.

References totemmrp_my_nodeid_get().

Referenced by message_source_is_local(), and message_source_set().

◆ totempg_queue_level_register_callback()

void totempg_queue_level_register_callback ( totem_queue_level_changed_fn  )

Definition at line 1508 of file totempg.c.

◆ totempg_ring_reenable()

int totempg_ring_reenable ( void  )

Definition at line 1455 of file totempg.c.

References totemmrp_ring_reenable().

◆ totempg_service_ready_register()

void totempg_service_ready_register ( void(*)(void)  totem_service_ready)

Definition at line 1502 of file totempg.c.

References totemmrp_service_ready_register().

◆ totempg_threaded_mode_enable()

void totempg_threaded_mode_enable ( void  )

Definition at line 1527 of file totempg.c.

◆ totempg_trans_ack()

void totempg_trans_ack ( void  )

Definition at line 1533 of file totempg.c.

References totemmrp_trans_ack().