|
static u8 * | format_socket_peer_id (u8 *s, va_list *args) |
|
always_inline void | msg_handler (mc_main_t *mcm, u32 buffer_index, u32 handler_frees_buffer, void *_h) |
|
static uword | append_buffer_index_to_iovec (vlib_main_t *vm, u32 buffer_index, struct iovec **iovs_return) |
|
static clib_error_t * | sendmsg_helper (mc_socket_main_t *msm, int socket, struct sockaddr_in *tx_addr, u32 buffer_index) |
|
static clib_error_t * | tx_buffer (void *transport, mc_transport_type_t type, u32 buffer_index) |
|
static clib_error_t * | tx_ack (void *transport, mc_peer_id_t dest_peer_id, u32 buffer_index) |
|
static clib_error_t * | recvmsg_helper (mc_socket_main_t *msm, int socket, struct sockaddr_in *rx_addr, u32 *buffer_index, u32 drop_message) |
|
static clib_error_t * | mastership_socket_read_ready (unix_file_t *uf) |
|
static clib_error_t * | to_relay_socket_read_ready (unix_file_t *uf) |
|
static clib_error_t * | from_relay_socket_read_ready (unix_file_t *uf) |
|
static clib_error_t * | join_socket_read_ready (unix_file_t *uf) |
|
static clib_error_t * | ack_socket_read_ready (unix_file_t *uf) |
|
static void | catchup_cleanup (mc_socket_main_t *msm, mc_socket_catchup_t *c, unix_main_t *um, unix_file_t *uf) |
|
static mc_socket_catchup_t * | find_catchup_from_file_descriptor (mc_socket_main_t *msm, int file_descriptor) |
|
static clib_error_t * | catchup_socket_read_ready (unix_file_t *uf, int is_server) |
|
static clib_error_t * | catchup_server_read_ready (unix_file_t *uf) |
|
static clib_error_t * | catchup_client_read_ready (unix_file_t *uf) |
|
static clib_error_t * | catchup_socket_write_ready (unix_file_t *uf, int is_server) |
|
static clib_error_t * | catchup_server_write_ready (unix_file_t *uf) |
|
static clib_error_t * | catchup_client_write_ready (unix_file_t *uf) |
|
static clib_error_t * | catchup_socket_error_ready (unix_file_t *uf) |
|
static clib_error_t * | catchup_listen_read_ready (unix_file_t *uf) |
|
static word | find_and_bind_to_free_port (word sock, word port) |
|
static clib_error_t * | setup_mutlicast_socket (mc_socket_main_t *msm, mc_multicast_socket_t *ms, char *type, uword udp_port) |
|
static clib_error_t * | socket_setup (mc_socket_main_t *msm) |
|
static void * | catchup_add_pending_output (mc_socket_catchup_t *c, uword n_bytes, u8 *set_output_vector) |
|
static uword | catchup_request_fun (void *transport_main, u32 stream_index, mc_peer_id_t catchup_peer_id) |
|
static void | catchup_send_fun (void *transport_main, uword opaque, u8 *data) |
|
static int | find_interface_ip4_address (char *if_name, u32 *ip4_address, u32 *mtu) |
|
clib_error_t * | mc_socket_main_init (mc_socket_main_t *msm, char **intfc_probe_list, int n_intfcs_to_probe) |
|