corosync  2.4.4
Data Fields
totemsrp_instance Struct Reference
Collaboration diagram for totemsrp_instance:
Collaboration graph
[legend]

Data Fields

int iface_changes
 
int failed_to_recv
 
int fcc_remcast_last
 
int fcc_mcast_last
 
int fcc_remcast_current
 
struct consensus_list_item consensus_list [PROCESSOR_COUNT_MAX]
 
int consensus_list_entries
 
struct srp_addr my_id
 
struct srp_addr my_proc_list [PROCESSOR_COUNT_MAX]
 
struct srp_addr my_failed_list [PROCESSOR_COUNT_MAX]
 
struct srp_addr my_new_memb_list [PROCESSOR_COUNT_MAX]
 
struct srp_addr my_trans_memb_list [PROCESSOR_COUNT_MAX]
 
struct srp_addr my_memb_list [PROCESSOR_COUNT_MAX]
 
struct srp_addr my_deliver_memb_list [PROCESSOR_COUNT_MAX]
 
struct srp_addr my_left_memb_list [PROCESSOR_COUNT_MAX]
 
unsigned int my_leave_memb_list [PROCESSOR_COUNT_MAX]
 
int my_proc_list_entries
 
int my_failed_list_entries
 
int my_new_memb_entries
 
int my_trans_memb_entries
 
int my_memb_entries
 
int my_deliver_memb_entries
 
int my_left_memb_entries
 
int my_leave_memb_entries
 
struct memb_ring_id my_ring_id
 
struct memb_ring_id my_old_ring_id
 
int my_aru_count
 
int my_merge_detect_timeout_outstanding
 
unsigned int my_last_aru
 
int my_seq_unchanged
 
int my_received_flg
 
unsigned int my_high_seq_received
 
unsigned int my_install_seq
 
int my_rotation_counter
 
int my_set_retrans_flg
 
int my_retrans_flg_count
 
unsigned int my_high_ring_delivered
 
int heartbeat_timeout
 
struct cs_queue new_message_queue
 
struct cs_queue new_message_queue_trans
 
struct cs_queue retrans_message_queue
 
struct sq regular_sort_queue
 
struct sq recovery_sort_queue
 
unsigned int my_aru
 
unsigned int my_high_delivered
 
struct list_head token_callback_received_listhead
 
struct list_head token_callback_sent_listhead
 
char orf_token_retransmit [TOKEN_SIZE_MAX]
 
int orf_token_retransmit_size
 
unsigned int my_token_seq
 
qb_loop_timer_handle timer_pause_timeout
 
qb_loop_timer_handle timer_orf_token_timeout
 
qb_loop_timer_handle timer_orf_token_retransmit_timeout
 
qb_loop_timer_handle timer_orf_token_hold_retransmit_timeout
 
qb_loop_timer_handle timer_merge_detect_timeout
 
qb_loop_timer_handle memb_timer_state_gather_join_timeout
 
qb_loop_timer_handle memb_timer_state_gather_consensus_timeout
 
qb_loop_timer_handle memb_timer_state_commit_timeout
 
qb_loop_timer_handle timer_heartbeat_timeout
 
int totemsrp_log_level_security
 
int totemsrp_log_level_error
 
int totemsrp_log_level_warning
 
int totemsrp_log_level_notice
 
int totemsrp_log_level_debug
 
int totemsrp_log_level_trace
 
int totemsrp_subsys_id
 
