#include <config.h>
#include <assert.h>
#include <sys/mman.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <sys/socket.h>
#include <netdb.h>
#include <sys/un.h>
#include <sys/ioctl.h>
#include <sys/param.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <unistd.h>
#include <fcntl.h>
#include <stdlib.h>
#include <stdio.h>
#include <errno.h>
#include <sched.h>
#include <time.h>
#include <sys/time.h>
#include <sys/poll.h>
#include <sys/uio.h>
#include <limits.h>
#include <qb/qbdefs.h>
#include <qb/qbutil.h>
#include <qb/qbloop.h>
#include <corosync/swab.h>
#include <corosync/sq.h>
#include <corosync/list.h>
#include <corosync/logsys.h>
#include "totemsrp.h"
#include "totemrrp.h"
#include "totemnet.h"
#include "cs_queue.h"

Include dependency graph for totemsrp.c:

Data Structures
struct	consensus_list_item

struct	token_callback_instance

struct	totemsrp_socket

struct	message_header

struct	mcast

struct	rtr_item

struct	orf_token

struct	memb_join

struct	memb_merge_detect

struct	token_hold_cancel

struct	memb_commit_token_memb_entry

struct	memb_commit_token

struct	message_item

struct	sort_queue_item

struct	totemsrp_instance

struct	message_handlers

Macros
#define	LOGSYS_UTILS_ONLY 1

#define	LOCALHOST_IP inet_addr("127.0.0.1")

#define	QUEUE_RTR_ITEMS_SIZE_MAX 16384 /* allow 16384 retransmit items */

#define	RETRANS_MESSAGE_QUEUE_SIZE_MAX 16384 /* allow 500 messages to be queued */

#define	RECEIVED_MESSAGE_QUEUE_SIZE_MAX 500 /* allow 500 messages to be queued */

#define	MAXIOVS 5

#define	RETRANSMIT_ENTRIES_MAX 30

#define	TOKEN_SIZE_MAX 64000 /* bytes */

#define	LEAVE_DUMMY_NODEID 0

#define	SEQNO_START_MSG 0x0

#define	SEQNO_START_TOKEN 0x0

#define	ENDIAN_LOCAL 0xff22

#define	log_printf(level, format, args...)

#define	LOGSYS_PERROR(err_num, level, fmt, args...)

Enumerations
enum	message_type { MESSAGE_TYPE_ORF_TOKEN = 0, MESSAGE_TYPE_MCAST = 1, MESSAGE_TYPE_MEMB_MERGE_DETECT = 2, MESSAGE_TYPE_MEMB_JOIN = 3, MESSAGE_TYPE_MEMB_COMMIT_TOKEN = 4, MESSAGE_TYPE_TOKEN_HOLD_CANCEL = 5 }

enum	encapsulation_type { MESSAGE_ENCAPSULATED = 1, MESSAGE_NOT_ENCAPSULATED = 2 }

enum	memb_state { MEMB_STATE_OPERATIONAL = 1, MEMB_STATE_GATHER = 2, MEMB_STATE_COMMIT = 3, MEMB_STATE_RECOVERY = 4 }

