24 #define M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_FDMI 182 #define FID_CTN 0xDEA110C 183 #define FID_KEY 0xDA221ED 184 #define FID_CTN1 0x1FA11ED 185 #define FID_KEY1 0x1A110CA 186 #define M0_FID(c_, k_) { .f_container = c_, .f_key = k_ } 199 m0_fi_disable(
"m0_fdmi__pdock_record_reg_find",
"fail_find");
269 struct m0_fid all_fids[3] = {
500 "fail_fdmi_rec_reg", 0, 1);
504 "fail_fdmi_rec_reg");
635 rpc_conn_pool_items_tlink_init_at_tail(pool_item,
697 rpc_conn_pool_items_tlink_del_fini(pool_item);
718 #undef M0_TRACE_SUBSYSTEM
static void my_item_done(struct m0_rpc_packet *p, struct m0_rpc_item *item, int rc)
static struct m0_addb2_philter p
static struct m0_rpc_packet * g_rpc_packet
struct m0_fdmi_flt_id_arr fr_matched_flts
M0_INTERNAL void m0_rpc_item_change_state(struct m0_rpc_item *item, enum m0_rpc_item_state state)
struct m0_rpc_link cpi_rpc_link
const struct m0_rpc_frm_ops frm_ops
struct m0_uint128 * frid_watch
void __fdmi_pd_fom_norpc(bool register_filter)
struct fdmi_sd_ut_ctx g_sd_ut
M0_INTERNAL bool m0_uint128_eq(const struct m0_uint128 *u0, const struct m0_uint128 *u1)
struct m0_fdmi_record_reg * m0_fdmi__pdock_record_reg_find(const struct m0_uint128 *rid)
M0_INTERNAL int m0_reqh_fop_handle(struct m0_reqh *reqh, struct m0_fop *fop)
M0_INTERNAL void m0_rpc_packet_traverse_items(struct m0_rpc_packet *p, item_visit_fn *visit, int opaque_data)
struct m0_rpc_machine tre_rpc_machine
void(* pf_custom_fom_fini)(struct m0_fom *fom)
int(* fto_create)(struct m0_fop *fop, struct m0_fom **out, struct m0_reqh *reqh)
struct m0_rpc_conn rlk_conn
static void ut_pd_fom_fini(struct m0_fom *fom)
M0_INTERNAL struct m0_fdmi_record_reg * m0_fdmi__pdock_fdmi_record_register(struct m0_fop *fop)
struct m0_fdmi_plugin_ops * ffr_pcb
void * m0_fop_data(const struct m0_fop *fop)
int detour_create(struct m0_fop *fop, struct m0_fom **out, struct m0_reqh *reqh)
#define container_of(ptr, type, member)
static struct m0_rpc_item * item
struct m0_fom_type_ops fomt_ops
struct m0_fom_type ft_fom_type
void fdmi_pd_register_filter(void)
int(* po_fdmi_rec)(struct m0_uint128 *rec_id, struct m0_buf fdmi_rec, struct m0_fid filter_id)
struct m0_sm_group rm_sm_grp
int(* native_create)(struct m0_fop *fop, struct m0_fom **out, struct m0_reqh *reqh)
void fdmi_serv_start_ut(const struct m0_filterc_ops *filterc_ops)
M0_INTERNAL void m0_sm_group_unlock(struct m0_sm_group *grp)
static struct m0_semaphore g_sem
void(* fpo_deregister_plugin)(struct m0_fid *filter_ids, uint64_t filter_count)
void fdmi_pd_fake_rec_reg(void)
static int pd_ut_pcb_fdmi_rec(struct m0_uint128 *rec_id, struct m0_buf fdmi_rec, struct m0_fid filter_id)
M0_INTERNAL void m0_ref_put(struct m0_ref *ref)
struct m0_uint128 frr_frid
void fdmi_pd_fake_release_rep(void)
M0_INTERNAL void m0_ref_get(struct m0_ref *ref)
M0_INTERNAL void m0_rpc_item_timer_stop(struct m0_rpc_item *item)
M0_INTERNAL void m0_fi_disable(const char *fp_func, const char *fp_tag)
void m0_fom_fini(struct m0_fom *fom)
void fdmi_pd_fom_norpc(void)
struct m0_uint128 frid_new
M0_INTERNAL void m0_rpc_conn_ha_timer_stop(struct m0_rpc_conn *conn)
void fdmi_pd_fake_release_nomem()
M0_INTERNAL int m0_fdmi__plugin_dock_init(void)
struct m0_fop_type m0_fop_fdmi_rec_release_rep_fopt
M0_INTERNAL int m0_semaphore_init(struct m0_semaphore *semaphore, unsigned value)
int(* fo_packet_ready)(struct m0_rpc_packet *p)
static const struct m0_fid fids[]
static int register_filter(const struct m0_fid *fid, const struct m0_fdmi_filter_desc *desc, const struct m0_fdmi_plugin_ops *pcb)
void fdmi_serv_stop_ut(void)
const struct m0_filterc_ops filterc_send_notif_ops
void fdmi_pd_rec_inject_fini(void)
const struct m0_fom_type_ops * ft_ops
void(* fpo_enable_filters)(bool enable, struct m0_fid *filter_ids, uint32_t filter_count)
static void m0_fi_enable_off_n_on_m(const char *func, const char *tag, uint32_t n, uint32_t m)
static struct test_rpc_env g_rpc_env
void(* rio_replied)(struct m0_rpc_item *item)
M0_INTERNAL bool m0_fid_eq(const struct m0_fid *fid0, const struct m0_fid *fid1)
struct m0_fop_type m0_fop_fdmi_rec_not_fopt
M0_INTERNAL int64_t m0_ref_read(const struct m0_ref *ref)
struct m0_fdmi_flt_id_arr farr
void prepare_rpc_env(struct test_rpc_env *env, struct m0_reqh *reqh, const struct m0_rpc_frm_ops *frm_ops, bool sender, struct m0_rpc_conn *rpc_conn, struct m0_rpc_session *rpc_session)
struct m0_reqh_context cc_reqh_ctx
struct m0_rpc_conn pc_conn
#define M0_ALLOC_PTR(ptr)
M0_INTERNAL void m0_semaphore_fini(struct m0_semaphore *semaphore)
void unprepare_rpc_env(struct test_rpc_env *env)
struct m0_rpc_session * ri_session
int(* fpo_register_filter)(const struct m0_fid *fid, const struct m0_fdmi_filter_desc *desc, const struct m0_fdmi_plugin_ops *pcb)
struct m0_rpc_item * m0_fop_to_rpc_item(const struct m0_fop *fop)
struct m0_sm_conf ft_conf
static struct m0_fop * fop
struct m0_fdmi_filter_reg * m0_fdmi__pdock_filter_reg_find(const struct m0_fid *fid)
struct m0_fid * fmf_flt_id
struct m0_uint128 fr_rec_id
M0_INTERNAL void m0_sm_group_lock(struct m0_sm_group *grp)
struct m0t1fs_filedata * fd
#define M0_UINT128(hi, lo)
const struct m0_filterc_ops filterc_stub_ops
struct m0_rpc_conn_pool * ut_pdock_conn_pool(void)
struct m0_rpc_session * frr_sess
struct m0_ut_suite fdmi_pd_ut
struct m0_rpc_session pc_sess
struct m0_rpc_session rlk_sess
M0_INTERNAL void m0_semaphore_down(struct m0_semaphore *semaphore)
M0_INTERNAL void m0_semaphore_up(struct m0_semaphore *semaphore)
struct m0_fop_fdmi_record * frr_rec
struct m0_rpc_machine * ri_rmachine
static int my_packet_ready(struct m0_rpc_packet *p)
M0_INTERNAL void m0_fdmi__plugin_dock_fini(void)
struct m0_rpc_item_ops release_ri_ops
struct m0_rpc_item f_item
const struct m0_reqh_service_type * ft_rstype
void(* fpo_release_fdmi_rec)(struct m0_uint128 *rec_id, struct m0_fid *filter_id)
static struct pdock_client_conn g_cc
struct m0_sm_conf ft_state_conf
void fdmi_pd_fake_rec_release(void)
static struct m0_rpc_conn * item2conn(const struct m0_rpc_item *item)
M0_INTERNAL const char * m0_rpc_item_remote_ep_addr(const struct m0_rpc_item *item)
struct m0_fop * m0_fop_alloc(struct m0_fop_type *fopt, void *data, struct m0_rpc_machine *mach)
const struct m0_fdmi_pd_ops * m0_fdmi_plugin_dock_api_get(void)