23 #define M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_SNSCM 71 "transformed_cp_nr: [%" PRIu64 "] has_incoming: %d\n",
104 if (
rc == 0 ||
rc == -ENOENT) {
116 #undef M0_TRACE_SUBSYSTEM
M0_INTERNAL void m0_cm_ag_unlock(struct m0_cm_aggr_group *ag)
#define M0_LOG(level,...)
struct m0_cm_ag_id cag_id
M0_INTERNAL bool m0_fid_is_set(const struct m0_fid *fid)
static struct m0_sns_cm_ag * sag
M0_INTERNAL void m0_cm_ag_lock(struct m0_cm_aggr_group *ag)
void m0_fom_phase_move(struct m0_fom *fom, int32_t rc, int phase)
M0_INTERNAL int m0_sns_cm_cp_dup(struct m0_cm_cp *src, struct m0_cm_cp **dest)
struct m0_cm_aggr_group * c_ag
uint32_t sag_incoming_cp_nr
M0_INTERNAL struct m0_sns_cm_cp * cp2snscp(const struct m0_cm_cp *cp)
M0_INTERNAL int m0_sns_cm_rebalance_cp_xform(struct m0_cm_cp *cp)
M0_INTERNAL int m0_sns_cm_rebalance_tgt_info(struct m0_sns_cm_ag *sag, struct m0_sns_cm_cp *scp)
uint64_t cag_transformed_cp_nr
M0_INTERNAL int m0_cm_cp_enqueue(struct m0_cm *cm, struct m0_cm_cp *cp)
static struct m0_sns_cm_cp scp
uint32_t sag_cp_created_nr
M0_INTERNAL struct m0_sns_cm_ag * ag2snsag(const struct m0_cm_aggr_group *ag)