enum	gather_state_from { TOTEMSRP_GSFROM_CONSENSUS_TIMEOUT = 0, TOTEMSRP_GSFROM_GATHER_MISSING1 = 1, TOTEMSRP_GSFROM_THE_TOKEN_WAS_LOST_IN_THE_OPERATIONAL_STATE = 2, TOTEMSRP_GSFROM_THE_CONSENSUS_TIMEOUT_EXPIRED = 3, TOTEMSRP_GSFROM_THE_TOKEN_WAS_LOST_IN_THE_COMMIT_STATE = 4, TOTEMSRP_GSFROM_THE_TOKEN_WAS_LOST_IN_THE_RECOVERY_STATE = 5, TOTEMSRP_GSFROM_FAILED_TO_RECEIVE = 6, TOTEMSRP_GSFROM_FOREIGN_MESSAGE_IN_OPERATIONAL_STATE = 7, TOTEMSRP_GSFROM_FOREIGN_MESSAGE_IN_GATHER_STATE = 8, TOTEMSRP_GSFROM_MERGE_DURING_OPERATIONAL_STATE = 9, TOTEMSRP_GSFROM_MERGE_DURING_GATHER_STATE = 10, TOTEMSRP_GSFROM_MERGE_DURING_JOIN = 11, TOTEMSRP_GSFROM_JOIN_DURING_OPERATIONAL_STATE = 12, TOTEMSRP_GSFROM_JOIN_DURING_COMMIT_STATE = 13, TOTEMSRP_GSFROM_JOIN_DURING_RECOVERY = 14, TOTEMSRP_GSFROM_INTERFACE_CHANGE = 15, TOTEMSRP_GSFROM_MAX = TOTEMSRP_GSFROM_INTERFACE_CHANGE }

Functions
struct message_header	__attribute__ ((packed))

void	main_deliver_fn (void context, const void msg, unsigned int msg_len)

void	main_iface_change_fn (void context, const struct totem_ip_address iface_address, unsigned int iface_no)

int	totemsrp_initialize (qb_loop_t poll_handle, void srp_context, struct totem_config totem_config, totemmrp_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))
	Create a protocol instance. More...

void	totemsrp_finalize (void *srp_context)

int	totemsrp_ifaces_get (void srp_context, unsigned int nodeid, struct totem_ip_address interfaces, unsigned int interfaces_size, char **status, unsigned int iface_count)

int	totemsrp_crypto_set (void srp_context, const char cipher_type, const char *hash_type)

unsigned int	totemsrp_my_nodeid_get (void *srp_context)

int	totemsrp_my_family_get (void *srp_context)

int	totemsrp_ring_reenable (void *srp_context)

void	totemsrp_event_signal (void *srp_context, enum totem_event_type type, int value)

int	totemsrp_mcast (void srp_context, struct iovec iovec, unsigned int iov_len, int guarantee)
	Multicast a message. More...

int	totemsrp_avail (void *srp_context)
	Return number of available messages that can be queued. More...

int	totemsrp_callback_token_create (void srp_context, 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	totemsrp_callback_token_destroy (void srp_context, void *handle_out)

void	totemsrp_net_mtu_adjust (struct totem_config *totem_config)

void	totemsrp_service_ready_register (void context, void(totem_service_ready)(void))

int	totemsrp_member_add (void context, const struct totem_ip_address member, int ring_no)

int	totemsrp_member_remove (void context, const struct totem_ip_address member, int ring_no)

void	totemsrp_threaded_mode_enable (void *context)

void	totemsrp_trans_ack (void *context)

Variables
char	type

char	encapsulated

unsigned short	endian_detector

unsigned int	nodeid

struct message_header	header

struct srp_addr	system_from

unsigned int	seq

int	this_seqno

struct memb_ring_id	ring_id

unsigned int	node_id

int	guarantee

unsigned int	token_seq

unsigned int	aru

unsigned int	aru_addr

unsigned int	backlog

unsigned int	fcc

int	retrans_flg

int	rtr_list_entries

struct rtr_item	rtr_list [0]

unsigned int	proc_list_entries

unsigned int	failed_list_entries

unsigned long long	ring_seq

unsigned char	end_of_memb_join [0]

unsigned int	high_delivered

unsigned int	received_flg

int	memb_index

int	addr_entries

unsigned char	end_of_commit_token [0]

struct message_item	__attribute__

const char *	gather_state_from_desc []

struct message_handlers	totemsrp_message_handlers

unsigned long long int	tv_old

Macro Definition Documentation

◆ ENDIAN_LOCAL

#define ENDIAN_LOCAL 0xff22

Definition at line 137 of file totemsrp.c.

Referenced by main_deliver_fn().

◆ LEAVE_DUMMY_NODEID

#define LEAVE_DUMMY_NODEID 0

Definition at line 102 of file totemsrp.c.

◆ LOCALHOST_IP

#define LOCALHOST_IP inet_addr("127.0.0.1")

Definition at line 95 of file totemsrp.c.

◆ log_printf

#define log_printf	(	level,
		format,
		args...
	)