void(* totemsrp_log_printf )(int level, int sybsys, const char *function, const char *file, int line, const char *format,...) __attribute__((format(printf
 
void(*) enum memb_stat memb_state )
 
qb_loop_t * totemsrp_poll_handle
 
struct totem_ip_address mcast_address
 
void(* totemsrp_deliver_fn )(unsigned int nodeid, const void *msg, unsigned int msg_len, int endian_conversion_required)
 
void(* totemsrp_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(* totemsrp_service_ready_fn )(void)
 
void(* totemsrp_waiting_trans_ack_cb_fn )(int waiting_trans_ack)
 
void(* memb_ring_id_create_or_load )(struct memb_ring_id *memb_ring_id, const struct totem_ip_address *addr)
 
void(* memb_ring_id_store )(const struct memb_ring_id *memb_ring_id, const struct totem_ip_address *addr)
 
int global_seqno
 
int my_token_held
 
unsigned long long token_ring_id_seq
 
unsigned int last_released
 
unsigned int set_aru
 
int old_ring_state_saved
 
int old_ring_state_aru
 
unsigned int old_ring_state_high_seq_received
 
unsigned int my_last_seq
 
struct timeval tv_old
 
void * totemrrp_context
 
struct totem_configtotem_config
 
unsigned int use_heartbeat
 
unsigned int my_trc
 
unsigned int my_pbl
 
unsigned int my_cbl
 
uint64_t pause_timestamp
 
struct memb_commit_tokencommit_token
 
totemsrp_stats_t stats
 
uint32_t orf_token_discard
 
uint32_t originated_orf_token
 
uint32_t threaded_mode_enabled
 
uint32_t waiting_trans_ack
 
int flushing
 
void * token_recv_event_handle
 
void * token_sent_event_handle
 
char commit_token_storage [40000]
 

Detailed Description

Definition at line 285 of file totemsrp.c.

Field Documentation

struct memb_commit_token* totemsrp_instance::commit_token

Definition at line 509 of file totemsrp.c.

char totemsrp_instance::commit_token_storage[40000]

Definition at line 525 of file totemsrp.c.

struct consensus_list_item totemsrp_instance::consensus_list[PROCESSOR_COUNT_MAX]

Definition at line 299 of file totemsrp.c.

int totemsrp_instance::consensus_list_entries

Definition at line 301 of file totemsrp.c.

int totemsrp_instance::failed_to_recv

Definition at line 288 of file totemsrp.c.

int totemsrp_instance::fcc_mcast_last

Definition at line 295 of file totemsrp.c.

int totemsrp_instance::fcc_remcast_current

Definition at line 297 of file totemsrp.c.

int totemsrp_instance::fcc_remcast_last

Definition at line 293 of file totemsrp.c.

int totemsrp_instance::flushing

Definition at line 521 of file totemsrp.c.

int totemsrp_instance::global_seqno

Definition at line 475 of file totemsrp.c.

int totemsrp_instance::heartbeat_timeout

Definition at line 363 of file totemsrp.c.

Referenced by totemsrp_initialize().

int totemsrp_instance::iface_changes

Definition at line 286 of file totemsrp.c.

Referenced by main_iface_change_fn().

unsigned int totemsrp_instance::last_released

Definition at line 481 of file totemsrp.c.

struct totem_ip_address totemsrp_instance::mcast_address

Definition at line 447 of file totemsrp.c.

Referenced by totemsrp_initialize().

void(* totemsrp_instance::memb_ring_id_create_or_load)(struct memb_ring_id *memb_ring_id, const struct totem_ip_address *addr)

Definition at line 467 of file totemsrp.c.

Referenced by main_iface_change_fn(), and totemsrp_initialize().

void(* totemsrp_instance::memb_ring_id_store)(const struct memb_ring_id *memb_ring_id, const struct totem_ip_address *addr)

Definition at line 471 of file totemsrp.c.

Referenced by totemsrp_initialize().

void(*) enum memb_stat totemsrp_instance::memb_state)

Definition at line 441 of file totemsrp.c.

qb_loop_timer_handle totemsrp_instance::memb_timer_state_commit_timeout

Definition at line 412 of file totemsrp.c.

qb_loop_timer_handle totemsrp_instance::memb_timer_state_gather_consensus_timeout

Definition at line 410 of file totemsrp.c.

qb_loop_timer_handle totemsrp_instance::memb_timer_state_gather_join_timeout

Definition at line 408 of file totemsrp.c.

unsigned int totemsrp_instance::my_aru

Definition at line 381 of file totemsrp.c.

int totemsrp_instance::my_aru_count

Definition at line 341 of file totemsrp.c.

unsigned int totemsrp_instance::my_cbl

Definition at line 505 of file totemsrp.c.

int totemsrp_instance::my_deliver_memb_entries

Definition at line 331 of file totemsrp.c.

struct srp_addr totemsrp_instance::my_deliver_memb_list[PROCESSOR_COUNT_MAX]

Definition at line 315 of file totemsrp.c.

struct srp_addr totemsrp_instance::my_failed_list[PROCESSOR_COUNT_MAX]

Definition at line 307 of file totemsrp.c.

int totemsrp_instance::my_failed_list_entries

Definition at line 323 of file totemsrp.c.

unsigned int totemsrp_instance::my_high_delivered

Definition at line 383 of file totemsrp.c.

unsigned int totemsrp_instance::my_high_ring_delivered

Definition at line 361 of file totemsrp.c.

unsigned int totemsrp_instance::my_high_seq_received

Definition at line 351 of file totemsrp.c.

struct srp_addr totemsrp_instance::my_id

Definition at line 303 of file totemsrp.c.

Referenced by main_iface_change_fn(), and totemsrp_mcast().

unsigned int totemsrp_instance::my_install_seq

Definition at line 353 of file totemsrp.c.

unsigned int totemsrp_instance::my_last_aru

Definition at line 345 of file totemsrp.c.

unsigned int totemsrp_instance::my_last_seq

Definition at line 491 of file totemsrp.c.

int totemsrp_instance::my_leave_memb_entries

Definition at line 335 of file totemsrp.c.

unsigned int totemsrp_instance::my_leave_memb_list[PROCESSOR_COUNT_MAX]

Definition at line 319 of file totemsrp.c.

int totemsrp_instance::my_left_memb_entries

Definition at line 333 of file totemsrp.c.

Referenced by totemsrp_ifaces_get().

struct srp_addr totemsrp_instance::my_left_memb_list[PROCESSOR_COUNT_MAX]

Definition at line 317 of file totemsrp.c.

Referenced by totemsrp_ifaces_get().

int totemsrp_instance::my_memb_entries

Definition at line 329 of file totemsrp.c.

Referenced by totemsrp_ifaces_get().

struct srp_addr totemsrp_instance::my_memb_list[PROCESSOR_COUNT_MAX]

Definition at line 313 of file totemsrp.c.

Referenced by main_iface_change_fn(), and totemsrp_ifaces_get().

int totemsrp_instance::my_merge_detect_timeout_outstanding

Definition at line 343 of file totemsrp.c.

int totemsrp_instance::my_new_memb_entries

Definition at line 325 of file totemsrp.c.

struct srp_addr totemsrp_instance::my_new_memb_list[PROCESSOR_COUNT_MAX]

Definition at line 309 of file totemsrp.c.

struct memb_ring_id totemsrp_instance::my_old_ring_id

Definition at line 339 of file totemsrp.c.

unsigned int totemsrp_instance::my_pbl

Definition at line 503 of file totemsrp.c.

struct srp_addr totemsrp_instance::my_proc_list[PROCESSOR_COUNT_MAX]

Definition at line 305 of file totemsrp.c.

int totemsrp_instance::my_proc_list_entries

Definition at line 321 of file totemsrp.c.

int totemsrp_instance::my_received_flg

Definition at line 349 of file totemsrp.c.

int totemsrp_instance::my_retrans_flg_count

Definition at line 359 of file totemsrp.c.

struct memb_ring_id totemsrp_instance::my_ring_id

Definition at line 337 of file totemsrp.c.

Referenced by main_iface_change_fn().

int totemsrp_instance::my_rotation_counter

Definition at line 355 of file totemsrp.c.

int totemsrp_instance::my_seq_unchanged

Definition at line 347 of file totemsrp.c.

int totemsrp_instance::my_set_retrans_flg

Definition at line 357 of file totemsrp.c.

int totemsrp_instance::my_token_held

Definition at line 477 of file totemsrp.c.

unsigned int totemsrp_instance::my_token_seq

Definition at line 393 of file totemsrp.c.

int totemsrp_instance::my_trans_memb_entries

Definition at line 327 of file totemsrp.c.

struct srp_addr totemsrp_instance::my_trans_memb_list[PROCESSOR_COUNT_MAX]

Definition at line 311 of file totemsrp.c.

unsigned int totemsrp_instance::my_trc

Definition at line 501 of file totemsrp.c.

struct cs_queue totemsrp_instance::new_message_queue

Definition at line 368 of file totemsrp.c.

Referenced by totemsrp_avail(), totemsrp_finalize(), totemsrp_initialize(), and totemsrp_mcast().

struct cs_queue totemsrp_instance::new_message_queue_trans

Definition at line 370 of file totemsrp.c.

Referenced by totemsrp_avail(), totemsrp_finalize(), totemsrp_initialize(), and totemsrp_mcast().

int totemsrp_instance::old_ring_state_aru

Definition at line 487 of file totemsrp.c.

unsigned int totemsrp_instance::old_ring_state_high_seq_received

Definition at line 489 of file totemsrp.c.

int totemsrp_instance::old_ring_state_saved

Definition at line 485 of file totemsrp.c.

uint32_t totemsrp_instance::orf_token_discard

Definition at line 513 of file totemsrp.c.

char totemsrp_instance::orf_token_retransmit[TOKEN_SIZE_MAX]

Definition at line 389 of file totemsrp.c.

int totemsrp_instance::orf_token_retransmit_size

Definition at line 391 of file totemsrp.c.

uint32_t totemsrp_instance::originated_orf_token

Definition at line 515 of file totemsrp.c.

uint64_t totemsrp_instance::pause_timestamp

Definition at line 507 of file totemsrp.c.

struct sq totemsrp_instance::recovery_sort_queue

Definition at line 376 of file totemsrp.c.

Referenced by totemsrp_finalize(), and totemsrp_initialize().

struct sq totemsrp_instance::regular_sort_queue

Definition at line 374 of file totemsrp.c.

Referenced by totemsrp_finalize(), and totemsrp_initialize().

struct cs_queue totemsrp_instance::retrans_message_queue

Definition at line 372 of file totemsrp.c.

Referenced by totemsrp_finalize(), and totemsrp_initialize().

unsigned int totemsrp_instance::set_aru

Definition at line 483 of file totemsrp.c.

totemsrp_stats_t totemsrp_instance::stats

Definition at line 511 of file totemsrp.c.

Referenced by main_deliver_fn(), totemsrp_initialize(), and totemsrp_mcast().

uint32_t totemsrp_instance::threaded_mode_enabled

Definition at line 517 of file totemsrp.c.

Referenced by totemsrp_initialize(), and totemsrp_threaded_mode_enable().

qb_loop_timer_handle totemsrp_instance::timer_heartbeat_timeout

Definition at line 414 of file totemsrp.c.

qb_loop_timer_handle totemsrp_instance::timer_merge_detect_timeout

Definition at line 406 of file totemsrp.c.

qb_loop_timer_handle totemsrp_instance::timer_orf_token_hold_retransmit_timeout

Definition at line 404 of file totemsrp.c.

qb_loop_timer_handle totemsrp_instance::timer_orf_token_retransmit_timeout

Definition at line 402 of file totemsrp.c.

qb_loop_timer_handle totemsrp_instance::timer_orf_token_timeout

Definition at line 400 of file totemsrp.c.

qb_loop_timer_handle totemsrp_instance::timer_pause_timeout

Definition at line 398 of file totemsrp.c.

struct list_head totemsrp_instance::token_callback_received_listhead

Definition at line 385 of file totemsrp.c.

Referenced by totemsrp_callback_token_create().

struct list_head totemsrp_instance::token_callback_sent_listhead

Definition at line 387 of file totemsrp.c.

Referenced by totemsrp_callback_token_create().

void* totemsrp_instance::token_recv_event_handle

Definition at line 523 of file totemsrp.c.

Referenced by totemsrp_initialize().

unsigned long long totemsrp_instance::token_ring_id_seq

Definition at line 479 of file totemsrp.c.

Referenced by main_iface_change_fn().

void* totemsrp_instance::token_sent_event_handle

Definition at line 524 of file totemsrp.c.

Referenced by totemsrp_initialize().

struct totem_config* totemsrp_instance::totem_config
void* totemsrp_instance::totemrrp_context
void(* totemsrp_instance::totemsrp_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)

Definition at line 455 of file totemsrp.c.

Referenced by totemsrp_initialize().

void(* totemsrp_instance::totemsrp_deliver_fn)(unsigned int nodeid, const void *msg, unsigned int msg_len, int endian_conversion_required)

Definition at line 449 of file totemsrp.c.

Referenced by totemsrp_initialize().

int totemsrp_instance::totemsrp_log_level_debug

Definition at line 427 of file totemsrp.c.

Referenced by main_iface_change_fn(), totemsrp_initialize(), and totemsrp_mcast().

int totemsrp_instance::totemsrp_log_level_error

Definition at line 421 of file totemsrp.c.

Referenced by totemsrp_initialize().

int totemsrp_instance::totemsrp_log_level_notice

Definition at line 425 of file totemsrp.c.

Referenced by totemsrp_initialize().

int totemsrp_instance::totemsrp_log_level_security

Definition at line 419 of file totemsrp.c.

Referenced by main_deliver_fn(), and totemsrp_initialize().

int totemsrp_instance::totemsrp_log_level_trace

Definition at line 429 of file totemsrp.c.

Referenced by totemsrp_initialize(), and totemsrp_mcast().

int totemsrp_instance::totemsrp_log_level_warning

Definition at line 423 of file totemsrp.c.

Referenced by totemsrp_initialize().

void(* totemsrp_instance::totemsrp_log_printf)(int level, int sybsys, const char *function, const char *file, int line, const char *format,...) __attribute__((format(printf

Definition at line 433 of file totemsrp.c.

Referenced by totemsrp_initialize().

qb_loop_t* totemsrp_instance::totemsrp_poll_handle

Definition at line 445 of file totemsrp.c.

Referenced by totemsrp_initialize().

void(* totemsrp_instance::totemsrp_service_ready_fn)(void)

Definition at line 462 of file totemsrp.c.

Referenced by main_iface_change_fn(), and totemsrp_service_ready_register().

int totemsrp_instance::totemsrp_subsys_id

Definition at line 431 of file totemsrp.c.

Referenced by totemsrp_initialize().

void(* totemsrp_instance::totemsrp_waiting_trans_ack_cb_fn)(int waiting_trans_ack)

Definition at line 464 of file totemsrp.c.

Referenced by totemsrp_initialize(), and totemsrp_trans_ack().

struct timeval totemsrp_instance::tv_old

Definition at line 493 of file totemsrp.c.

unsigned int totemsrp_instance::use_heartbeat

Definition at line 499 of file totemsrp.c.

Referenced by totemsrp_initialize().

uint32_t totemsrp_instance::waiting_trans_ack

Definition at line 519 of file totemsrp.c.

Referenced by totemsrp_avail(), totemsrp_mcast(), and totemsrp_trans_ack().


The documentation for this struct was generated from the following file: