220 brw_fop->bo_base.rrq_policy =
RIP_NONE;
254 m0_rm_ur_tlink_del_fini(credit);
444 rvk_fop->fr_base.rrq_policy =
RIP_NONE;
468 m0_rm_ur_tlink_del_fini(credit);
474 m0_rm_ur_tlink_del_fini(credit);
static void rvk_data_setup(enum test_type test)
struct m0_reqh_service * reqh_svc
static void fom_fini_test(enum m0_rm_incoming_type fomtype)
enum m0_rm_remote_state rem_state
struct m0_fom_domain * fl_dom
static struct m0_fop * fop_alloc(enum m0_rm_incoming_type fomtype)
static void brw_test_cleanup(void)
static struct m0_rm_loan * test_loan
struct m0_rm_fop_req fr_base
struct rm_ctx rm_ctxs[SERVER_NR]
static int revoke_fom_tick(struct m0_fom *)
struct rm_ut_data rm_test_data
static struct m0_sm_group * grp
static void rm_ctx_init(struct m0_rm_lock_ctx *ctx, struct m0_client *m0c, struct m0_fid *fid)
struct m0_sm_group fl_group
struct m0_cookie rl_cookie
struct m0_rpc_machine rmc_rpc
struct m0_ut_rpc_mach_ctx rc_rmach_ctx
static void rmfoms_utinit(void)
static int revoke_fom_create(struct m0_fop *fop, struct m0_fom **out, struct m0_reqh *reqh)
static void fom_create_test(enum m0_rm_incoming_type fomtype, bool err_test)
static void rvk_fom_state_test(enum test_type test)
struct m0_sm_ast * s_forkq
struct m0_rm_owner * rd_owner
void * m0_fop_data(const struct m0_fop *fop)
struct m0_rm_fop_credit rrq_credit
static int borrow_fom_create(struct m0_fop *fop, struct m0_fom **out, struct m0_reqh *reqh)
M0_INTERNAL void m0_rm_remote_init(struct m0_rm_remote *rem, struct m0_rm_resource *res)
static void brw_fop_populate(struct m0_fom *fom, enum test_type test)
void m0_remotes_tlist_add(struct m0_tl *tl, struct m0_rm_remote *rem)
#define container_of(ptr, type, member)
struct m0_rm_credit rd_credit
M0_INTERNAL int m0_rm_loan_init(struct m0_rm_loan *loan, const struct m0_rm_credit *credit, struct m0_rm_remote *creditor)
M0_INTERNAL void m0_sm_group_fini(struct m0_sm_group *grp)
M0_INTERNAL int m0_rm_credit_encode(struct m0_rm_credit *credit, struct m0_buf *buf)
static void brw_fom_state_test(enum test_type test)
struct m0_rm_fop_req bo_base
M0_INTERNAL void m0_sm_group_unlock(struct m0_sm_group *grp)
static void rvk_fom_fini_test(void)
struct m0_rm_credit rl_credit
static void rm_ctx_fini(struct m0_ref *ref)
static void fom_fini(struct m0_fom *fom, enum m0_rm_incoming_type fomtype)
void rm_fom_funcs_test(void)
#define M0_FID_TINIT(type, container, key)
#define m0_tl_teardown(name, head, obj)
static void borrow_fom_fini(struct m0_fom *fom)
static struct m0_rpc_machine * machine
void rm_utdata_owner_windup_fini(struct rm_ut_data *data)
M0_INTERNAL void m0_sm_group_init(struct m0_sm_group *grp)
m0_time_t m0_time_now(void)
static void brw_fom_fini_test(void)
static struct m0_fom_locality dummy_loc
M0_INTERNAL void m0_cookie_init(struct m0_cookie *cookie, const uint64_t *obj)
struct m0_sm_ast * sa_next
M0_INTERNAL void m0_buf_free(struct m0_buf *buf)
void rm_utdata_init(struct rm_ut_data *data, enum obj_type type)
M0_INTERNAL void m0_fom_sm_init(struct m0_fom *fom)
static void brw_fom_state_validate(struct m0_fom *fom, int32_t rc, enum test_type test)
M0_INTERNAL int64_t m0_ref_read(const struct m0_ref *ref)
M0_INTERNAL void m0_rm_loan_fini(struct m0_rm_loan *loan)
static void rvk_fom_state_validate(struct m0_fom *fom, int32_t rc, enum test_type test)
M0_INTERNAL void m0_rm_credit_init(struct m0_rm_credit *credit, struct m0_rm_owner *owner)
M0_INTERNAL void m0_rm_remote_fini(struct m0_rm_remote *rem)
struct m0_fom_locality * fo_loc
#define M0_ALLOC_PTR(ptr)
bool m0_rm_ur_tlist_is_empty(const struct m0_tl *list)
M0_INTERNAL struct m0_fom_domain * m0_fom_dom(void)
void m0_ut_fom_phase_set(struct m0_fom *fom, int phase)
static struct m0_rm_remote * remote
struct m0_tl ro_owned[OWOS_NR]
static void rvk_fop_populate(struct m0_fom *fom)
void m0_fop_put_lock(struct m0_fop *fop)
static struct m0_fop * fop
struct m0_fop_type m0_rm_fop_revoke_fopt
const struct m0_tl_descr m0_remotes_tl
M0_INTERNAL void m0_sm_group_lock(struct m0_sm_group *grp)
static void m0_fi_enable_once(const char *func, const char *tag)
M0_INTERNAL void m0_rm_owner_unlock(struct m0_rm_owner *owner)
#define M0_UINT128(hi, lo)
void rings_utdata_ops_set(struct rm_ut_data *data)
void m0_remotes_tlist_del(struct m0_rm_remote *rem)
M0_INTERNAL void m0_fom_locality_inc(struct m0_fom *fom)
static void brw_fom_create_test(void)
void rm_test_owner_capital_raise(struct m0_rm_owner *owner, struct m0_rm_credit *credit)
struct m0_rm_resource * rd_res
struct m0_cookie rem_cookie
M0_INTERNAL void m0_rm_owner_lock(struct m0_rm_owner *owner)
static void borrow_fom_funcs_test(void)
M0_INTERNAL void m0_rm_credit_fini(struct m0_rm_credit *credit)
static int borrow_fom_tick(struct m0_fom *)
static void revoke_fom_funcs_test(void)
static void rmfoms_utfini(void)
struct m0_fop_type m0_rm_fop_borrow_fopt
static void rvk_fom_create_test(void)
#define m0_tl_for(name, head, obj)
static void rvk_test_cleanup(void)
struct m0_reqh_service dummy_svc
static void fom_create(enum m0_rm_incoming_type fomtype, bool err_test, struct m0_fop *fop, struct m0_fom **fom)
static void revoke_fom_fini(struct m0_fom *fom)
static void fop_dealloc(struct m0_fop *fop)
struct m0_rm_resource * ro_resource
struct m0_fop * m0_fop_alloc(struct m0_fop_type *fopt, void *data, struct m0_rpc_machine *mach)
#define M0_IMPOSSIBLE(fmt,...)