mc.c File Reference

Include dependency graph for mc.c:

Go to the source code of this file.

Macros
#define	MSG_ID_DEBUG   0
#define	EVENT_MC_SEND_CATCHUP_DATA   0
#define	EVENT_MC_UNSERIALIZE_BUFFER   0
#define	EVENT_MC_UNSERIALIZE_CATCHUP   1

Functions
static u32	elog_id_for_peer_id (mc_main_t *m, u64 peer_id)
static u32	elog_id_for_msg_name (mc_main_t *m, char *msg_name)
static void	elog_tx_msg (mc_main_t *m, u32 stream_id, u32 local_sequence, u32 retry_count)
always_inline i32	mc_seq_cmp (u32 x, u32 y)
void *	mc_get_vlib_buffer (vlib_main_t *vm, u32 n_bytes, u32 *bi_return)
static void	delete_peer_with_index (mc_main_t *mcm, mc_stream_t *s, uword index, int notify_application)
static mc_stream_peer_t *	get_or_create_peer_with_id (mc_main_t *mcm, mc_stream_t *s, mc_peer_id_t id, int *created)
static void	maybe_send_window_open_event (vlib_main_t *vm, mc_stream_t *stream)
static void	mc_retry_free (mc_main_t *mcm, mc_stream_t *s, mc_retry_t *r)
static void	mc_resend_retired (mc_main_t *mcm, mc_stream_t *s, u32 local_sequence)
static uword *	delete_retry_fifo_elt (mc_main_t *mcm, mc_stream_t *stream, mc_retry_t *r, uword *dead_peer_bitmap)
always_inline mc_retry_t *	prev_retry (mc_stream_t *s, mc_retry_t *r)
always_inline mc_retry_t *	next_retry (mc_stream_t *s, mc_retry_t *r)
always_inline void	remove_retry_from_pool (mc_stream_t *s, mc_retry_t *r)
static void	check_retry (mc_main_t *mcm, mc_stream_t *s)
always_inline mc_main_t *	mc_node_get_main (vlib_node_runtime_t *node)
static uword	mc_retry_process (vlib_main_t *vm, vlib_node_runtime_t *node, vlib_frame_t *f)
static void	send_join_or_leave_request (mc_main_t *mcm, u32 stream_index, u32 is_join)
static uword	mc_join_ager_process (vlib_main_t *vm, vlib_node_runtime_t *node, vlib_frame_t *f)
static void	serialize_mc_register_stream_name (serialize_main_t *m, va_list *va)
static void	elog_stream_name (char *buf, int n_buf_bytes, char *v)
static void	unserialize_mc_register_stream_name (serialize_main_t *m, va_list *va)
	MC_SERIALIZE_MSG (mc_register_stream_name_msg, static)
