43 #ifndef TOTEMMRP_H_DEFINED
44 #define TOTEMMRP_H_DEFINED
53 int log_level_security,
55 int log_level_warning,
63 qb_loop_t *poll_handle,
71 int endian_conversion_required),
74 const unsigned int *member_list,
size_t member_list_entries,
75 const unsigned int *left_list,
size_t left_list_entries,
76 const unsigned int *joined_list,
size_t joined_list_entries,
78 void (*waiting_trans_ack_cb_fn) (
79 int waiting_trans_ack));
111 unsigned int interfaces_size,
113 unsigned int *iface_count);
124 void (*totem_service_ready) (
void));
int totemmrp_avail(void)
Return number of available messages that can be queued.
int totemmrp_crypto_set(const char *cipher_type, const char *hash_type)
void totemmrp_trans_ack(void)
int totemmrp_member_add(const struct totem_ip_address *member, int ring_no)
The totem_ip_address struct.
int totemmrp_my_family_get(void)
void totemmrp_threaded_mode_enable(void)
totem_configuration_type
The totem_configuration_type enum.
void totemmrp_event_signal(enum totem_event_type type, int value)
int totemmrp_member_remove(const struct totem_ip_address *member, int ring_no)
#define log_printf(level, format, args...)
int totemmrp_ring_reenable(void)
void totemmrp_log_printf_init(void(*log_printf)(int, char *,...), int log_level_security, int log_level_error, int log_level_warning, int log_level_notice, int log_level_debug)
Initialize the logger.
void totemmrp_service_ready_register(void(*totem_service_ready)(void))
int totemmrp_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)
int totemmrp_initialize(qb_loop_t *poll_handle, struct totem_config *totem_config, totempg_stats_t *stats, 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), void(*waiting_trans_ack_cb_fn)(int waiting_trans_ack))
Initialize the group messaging interface.
unsigned int totemmrp_my_nodeid_get(void)
int totemmrp_mcast(struct iovec *iovec, unsigned int iov_len, int priority)
Multicast a message.
int totemmrp_ifaces_get(unsigned int nodeid, struct totem_ip_address *interfaces, unsigned int interfaces_size, char ***status, unsigned int *iface_count)
struct memb_ring_id ring_id
void totemmrp_callback_token_destroy(void *handle_out)
totem_callback_token_type
The totem_callback_token_type enum.
void totemmrp_finalize(void)