40 enum { UT_BUF_NR = 8, UT_TM_NR = 2 };
56 ctx->rmc_ep_addr, &
ctx->rmc_reqh,
67 static const size_t str_len = 100;
69 static uint64_t
start = 10000;
72 snprintf(str, str_len,
"linuxstob:./ut_reqh%"PRIu64,
start++);
91 .rhia_mdstore = &
ctx->rmc_mdstore,
96 ctx->rmc_ut_be.but_dom_cfg.bc_engine.bec_reqh = &
ctx->rmc_reqh;
102 seg =
ctx->rmc_ut_seg.bus_seg;
111 &
ctx->rmc_ut_be.but_dom,
seg);
133 &
ctx->rmc_ut_be.but_dom);
139 ctx->rmc_ut_be.but_stob_domain_location);
140 m0_free(
ctx->rmc_ut_be.but_stob_domain_location);
161 .rhia_dtm = (
void*)1,
162 .rhia_mdstore = (
void*)1,
void m0_be_ut_seg_fini(struct m0_be_ut_seg *ut_seg)
void m0_rpc_machine_fini(struct m0_rpc_machine *machine)
M0_INTERNAL void m0_reqh_services_terminate(struct m0_reqh *reqh)
void m0_net_domain_fini(struct m0_net_domain *dom)
M0_INTERNAL void m0_ut_rpc_mach_init_and_add(struct m0_ut_rpc_mach_ctx *ctx)
M0_INTERNAL int m0_be_ut_backend_init_cfg(struct m0_be_ut_backend *ut_be, const struct m0_be_domain_cfg *cfg, bool mkfs)
M0_INTERNAL int m0_cob_domain_mkfs(struct m0_cob_domain *dom, const struct m0_fid *rootfid, struct m0_be_tx *tx)
M0_INTERNAL int m0_mdstore_init(struct m0_mdstore *md, struct m0_be_seg *db, bool init_root)
#define M0_REQH_INIT(reqh,...)
static struct m0_sm_group * grp
static void buf_dummy(struct m0_net_buffer_pool *bp)
M0_INTERNAL void m0_ut_be_tx_end(struct m0_be_tx *tx)
void m0_be_ut_seg_init(struct m0_be_ut_seg *ut_seg, struct m0_be_ut_backend *ut_be, m0_bcount_t size)
M0_INTERNAL void m0_reqh_fini(struct m0_reqh *reqh)
static char * ut_reqh_location_get(void)
M0_INTERNAL void m0_cob_tx_credit(struct m0_cob_domain *dom, enum m0_cob_op optype, struct m0_be_tx_credit *accum)
M0_INTERNAL const struct m0_fid M0_MDSERVICE_SLASH_FID
M0_INTERNAL void m0_ut_be_tx_begin(struct m0_be_tx *tx, struct m0_be_ut_backend *ut_be, struct m0_be_tx_credit *cred)
void(* nbpo_below_threshold)(struct m0_net_buffer_pool *)
M0_INTERNAL int m0_rpc_net_buffer_pool_setup(struct m0_net_domain *ndom, struct m0_net_buffer_pool *app_pool, uint32_t bufs_nr, uint32_t tm_nr)
M0_INTERNAL int m0_rpc_machine_init(struct m0_rpc_machine *machine, struct m0_net_domain *net_dom, const char *ep_addr, struct m0_reqh *reqh, struct m0_net_buffer_pool *receive_pool, uint32_t colour, m0_bcount_t msg_size, uint32_t queue_len)
struct m0_net_xprt * m0_net_xprt_default_get(void)
void * m0_alloc(size_t size)
M0_INTERNAL void m0_be_domain_cleanup_by_location(const char *stob_domain_location)
static void ut_reqh_and_stuff_init(struct m0_ut_rpc_mach_ctx *ctx)
struct m0_sm_group * m0_be_ut_backend_sm_group_lookup(struct m0_be_ut_backend *ut_be)
M0_INTERNAL void m0_reqh_post_storage_fini_svcs_stop(struct m0_reqh *reqh)
M0_INTERNAL void m0_reqh_idle_wait(struct m0_reqh *reqh)
M0_INTERNAL int m0_reqh_state_get(struct m0_reqh *reqh)
M0_INTERNAL void m0_reqh_start(struct m0_reqh *reqh)
int m0_net_domain_init(struct m0_net_domain *dom, const struct m0_net_xprt *xprt)
static const struct m0_net_buffer_pool_ops buf_ops
M0_INTERNAL int m0_mdstore_create(struct m0_mdstore *md, struct m0_sm_group *grp, struct m0_cob_domain_id *id, struct m0_be_domain *bedom, struct m0_be_seg *db)
M0_INTERNAL void m0_ut_rpc_mach_fini(struct m0_ut_rpc_mach_ctx *ctx)
static int start(struct m0_fom *fom)
M0_INTERNAL void m0_reqh_pre_storage_fini_svcs_stop(struct m0_reqh *reqh)
void m0_be_ut_backend_fini(struct m0_be_ut_backend *ut_be)
static struct m0_be_seg * seg
M0_INTERNAL int m0_mdstore_destroy(struct m0_mdstore *md, struct m0_sm_group *grp, struct m0_be_domain *bedom)
static struct bulkio_params * bp
void m0_rpc_net_buffer_pool_cleanup(struct m0_net_buffer_pool *app_pool)
M0_INTERNAL int m0_reqh_be_init(struct m0_reqh *reqh, struct m0_be_seg *seg)
struct m0_fid g_process_fid