void	mc_rx_buffer_unserialize (mc_main_t *mcm, mc_stream_t *stream, mc_peer_id_t peer_id, u32 buffer_index)
static u8 *	mc_internal_catchup_snapshot (mc_main_t *mcm, u8 *data_vector, u32 last_global_sequence_processed)
static void	mc_internal_catchup (mc_main_t *mcm, u8 *data, u32 n_data_bytes)
void	mc_stream_join_process_hold (void)
static u32	mc_stream_join_helper (mc_main_t *mcm, mc_stream_config_t *config, u32 is_internal)
u32	mc_stream_join (mc_main_t *mcm, mc_stream_config_t *config)
void	mc_stream_leave (mc_main_t *mcm, u32 stream_index)
void	mc_msg_join_or_leave_request_handler (mc_main_t *mcm, mc_msg_join_or_leave_request_t *req, u32 buffer_index)
void	mc_msg_join_reply_handler (mc_main_t *mcm, mc_msg_join_reply_t *mp, u32 buffer_index)
void	mc_wait_for_stream_ready (mc_main_t *m, char *stream_name)
u32	mc_stream_send (mc_main_t *mcm, u32 stream_index, u32 buffer_index)
void	mc_msg_user_request_handler (mc_main_t *mcm, mc_msg_user_request_t *mp, u32 buffer_index)
void	mc_msg_user_ack_handler (mc_main_t *mcm, mc_msg_user_ack_t *mp, u32 buffer_index)
static uword	mc_catchup_process (vlib_main_t *vm, vlib_node_runtime_t *node, vlib_frame_t *f)
static void	serialize_mc_stream (serialize_main_t *m, va_list *va)
void	unserialize_mc_stream (serialize_main_t *m, va_list *va)
void	mc_msg_catchup_request_handler (mc_main_t *mcm, mc_msg_catchup_request_t *req, u32 catchup_opaque)
void	mc_msg_catchup_reply_handler (mc_main_t *mcm, mc_msg_catchup_reply_t *mp, u32 catchup_opaque)
static void	perform_catchup (mc_main_t *mcm, mc_msg_catchup_reply_t *mp)
static void	this_node_maybe_master (mc_main_t *mcm)
static void	this_node_slave (mc_main_t *mcm)
static uword	mc_mastership_process (vlib_main_t *vm, vlib_node_runtime_t *node, vlib_frame_t *f)
void	mc_enable_disable_mastership (mc_main_t *mcm, int we_can_be_master)
void	mc_msg_master_assert_handler (mc_main_t *mcm, mc_msg_master_assert_t *mp, u32 buffer_index)
static void	mc_serialize_init (mc_main_t *mcm)
clib_error_t *	mc_serialize_va (mc_main_t *mc, u32 stream_index, u32 multiple_messages_per_vlib_buffer, mc_serialize_msg_t *msg, va_list *va)
clib_error_t *	mc_serialize_internal (mc_main_t *mc, u32 stream_index, u32 multiple_messages_per_vlib_buffer, mc_serialize_msg_t *msg,...)
uword	mc_unserialize_message (mc_main_t *mcm, mc_stream_t *s, serialize_main_t *m)
void	mc_unserialize_internal (mc_main_t *mcm, u32 stream_and_buffer_index)
void	mc_unserialize (mc_main_t *mcm, mc_stream_t *s, u32 buffer_index)
static uword	mc_unserialize_process (vlib_main_t *vm, vlib_node_runtime_t *node, vlib_frame_t *f)
void	serialize_mc_main (serialize_main_t *m, va_list *va)
void	unserialize_mc_main (serialize_main_t *m, va_list *va)
void	mc_main_init (mc_main_t *mcm, char *tag)
static u8 *	format_mc_relay_state (u8 *s, va_list *args)
static u8 *	format_mc_stream_state (u8 *s, va_list *args)
static int	mc_peer_comp (void *a1, void *a2)
u8 *	format_mc_main (u8 *s, va_list *args)

Variables
static format_function_t	format_mc_stream_state

Macro Definition Documentation

#define EVENT_MC_SEND_CATCHUP_DATA   0

Definition at line 1267 of file mc.c.

#define EVENT_MC_UNSERIALIZE_BUFFER   0

Definition at line 1422 of file mc.c.

#define EVENT_MC_UNSERIALIZE_CATCHUP   1

Definition at line 1423 of file mc.c.

#define MSG_ID_DEBUG   0

Definition at line 24 of file mc.c.

Function Documentation

static void check_retry ( mc_main_t *  mcm, mc_stream_t *  s  )

static

Definition at line 329 of file mc.c.

Here is the call graph for this function:

Here is the caller graph for this function:

static void delete_peer_with_index ( mc_main_t *  mcm, mc_stream_t *  s, uword  index, int  notify_application  )

static

Definition at line 113 of file mc.c.

Here is the call graph for this function:

Here is the caller graph for this function:

static uword* delete_retry_fifo_elt ( mc_main_t *  mcm, mc_stream_t *  stream, mc_retry_t *  r, uword *  dead_peer_bitmap  )

static

Definition at line 260 of file mc.c.

Here is the caller graph for this function:

static u32 elog_id_for_msg_name ( mc_main_t *  m, char *  msg_name  )

static

Definition at line 45 of file mc.c.

Here is the call graph for this function:

Here is the caller graph for this function:

static u32 elog_id_for_peer_id ( mc_main_t *  m, u64  peer_id  )

static

