|
| TYPE_DESCR (m0_net_test_cmd) |
|
| TYPE_DESCR (m0_net_test_cmd_done) |
|
| TYPE_DESCR (m0_net_test_cmd_init) |
|
| TYPE_DESCR (m0_net_test_msg_nr) |
|
| TYPE_DESCR (m0_net_test_cmd_status_data) |
|
static m0_bcount_t | cmd_status_data_serialize (enum m0_net_test_serialize_op op, struct m0_net_test_cmd_status_data *sd, struct m0_bufvec *bv, m0_bcount_t offset) |
|
static int | cmd_serialize (enum m0_net_test_serialize_op op, struct m0_net_test_cmd *cmd, struct m0_net_buffer *buf, m0_bcount_t offset, m0_bcount_t *length) |
|
static void | cmd_free (struct m0_net_test_cmd *cmd) |
|
static struct m0_net_test_cmd_ctx * | cmd_ctx_extract (struct m0_net_test_network_ctx *net_ctx) |
|
static void | commands_tm_event_cb (const struct m0_net_tm_event *ev) |
|
static void | commands_cb_msg_recv (struct m0_net_test_network_ctx *net_ctx, const uint32_t buf_index, enum m0_net_queue_type q, const struct m0_net_buffer_event *ev) |
|
static void | commands_cb_msg_send (struct m0_net_test_network_ctx *net_ctx, const uint32_t buf_index, enum m0_net_queue_type q, const struct m0_net_buffer_event *ev) |
|
static void | commands_cb_impossible (struct m0_net_test_network_ctx *ctx, const uint32_t buf_index, enum m0_net_queue_type q, const struct m0_net_buffer_event *ev) |
|
static int | commands_recv_enqueue (struct m0_net_test_cmd_ctx *ctx, size_t buf_index) |
|
static void | commands_recv_dequeue (struct m0_net_test_cmd_ctx *ctx, size_t buf_index) |
|
static void | commands_recv_ep_put (struct m0_net_test_cmd_ctx *ctx, size_t buf_index) |
|
static bool | is_buf_in_recv_q (struct m0_net_test_cmd_ctx *ctx, size_t buf_index) |
|
static void | commands_recv_dequeue_nr (struct m0_net_test_cmd_ctx *ctx, size_t nr) |
|
static int | commands_initfini (struct m0_net_test_cmd_ctx *ctx, const char *cmd_ep, m0_time_t send_timeout, m0_net_test_commands_send_cb_t send_cb, struct m0_net_test_slist *ep_list, bool init) |
|
int | m0_net_test_commands_init (struct m0_net_test_cmd_ctx *ctx, const char *cmd_ep, m0_time_t send_timeout, m0_net_test_commands_send_cb_t send_cb, struct m0_net_test_slist *ep_list) |
|
void | m0_net_test_commands_fini (struct m0_net_test_cmd_ctx *ctx) |
|
int | m0_net_test_commands_send (struct m0_net_test_cmd_ctx *ctx, struct m0_net_test_cmd *cmd) |
|
void | m0_net_test_commands_send_wait_all (struct m0_net_test_cmd_ctx *ctx) |
|
int | m0_net_test_commands_recv (struct m0_net_test_cmd_ctx *ctx, struct m0_net_test_cmd *cmd, m0_time_t deadline) |
|
int | m0_net_test_commands_recv_enqueue (struct m0_net_test_cmd_ctx *ctx, size_t buf_index) |
|
void | m0_net_test_commands_received_free (struct m0_net_test_cmd *cmd) |
|
bool | m0_net_test_commands_invariant (struct m0_net_test_cmd_ctx *ctx) |
|