43 #ifndef TOTEMRRP_H_DEFINED
44 #define TOTEMRRP_H_DEFINED
46 #include <sys/types.h>
47 #include <sys/socket.h>
48 #include <qb/qbloop.h>
51 #define TOTEMRRP_NOFLUSH 0
52 #define TOTEMRRP_FLUSH 1
67 unsigned int msg_len),
69 void (*iface_change_fn) (
72 unsigned int iface_no),
74 void (*token_seqid_get) (
77 unsigned int *token_is),
79 unsigned int (*msgs_missing) (
void),
81 void (*target_set_completed) (
99 unsigned int msg_len);
104 unsigned int msg_len);
109 unsigned int msg_len);
120 unsigned int iface_no);
129 unsigned int *iface_count);
133 const char *cipher_type,
134 const char *hash_type);
138 unsigned int iface_no);
int totemrrp_iface_check(void *rrp_context)
int totemrrp_ifaces_get(void *rrp_context, char ***status, unsigned int *iface_count)
void * totemrrp_buffer_alloc(void *rrp_context)
int totemrrp_finalize(void *rrp_context)
int totemrrp_member_remove(void *rrp_context, const struct totem_ip_address *member, int iface_no)
int totemrrp_crypto_set(void *rrp_context, const char *cipher_type, const char *hash_type)
int totemrrp_send_flush(void *rrp_context)
int totemrrp_member_add(void *rrp_context, const struct totem_ip_address *member, int iface_no)
int totemrrp_initialize(qb_loop_t *poll_handle, void **rrp_context, struct totem_config *totem_config, totemsrp_stats_t *stats, void *context, void(*deliver_fn)(void *context, const void *msg, unsigned int msg_len), void(*iface_change_fn)(void *context, const struct totem_ip_address *iface_addr, unsigned int iface_no), void(*token_seqid_get)(const void *msg, unsigned int *seqid, unsigned int *token_is), unsigned int(*msgs_missing)(void), void(*target_set_completed)(void *context))
Create an instance.
int totemrrp_recv_flush(void *rrp_context)
void totemrrp_buffer_release(void *rrp_context, void *ptr)
char * status[INTERFACE_MAX]
int totemrrp_processor_count_set(void *rrp_context, unsigned int processor_count)
int totemrrp_mcast_noflush_send(void *rrp_context, const void *msg, unsigned int msg_len)
int totemrrp_mcast_recv_empty(void *rrp_context)
int totemrrp_mcast_flush_send(void *rrp_context, const void *msg, unsigned int msg_len)
int totemrrp_ring_reenable(void *rrp_context, unsigned int iface_no)
int totemrrp_token_send(void *rrp_context, const void *msg, unsigned int msg_len)
int totemrrp_token_target_set(void *rrp_context, struct totem_ip_address *addr, unsigned int iface_no)