Definition at line 28 of file mc.c.

Here is the call graph for this function:

Here is the caller graph for this function:

static void elog_stream_name ( char *  buf, int  n_buf_bytes, char *  v  )

static

Definition at line 542 of file mc.c.

Here is the caller graph for this function:

static void elog_tx_msg ( mc_main_t *  m, u32  stream_id, u32  local_sequence, u32  retry_count  )

static

Definition at line 68 of file mc.c.

Here is the caller graph for this function:

u8* format_mc_main	(	u8 *	s,
		va_list *	args
	)

Definition at line 2285 of file mc.c.

Here is the call graph for this function:

static u8* format_mc_relay_state ( u8 *  s, va_list *  args  )

static

Definition at line 2238 of file mc.c.

Here is the call graph for this function:

Here is the caller graph for this function:

static u8* format_mc_stream_state ( u8 *  s, va_list *  args  )

static

Definition at line 2260 of file mc.c.

Here is the call graph for this function:

static mc_stream_peer_t* get_or_create_peer_with_id ( mc_main_t *  mcm, mc_stream_t *  s, mc_peer_id_t  id, int *  created  )

static

Definition at line 139 of file mc.c.

Here is the call graph for this function:

Here is the caller graph for this function:

static void maybe_send_window_open_event ( vlib_main_t *  vm, mc_stream_t *  stream  )

static

Definition at line 182 of file mc.c.

Here is the call graph for this function:

Here is the caller graph for this function:

static uword mc_catchup_process ( vlib_main_t *  vm, vlib_node_runtime_t *  node, vlib_frame_t *  f  )

static

Definition at line 1270 of file mc.c.

Here is the call graph for this function:

Here is the caller graph for this function:

void mc_enable_disable_mastership	(	mc_main_t *	mcm,
		int	we_can_be_master
	)

Definition at line 1692 of file mc.c.

Here is the call graph for this function:

Here is the caller graph for this function:

void* mc_get_vlib_buffer	(	vlib_main_t *	vm,
		u32	n_bytes,
		u32 *	bi_return
	)

Definition at line 98 of file mc.c.

Here is the call graph for this function:

Here is the caller graph for this function:

static void mc_internal_catchup ( mc_main_t *  mcm, u8 *  data, u32  n_data_bytes  )

static

Definition at line 636 of file mc.c.

Here is the call graph for this function:

Here is the caller graph for this function:

static u8* mc_internal_catchup_snapshot ( mc_main_t *  mcm, u8 *  data_vector, u32  last_global_sequence_processed  )

static

Definition at line 621 of file mc.c.

Here is the call graph for this function:

Here is the caller graph for this function:

static uword mc_join_ager_process ( vlib_main_t *  vm, vlib_node_runtime_t *  node, vlib_frame_t *  f  )

static

Definition at line 464 of file mc.c.

Here is the call graph for this function:

Here is the caller graph for this function:

void mc_main_init	(	mc_main_t *	mcm,
		char *	tag
	)

Definition at line 2186 of file mc.c.

Here is the call graph for this function:

Here is the caller graph for this function:

static uword mc_mastership_process ( vlib_main_t *  vm, vlib_node_runtime_t *  node, vlib_frame_t *  f  )

static

Definition at line 1669 of file mc.c.

Here is the call graph for this function:

Here is the caller graph for this function:

void mc_msg_catchup_reply_handler	(	mc_main_t *	mcm,
		mc_msg_catchup_reply_t *	mp,
		u32	catchup_opaque
	)

Definition at line 1425 of file mc.c.

Here is the call graph for this function:

Here is the caller graph for this function:

void mc_msg_catchup_request_handler	(	mc_main_t *	mcm,
		mc_msg_catchup_request_t *	req,
		u32	catchup_opaque
	)

Definition at line 1341 of file mc.c.

Here is the call graph for this function:

Here is the caller graph for this function:

void mc_msg_join_or_leave_request_handler	(	mc_main_t *	mcm,
		mc_msg_join_or_leave_request_t *	req,
		u32	buffer_index
	)

Definition at line 819 of file mc.c.

Here is the call graph for this function:

Here is the caller graph for this function:

