23 #define M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_HA 88 rep->gr_msg.s_len = 0;
105 for (
i = 0;
i < req_fop->
nv_nr; ++
i) {
155 if (ha_state_fop ==
NULL){
194 #undef M0_TRACE_SUBSYSTEM
uint32_t m0_fop_opcode(const struct m0_fop *fop)
#define M0_ALLOC_ARR(arr, nr)
M0_INTERNAL void m0_fom_block_enter(struct m0_fom *fom)
static struct m0_addb2_mach * m
const struct m0_fom_ops m0_ha_state_set_fom_ops
int(* fo_tick)(struct m0_fom *fom)
M0_INTERNAL struct m0_conf_obj * m0_conf_cache_lookup(const struct m0_conf_cache *cache, const struct m0_fid *id)
static void ha_state_get(struct m0_conf_cache *cache, struct m0_ha_nvec *req_fop, struct m0_ha_state_fop *rep_fop)
int(* fto_create)(struct m0_fop *fop, struct m0_fom **out, struct m0_reqh *reqh)
void * m0_fop_data(const struct m0_fop *fop)
static int ha_state_set_fom_tick(struct m0_fom *fom)
static size_t ha_state_fom_home_locality(const struct m0_fom *fom)
const struct m0_fom_ops ha_state_get_fom_ops
struct m0_fop_getxattr_rep * rep
struct m0_fom_type ft_fom_type
void m0_fom_init(struct m0_fom *fom, const struct m0_fom_type *fom_type, const struct m0_fom_ops *ops, struct m0_fop *fop, struct m0_fop *reply, struct m0_reqh *reqh)
struct m0_fop_type * f_type
struct m0_rpc_machine * m0_fop_rpc_machine(const struct m0_fop *fop)
return M0_ERR(-EOPNOTSUPP)
#define M0_NVEC_PRINT(nvec_, label, level)
M0_INTERNAL struct m0_confc * m0_reqh2confc(struct m0_reqh *reqh)
const struct m0_fom_type_ops * m0_ha_state_set_fom_type_ops
void m0_fom_fini(struct m0_fom *fom)
static struct m0_confc * confc
static const struct m0_fom_type_ops ha_get_fomt_ops
M0_INTERNAL void m0_fom_block_leave(struct m0_fom *fom)
struct m0_fop_type m0_ha_state_get_rep_fopt
struct m0_conf_cache cc_cache
static const struct m0_fom_type_ops ha_set_fomt_ops
void m0_rpc_reply_post(struct m0_rpc_item *request, struct m0_rpc_item *reply)
struct m0_fop_type m0_fop_generic_reply_fopt
struct m0_fop * m0_fop_reply_alloc(struct m0_fop *req, struct m0_fop_type *rept)
static int ha_state_get_fom_tick(struct m0_fom *fom)
const struct m0_fom_type_ops * m0_ha_state_get_fom_type_ops
#define M0_ALLOC_PTR(ptr)
void m0_fop_put_lock(struct m0_fop *fop)
static struct m0_fop * fop
static int ha_state_set_fom_create(struct m0_fop *fop, struct m0_fom **m, struct m0_reqh *reqh)
void m0_fom_phase_set(struct m0_fom *fom, int phase)
struct m0_ha_note * nv_note
M0_INTERNAL void m0_ha_state_accept(const struct m0_ha_nvec *note, bool ignore_same_state)
M0_INTERNAL void m0_conf_cache_lock(struct m0_conf_cache *cache)
static struct m0_dtm_oper_descr reply
struct m0_ha_nvec hs_note
static int ha_state_get_fom_create(struct m0_fop *fop, struct m0_fom **m, struct m0_reqh *reqh)
M0_INTERNAL struct m0_reqh * m0_fom2reqh(const struct m0_fom *fom)
M0_INTERNAL void m0_conf_cache_unlock(struct m0_conf_cache *cache)
struct m0_fop * m0_fop_alloc(struct m0_fop_type *fopt, void *data, struct m0_rpc_machine *mach)
static void ha_state_fom_fini(struct m0_fom *fom)