25 #ifndef __MOTR_NET_TEST_NETWORK_H__ 26 #define __MOTR_NET_TEST_NETWORK_H__ 60 const uint32_t buf_index,
155 const char *tm_addr);
194 uint32_t buf_ping_index,
203 uint32_t buf_ping_index,
211 uint32_t buf_ping_index);
222 int32_t buf_bulk_index,
262 uint32_t buf_bulk_index,
263 uint32_t buf_ping_index,
274 uint32_t buf_ping_index);
284 uint32_t buf_ping_index);
uint32_t ntncfg_buf_ping_nr
static struct m0_semaphore q
struct m0_net_domain * ntc_dom
static const char * ep_addr
struct m0_net_end_point * m0_net_test_network_ep(struct m0_net_test_network_ctx *ctx, size_t ep_index)
size_t m0_net_test_network_bd_nr(struct m0_net_test_network_ctx *ctx, uint32_t buf_ping_index)
struct m0_net_buffer * ntc_buf_ping
m0_net_test_network_buffer_cb_proc_t ntnbc_cb[M0_NET_QT_NR]
void m0_net_test_network_buffer_dequeue(struct m0_net_test_network_ctx *ctx, enum m0_net_test_network_buf_type buf_type, int32_t buf_index)
m0_time_t ntnt_timeout[M0_NET_QT_NR]
bool m0_net_test_network_ctx_invariant(struct m0_net_test_network_ctx *ctx)
struct m0_net_test_network_cfg ntc_cfg
struct m0_net_buffer * m0_net_test_network_buf(struct m0_net_test_network_ctx *ctx, enum m0_net_test_network_buf_type buf_type, uint32_t buf_index)
int m0_net_test_network_buf_resize(struct m0_net_test_network_ctx *ctx, enum m0_net_test_network_buf_type buf_type, uint32_t buf_index, m0_bcount_t new_size)
m0_bcount_t ntncfg_buf_size_bulk
struct m0_net_test_network_buffer_callbacks ntncfg_buf_cb
int m0_net_test_network_msg_recv(struct m0_net_test_network_ctx *ctx, uint32_t buf_ping_index)
struct m0_net_test_network_timeouts m0_net_test_network_timeouts_never(void)
void m0_net_test_network_bd_nr_dec(struct m0_net_test_network_ctx *ctx, uint32_t buf_ping_index)
ssize_t m0_net_test_network_ep_search(struct m0_net_test_network_ctx *ctx, const char *ep_addr)
m0_net_test_network_buf_type
static m0_bindex_t offset
static struct fdmi_ctx ctx
struct m0_net_transfer_mc * ntc_tm
void(* m0_net_test_network_buffer_cb_proc_t)(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)
void m0_net_test_network_ctx_fini(struct m0_net_test_network_ctx *ctx)
struct m0_net_buffer * ntc_buf_bulk
int m0_net_test_network_ctx_init(struct m0_net_test_network_ctx *ctx, struct m0_net_test_network_cfg *cfg, const char *tm_addr)
int m0_net_test_network_msg_send(struct m0_net_test_network_ctx *ctx, uint32_t buf_ping_index, uint32_t ep_index)
m0_bcount_t ntncfg_buf_size_ping
struct m0_net_test_network_timeouts ntncfg_timeouts
uint32_t ntncfg_buf_bulk_nr
int m0_net_test_network_msg_send_ep(struct m0_net_test_network_ctx *ctx, uint32_t buf_ping_index, struct m0_net_end_point *ep)
int m0_net_test_network_ep_add(struct m0_net_test_network_ctx *ctx, const char *ep_addr)
m0_bcount_t m0_net_test_network_bd_serialize(enum m0_net_test_serialize_op op, struct m0_net_test_network_ctx *ctx, uint32_t buf_bulk_index, uint32_t buf_ping_index, m0_bcount_t offset)
struct m0_net_end_point ** ntc_ep
void m0_net_test_network_buf_fill(struct m0_net_test_network_ctx *ctx, enum m0_net_test_network_buf_type buf_type, uint32_t buf_index, uint8_t fill)
int m0_net_test_network_ep_add_slist(struct m0_net_test_network_ctx *ctx, const struct m0_net_test_slist *eps)
int m0_net_test_network_bulk_enqueue(struct m0_net_test_network_ctx *ctx, int32_t buf_bulk_index, int32_t ep_index, enum m0_net_queue_type q)
struct m0_net_tm_callbacks ntncfg_tm_cb