void mc_msg_join_reply_handler	(	mc_main_t *	mcm,
		mc_msg_join_reply_t *	mp,
		u32	buffer_index
	)

Definition at line 878 of file mc.c.

Here is the call graph for this function:

Here is the caller graph for this function:

void mc_msg_master_assert_handler	(	mc_main_t *	mcm,
		mc_msg_master_assert_t *	mp,
		u32	buffer_index
	)

Definition at line 1703 of file mc.c.

Here is the call graph for this function:

Here is the caller graph for this function:

void mc_msg_user_ack_handler	(	mc_main_t *	mcm,
		mc_msg_user_ack_t *	mp,
		u32	buffer_index
	)

Definition at line 1111 of file mc.c.

Here is the call graph for this function:

Here is the caller graph for this function:

void mc_msg_user_request_handler	(	mc_main_t *	mcm,
		mc_msg_user_request_t *	mp,
		u32	buffer_index
	)

Definition at line 993 of file mc.c.

Here is the call graph for this function:

Here is the caller graph for this function:

always_inline mc_main_t* mc_node_get_main

(

vlib_node_runtime_t *

node

)

Definition at line 415 of file mc.c.

Here is the caller graph for this function:

static int mc_peer_comp ( void *  a1, void *  a2  )

static

Definition at line 2277 of file mc.c.

Here is the call graph for this function:

Here is the caller graph for this function:

static void mc_resend_retired ( mc_main_t *  mcm, mc_stream_t *  s, u32  local_sequence  )

static

Definition at line 217 of file mc.c.

Here is the caller graph for this function:

static void mc_retry_free ( mc_main_t *  mcm, mc_stream_t *  s, mc_retry_t *  r  )

static

Definition at line 196 of file mc.c.

Here is the call graph for this function:

Here is the caller graph for this function:

static uword mc_retry_process ( vlib_main_t *  vm, vlib_node_runtime_t *  node, vlib_frame_t *  f  )

static

Definition at line 422 of file mc.c.

Here is the call graph for this function:

Here is the caller graph for this function:

void mc_rx_buffer_unserialize	(	mc_main_t *	mcm,
		mc_stream_t *	stream,
		mc_peer_id_t	peer_id,
		u32	buffer_index
	)

Definition at line 614 of file mc.c.

Here is the call graph for this function:

Here is the caller graph for this function:

always_inline i32 mc_seq_cmp	(	u32	x,
		u32	y
	)

Definition at line 95 of file mc.c.

Here is the caller graph for this function:

static void mc_serialize_init ( mc_main_t *  mcm )

static

Definition at line 1777 of file mc.c.

Here is the call graph for this function:

Here is the caller graph for this function:

clib_error_t* mc_serialize_internal	(	mc_main_t *	mc,
		u32	stream_index,
		u32	multiple_messages_per_vlib_buffer,
		mc_serialize_msg_t *	msg,
			...
	)

Definition at line 1875 of file mc.c.

Here is the call graph for this function:

MC_SERIALIZE_MSG	(	mc_register_stream_name_msg	,
		static
	)

Here is the caller graph for this function:

clib_error_t* mc_serialize_va	(	mc_main_t *	mc,
		u32	stream_index,
		u32	multiple_messages_per_vlib_buffer,
		mc_serialize_msg_t *	msg,
		va_list *	va
	)

Definition at line 1799 of file mc.c.

Here is the call graph for this function:

Here is the caller graph for this function:

u32 mc_stream_join	(	mc_main_t *	mcm,
		mc_stream_config_t *	config
	)

Definition at line 793 of file mc.c.

Here is the call graph for this function:

Here is the caller graph for this function:

static u32 mc_stream_join_helper ( mc_main_t *  mcm, mc_stream_config_t *  config, u32  is_internal  )

static

Definition at line 652 of file mc.c.

Here is the call graph for this function:

Here is the caller graph for this function:

void mc_stream_join_process_hold

(

void

)

Definition at line 649 of file mc.c.

Here is the caller graph for this function:

void mc_stream_leave	(	mc_main_t *	mcm,
		u32	stream_index
	)

