|
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) |
|
static 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) |
|
static mc_retry_t * | prev_retry (mc_stream_t *s, mc_retry_t *r) |
|
static mc_retry_t * | next_retry (mc_stream_t *s, mc_retry_t *r) |
|
static 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) |
|
static 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) |
|