Value:

do {                                                    \
        instance->totemsrp_log_printf (                 \
                level, instance->totemsrp_subsys_id,    \
                __FUNCTION__, __FILE__, __LINE__,       \
                format, ##args);                        \
} while (0);

Definition at line 691 of file totemsrp.c.

Referenced by main_deliver_fn(), and main_iface_change_fn().

◆ LOGSYS_PERROR

#define LOGSYS_PERROR	(	err_num,
		level,
		fmt,
		args...
	)

Value:

do {                                                                                            \
        char _error_str[LOGSYS_MAX_PERROR_MSG_LEN];                                             \
        const char *_error_ptr = qb_strerror_r(err_num, _error_str, sizeof(_error_str));        \
        instance->totemsrp_log_printf (                                                         \
                level, instance->totemsrp_subsys_id,                                            \
                __FUNCTION__, __FILE__, __LINE__,                                               \
                fmt ": %s (%d)\n", ##args, _error_ptr, err_num);                                \
        } while(0)

Definition at line 698 of file totemsrp.c.

◆ LOGSYS_UTILS_ONLY

#define LOGSYS_UTILS_ONLY 1

Definition at line 86 of file totemsrp.c.

◆ MAXIOVS

#define MAXIOVS 5

Definition at line 99 of file totemsrp.c.

◆ QUEUE_RTR_ITEMS_SIZE_MAX

#define QUEUE_RTR_ITEMS_SIZE_MAX 16384 /* allow 16384 retransmit items */

Definition at line 96 of file totemsrp.c.

◆ RECEIVED_MESSAGE_QUEUE_SIZE_MAX

#define RECEIVED_MESSAGE_QUEUE_SIZE_MAX 500 /* allow 500 messages to be queued */

Definition at line 98 of file totemsrp.c.

◆ RETRANS_MESSAGE_QUEUE_SIZE_MAX

#define RETRANS_MESSAGE_QUEUE_SIZE_MAX 16384 /* allow 500 messages to be queued */

Definition at line 97 of file totemsrp.c.

◆ RETRANSMIT_ENTRIES_MAX

#define RETRANSMIT_ENTRIES_MAX 30

Definition at line 100 of file totemsrp.c.

◆ SEQNO_START_MSG

#define SEQNO_START_MSG 0x0

Definition at line 114 of file totemsrp.c.

◆ SEQNO_START_TOKEN

#define SEQNO_START_TOKEN 0x0

Definition at line 115 of file totemsrp.c.

◆ TOKEN_SIZE_MAX

#define TOKEN_SIZE_MAX 64000 /* bytes */

Definition at line 101 of file totemsrp.c.

Enumeration Type Documentation

◆ encapsulation_type

enum encapsulation_type

Enumerator
MESSAGE_ENCAPSULATED
MESSAGE_NOT_ENCAPSULATED

Definition at line 148 of file totemsrp.c.

◆ gather_state_from

enum gather_state_from

Enumerator
TOTEMSRP_GSFROM_CONSENSUS_TIMEOUT
TOTEMSRP_GSFROM_GATHER_MISSING1
TOTEMSRP_GSFROM_THE_TOKEN_WAS_LOST_IN_THE_OPERATIONAL_STATE
TOTEMSRP_GSFROM_THE_CONSENSUS_TIMEOUT_EXPIRED
TOTEMSRP_GSFROM_THE_TOKEN_WAS_LOST_IN_THE_COMMIT_STATE
TOTEMSRP_GSFROM_THE_TOKEN_WAS_LOST_IN_THE_RECOVERY_STATE
TOTEMSRP_GSFROM_FAILED_TO_RECEIVE
TOTEMSRP_GSFROM_FOREIGN_MESSAGE_IN_OPERATIONAL_STATE
TOTEMSRP_GSFROM_FOREIGN_MESSAGE_IN_GATHER_STATE
TOTEMSRP_GSFROM_MERGE_DURING_OPERATIONAL_STATE
TOTEMSRP_GSFROM_MERGE_DURING_GATHER_STATE
TOTEMSRP_GSFROM_MERGE_DURING_JOIN
TOTEMSRP_GSFROM_JOIN_DURING_OPERATIONAL_STATE
TOTEMSRP_GSFROM_JOIN_DURING_COMMIT_STATE
TOTEMSRP_GSFROM_JOIN_DURING_RECOVERY
TOTEMSRP_GSFROM_INTERFACE_CHANGE
TOTEMSRP_GSFROM_MAX

Definition at line 537 of file totemsrp.c.

◆ memb_state

enum memb_state

Enumerator
MEMB_STATE_OPERATIONAL
MEMB_STATE_GATHER
MEMB_STATE_COMMIT
MEMB_STATE_RECOVERY

Definition at line 278 of file totemsrp.c.

◆ message_type

enum message_type

Enumerator
MESSAGE_TYPE_ORF_TOKEN
MESSAGE_TYPE_MCAST
MESSAGE_TYPE_MEMB_MERGE_DETECT
MESSAGE_TYPE_MEMB_JOIN
MESSAGE_TYPE_MEMB_COMMIT_TOKEN
MESSAGE_TYPE_TOKEN_HOLD_CANCEL

Definition at line 139 of file totemsrp.c.

Function Documentation

◆ attribute()

struct message_header __attribute__ ( (packed) )

◆ main_deliver_fn()

void main_deliver_fn	(	void *	context,
		const void *	msg,
		unsigned int	msg_len
	)

◆ main_iface_change_fn()

void main_iface_change_fn	(	void *	context,
		const struct totem_ip_address *	iface_address,
		unsigned int	iface_no
	)

◆ totemsrp_avail()

int totemsrp_avail ( void * srp_context )

Return number of available messages that can be queued.

Definition at line 2560 of file totemsrp.c.

References totemsrp_instance::new_message_queue, totemsrp_instance::new_message_queue_trans, and totemsrp_instance::waiting_trans_ack.

Referenced by totemmrp_avail().

◆ totemsrp_callback_token_create()

int totemsrp_callback_token_create	(	void *	srp_context,
		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 3479 of file totemsrp.c.

Referenced by totemmrp_callback_token_create().

◆ totemsrp_callback_token_destroy()

void totemsrp_callback_token_destroy	(	void *	srp_context,
		void **	handle_out
	)

Definition at line 3514 of file totemsrp.c.

Referenced by totemmrp_callback_token_destroy().

◆ totemsrp_crypto_set()

int totemsrp_crypto_set	(	void *	srp_context,
		const char *	cipher_type,
		const char *	hash_type
	)

Definition at line 1124 of file totemsrp.c.

References totemsrp_instance::totemrrp_context, and totemrrp_crypto_set().

Referenced by totemmrp_crypto_set().

◆ totemsrp_event_signal()

void totemsrp_event_signal	(	void *	srp_context,
		enum totem_event_type	type,
		int	value
	)

Definition at line 2482 of file totemsrp.c.

Referenced by totemmrp_event_signal().

◆ totemsrp_finalize()

void totemsrp_finalize ( void * srp_context )

Definition at line 1042 of file totemsrp.c.

Referenced by totemmrp_finalize().

◆ totemsrp_ifaces_get()

int totemsrp_ifaces_get	(	void *	srp_context,
		unsigned int	nodeid,
		struct totem_ip_address *	interfaces,
		unsigned int	interfaces_size,
		char ***	status,
		unsigned int *	iface_count
	)

Definition at line 1066 of file totemsrp.c.

References srp_addr::addr, totem_config::interface_count, totemsrp_instance::my_left_memb_entries, totemsrp_instance::my_left_memb_list, totemsrp_instance::my_memb_entries, totemsrp_instance::my_memb_list, totem_ip_address::nodeid, totemsrp_instance::totem_config, totemsrp_instance::totemrrp_context, and totemrrp_ifaces_get().

Referenced by totemmrp_ifaces_get().

◆ totemsrp_initialize()

int totemsrp_initialize	(	qb_loop_t *	poll_handle,
		void **	srp_context,
		struct totem_config *	totem_config,
		totemmrp_stats_t *	stats,
		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,
		void(*)(int waiting_trans_ack)	waiting_trans_ack_cb_fn
	)

Create a protocol instance.

Definition at line 832 of file totemsrp.c.

◆ totemsrp_mcast()

int totemsrp_mcast	(	void *	srp_context,
		struct iovec *	iovec,
		unsigned int	iov_len,
		int	guarantee
	)

Multicast a message.

Definition at line 2491 of file totemsrp.c.

References consensus_list_item::addr, totemsrp_instance::new_message_queue, totemsrp_instance::new_message_queue_trans, and totemsrp_instance::waiting_trans_ack.

Referenced by totemmrp_mcast().

◆ totemsrp_member_add()

int totemsrp_member_add	(	void *	context,
		const struct totem_ip_address *	member,
		int	ring_no
	)

Definition at line 5133 of file totemsrp.c.

References totemsrp_instance::totemrrp_context, and totemrrp_member_add().

Referenced by main_iface_change_fn(), and totemmrp_member_add().

◆ totemsrp_member_remove()

int totemsrp_member_remove	(	void *	context,
		const struct totem_ip_address *	member,
		int	ring_no
	)

Definition at line 5146 of file totemsrp.c.

References totemsrp_instance::totemrrp_context, and totemrrp_member_remove().

Referenced by totemmrp_member_remove().

◆ totemsrp_my_family_get()

int totemsrp_my_family_get ( void * srp_context )

Definition at line 1149 of file totemsrp.c.

References totem_interface::boundto, totem_ip_address::family, totem_config::interfaces, and totemsrp_instance::totem_config.

Referenced by totemmrp_my_family_get().

◆ totemsrp_my_nodeid_get()

unsigned int totemsrp_my_nodeid_get ( void * srp_context )

Definition at line 1138 of file totemsrp.c.

References totem_interface::boundto, totem_config::interfaces, totem_ip_address::nodeid, and totemsrp_instance::totem_config.

Referenced by totemmrp_my_nodeid_get().

◆ totemsrp_net_mtu_adjust()

void totemsrp_net_mtu_adjust ( struct totem_config * totem_config )

Definition at line 5120 of file totemsrp.c.

References totem_config::net_mtu.

◆ totemsrp_ring_reenable()

int totemsrp_ring_reenable ( void * srp_context )

Definition at line 1161 of file totemsrp.c.

References totem_config::interface_count, totemsrp_instance::totem_config, totemsrp_instance::totemrrp_context, and totemrrp_ring_reenable().

Referenced by totemmrp_ring_reenable().

◆ totemsrp_service_ready_register()

void totemsrp_service_ready_register	(	void *	context,
		void(*)(void)	totem_service_ready
	)

Definition at line 5124 of file totemsrp.c.

References totemsrp_instance::totemsrp_service_ready_fn.

Referenced by totemmrp_service_ready_register().

◆ totemsrp_threaded_mode_enable()

void totemsrp_threaded_mode_enable ( void * context )

Definition at line 5159 of file totemsrp.c.

References totemsrp_instance::threaded_mode_enabled.

Referenced by totemmrp_threaded_mode_enable().

◆ totemsrp_trans_ack()

void totemsrp_trans_ack ( void * context )

Definition at line 5166 of file totemsrp.c.

References totemsrp_instance::totemsrp_waiting_trans_ack_cb_fn, and totemsrp_instance::waiting_trans_ack.

Referenced by totemmrp_trans_ack().

Variable Documentation

◆ attribute

struct message_item __attribute__

◆ addr_entries

int addr_entries

Definition at line 65 of file totemsrp.c.

◆ aru

unsigned int aru

Definition at line 63 of file totemsrp.c.

◆ aru_addr

unsigned int aru_addr

Definition at line 64 of file totemsrp.c.

◆ backlog

unsigned int backlog

Definition at line 66 of file totemsrp.c.

◆ encapsulated

char encapsulated

Definition at line 61 of file totemsrp.c.

◆ end_of_commit_token

unsigned char end_of_commit_token[0]

Definition at line 66 of file totemsrp.c.

◆ end_of_memb_join

unsigned char end_of_memb_join[0]

Definition at line 65 of file totemsrp.c.

◆ endian_detector

unsigned short endian_detector

Definition at line 62 of file totemsrp.c.

◆ failed_list_entries

unsigned int failed_list_entries

Definition at line 63 of file totemsrp.c.

◆ fcc

unsigned int fcc

Definition at line 67 of file totemsrp.c.

◆ gather_state_from_desc

const char* gather_state_from_desc[]

Initial value:

= {
        [TOTEMSRP_GSFROM_CONSENSUS_TIMEOUT] = "consensus timeout",
        [TOTEMSRP_GSFROM_GATHER_MISSING1] = "MISSING",
        [TOTEMSRP_GSFROM_THE_TOKEN_WAS_LOST_IN_THE_OPERATIONAL_STATE] = "The token was lost in the OPERATIONAL state.",
        [TOTEMSRP_GSFROM_THE_CONSENSUS_TIMEOUT_EXPIRED] = "The consensus timeout expired.",
        [TOTEMSRP_GSFROM_THE_TOKEN_WAS_LOST_IN_THE_COMMIT_STATE] = "The token was lost in the COMMIT state.",
        [TOTEMSRP_GSFROM_THE_TOKEN_WAS_LOST_IN_THE_RECOVERY_STATE] = "The token was lost in the RECOVERY state.",
        [TOTEMSRP_GSFROM_FAILED_TO_RECEIVE] = "failed to receive",
        [TOTEMSRP_GSFROM_FOREIGN_MESSAGE_IN_OPERATIONAL_STATE] = "foreign message in operational state",
        [TOTEMSRP_GSFROM_FOREIGN_MESSAGE_IN_GATHER_STATE] = "foreign message in gather state",
        [TOTEMSRP_GSFROM_MERGE_DURING_OPERATIONAL_STATE] = "merge during operational state",
        [TOTEMSRP_GSFROM_MERGE_DURING_GATHER_STATE] = "merge during gather state",
        [TOTEMSRP_GSFROM_MERGE_DURING_JOIN] = "merge during join",
        [TOTEMSRP_GSFROM_JOIN_DURING_OPERATIONAL_STATE] = "join during operational state",
        [TOTEMSRP_GSFROM_JOIN_DURING_COMMIT_STATE] = "join during commit state",
        [TOTEMSRP_GSFROM_JOIN_DURING_RECOVERY] = "join during recovery",
        [TOTEMSRP_GSFROM_INTERFACE_CHANGE] = "interface change",
}

Definition at line 557 of file totemsrp.c.

◆ guarantee

int guarantee

Definition at line 66 of file totemsrp.c.

◆ header

struct message_header header

Definition at line 60 of file totemsrp.c.

Referenced by corosync_sending_allowed().

◆ high_delivered

unsigned int high_delivered

Definition at line 62 of file totemsrp.c.

◆ memb_index

int memb_index

Definition at line 64 of file totemsrp.c.

◆ node_id

unsigned int node_id

Definition at line 65 of file totemsrp.c.

◆ nodeid

unsigned int nodeid

Definition at line 63 of file totemsrp.c.

◆ proc_list_entries

unsigned int proc_list_entries

Definition at line 62 of file totemsrp.c.

◆ received_flg

unsigned int received_flg

Definition at line 63 of file totemsrp.c.

◆ retrans_flg

unsigned int retrans_flg

Definition at line 68 of file totemsrp.c.

◆ ring_id

struct memb_ring_id ring_id

Definition at line 64 of file totemsrp.c.

Referenced by votequorum_dispatch().

◆ ring_seq

unsigned long long ring_seq

Definition at line 64 of file totemsrp.c.

◆ rtr_list

struct rtr_item rtr_list[0]

Definition at line 70 of file totemsrp.c.

◆ rtr_list_entries

int rtr_list_entries

Definition at line 69 of file totemsrp.c.

◆ seq

unsigned int seq

Definition at line 62 of file totemsrp.c.

◆ system_from

struct srp_addr system_from

Definition at line 61 of file totemsrp.c.

Referenced by totemudp_recv_mcast_empty(), and totemudpu_recv_mcast_empty().

◆ this_seqno

int this_seqno

Definition at line 63 of file totemsrp.c.

◆ token_seq

unsigned int token_seq

Definition at line 62 of file totemsrp.c.

◆ totemsrp_message_handlers

struct message_handlers totemsrp_message_handlers

Initial value:

= {
        6,
        {
                message_handler_orf_token,            
                message_handler_mcast,                
                message_handler_memb_merge_detect,    
                message_handler_memb_join,            
                message_handler_memb_commit_token,    
                message_handler_token_hold_cancel     
        }
}

Definition at line 679 of file totemsrp.c.

◆ tv_old

unsigned long long int tv_old

Definition at line 3944 of file totemsrp.c.

◆ type

char type

Definition at line 60 of file totemsrp.c.

Data Structures

Macros

Enumerations

Functions

Variables

Macro Definition Documentation

◆ ENDIAN_LOCAL

◆ LEAVE_DUMMY_NODEID

◆ LOCALHOST_IP

◆ log_printf

◆ LOGSYS_PERROR

◆ LOGSYS_UTILS_ONLY

◆ MAXIOVS

◆ QUEUE_RTR_ITEMS_SIZE_MAX

◆ RECEIVED_MESSAGE_QUEUE_SIZE_MAX

◆ RETRANS_MESSAGE_QUEUE_SIZE_MAX

◆ RETRANSMIT_ENTRIES_MAX

◆ SEQNO_START_MSG

◆ SEQNO_START_TOKEN

◆ TOKEN_SIZE_MAX

Enumeration Type Documentation

◆ encapsulation_type

◆ gather_state_from

◆ memb_state

◆ message_type

Function Documentation

◆ __attribute__()

◆ main_deliver_fn()

◆ main_iface_change_fn()

◆ totemsrp_avail()

◆ totemsrp_callback_token_create()

◆ totemsrp_callback_token_destroy()

◆ totemsrp_crypto_set()

◆ totemsrp_event_signal()

◆ totemsrp_finalize()

◆ totemsrp_ifaces_get()

◆ totemsrp_initialize()

◆ totemsrp_mcast()

◆ totemsrp_member_add()

◆ totemsrp_member_remove()

◆ totemsrp_my_family_get()

◆ totemsrp_my_nodeid_get()

◆ totemsrp_net_mtu_adjust()

◆ totemsrp_ring_reenable()

◆ totemsrp_service_ready_register()

◆ totemsrp_threaded_mode_enable()

◆ totemsrp_trans_ack()

Variable Documentation

◆ __attribute__

◆ addr_entries

◆ aru

◆ aru_addr

◆ backlog

◆ encapsulated

◆ end_of_commit_token

◆ end_of_memb_join

◆ endian_detector

◆ failed_list_entries

◆ fcc

◆ gather_state_from_desc

◆ guarantee

◆ header

◆ high_delivered

◆ memb_index

◆ node_id

◆ nodeid

◆ proc_list_entries

◆ received_flg

◆ retrans_flg

◆ ring_id

◆ ring_seq

◆ rtr_list

◆ rtr_list_entries

◆ seq

◆ system_from

◆ this_seqno

◆ token_seq

◆ totemsrp_message_handlers

◆ tv_old

◆ type

◆ attribute()

◆ attribute