Definition at line 796 of file mc.c.

Here is the call graph for this function:

Here is the caller graph for this function:

u32 mc_stream_send	(	mc_main_t *	mcm,
		u32	stream_index,
		u32	buffer_index
	)

Definition at line 923 of file mc.c.

Here is the call graph for this function:

Here is the caller graph for this function:

void mc_unserialize	(	mc_main_t *	mcm,
		mc_stream_t *	s,
		u32	buffer_index
	)

Definition at line 2042 of file mc.c.

Here is the call graph for this function:

Here is the caller graph for this function:

void mc_unserialize_internal	(	mc_main_t *	mcm,
		u32	stream_and_buffer_index
	)

Definition at line 2004 of file mc.c.

Here is the call graph for this function:

Here is the caller graph for this function:

uword mc_unserialize_message	(	mc_main_t *	mcm,
		mc_stream_t *	s,
		serialize_main_t *	m
	)

Definition at line 1901 of file mc.c.

Here is the call graph for this function:

Here is the caller graph for this function:

static uword mc_unserialize_process ( vlib_main_t *  vm, vlib_node_runtime_t *  node, vlib_frame_t *  f  )

static

Definition at line 2054 of file mc.c.

Here is the call graph for this function:

Here is the caller graph for this function:

void mc_wait_for_stream_ready	(	mc_main_t *	m,
		char *	stream_name
	)

Definition at line 901 of file mc.c.

Here is the call graph for this function:

Here is the caller graph for this function:

always_inline mc_retry_t* next_retry	(	mc_stream_t *	s,
		mc_retry_t *	r
	)

Definition at line 304 of file mc.c.

Here is the caller graph for this function:

static void perform_catchup ( mc_main_t *  mcm, mc_msg_catchup_reply_t *  mp  )

static

Definition at line 1433 of file mc.c.

Here is the call graph for this function:

Here is the caller graph for this function:

always_inline mc_retry_t* prev_retry	(	mc_stream_t *	s,
		mc_retry_t *	r
	)

Definition at line 296 of file mc.c.

Here is the caller graph for this function:

always_inline void remove_retry_from_pool	(	mc_stream_t *	s,
		mc_retry_t *	r
	)

Definition at line 312 of file mc.c.

Here is the call graph for this function:

Here is the caller graph for this function:

static void send_join_or_leave_request ( mc_main_t *  mcm, u32  stream_index, u32  is_join  )

static

Definition at line 441 of file mc.c.

Here is the call graph for this function:

Here is the caller graph for this function:

void serialize_mc_main	(	serialize_main_t *	m,
		va_list *	va
	)

Definition at line 2093 of file mc.c.

Here is the call graph for this function:

Here is the caller graph for this function:

static void serialize_mc_register_stream_name ( serialize_main_t *  m, va_list *  va  )

static

Definition at line 536 of file mc.c.

Here is the call graph for this function:

Here is the caller graph for this function:

static void serialize_mc_stream ( serialize_main_t *  m, va_list *  va  )

static

Definition at line 1302 of file mc.c.

Here is the call graph for this function:

Here is the caller graph for this function:

static void this_node_maybe_master ( mc_main_t *  mcm )

static

Definition at line 1540 of file mc.c.

Here is the call graph for this function:

Here is the caller graph for this function:

static void this_node_slave ( mc_main_t *  mcm )

static

Definition at line 1627 of file mc.c.

Here is the call graph for this function:

Here is the caller graph for this function:

void unserialize_mc_main	(	serialize_main_t *	m,
		va_list *	va
	)

Definition at line 2116 of file mc.c.

Here is the call graph for this function:

Here is the caller graph for this function:

static void unserialize_mc_register_stream_name ( serialize_main_t *  m, va_list *  va  )

static

Definition at line 548 of file mc.c.

Here is the call graph for this function:

void unserialize_mc_stream	(	serialize_main_t *	m,
		va_list *	va
	)

Definition at line 1317 of file mc.c.

Here is the call graph for this function:

Here is the caller graph for this function:

Variable Documentation

format_function_t format_mc_stream_state

static

Definition at line 26 of file mc.c.