25 #ifndef __MOTR_SNS_CM_AG_H__ 26 #define __MOTR_SNS_CM_AG_H__
static struct m0_fid gob_fid
M0_INTERNAL uint64_t m0_sns_cm_ag_local_cp_nr(const struct m0_cm_aggr_group *ag)
M0_INTERNAL void agid2fid(const struct m0_cm_ag_id *id, struct m0_fid *fid)
struct m0_bitmap sag_fmap
M0_INTERNAL void m0_sns_cm_ag_agid_setup(const struct m0_fid *gob_fid, uint64_t group, struct m0_cm_ag_id *agid)
static struct m0_sns_cm * scm
M0_INTERNAL void m0_sns_cm_ag_fini(struct m0_sns_cm_ag *sag)
M0_INTERNAL uint64_t agid2group(const struct m0_cm_ag_id *id)
M0_INTERNAL void m0_sns_cm_ag_iter_fini(struct m0_sns_cm_ag_iter *ai)
static struct m0_sns_cm_ag * sag
struct m0_sns_cm_file_ctx * ai_fctx
M0_INTERNAL bool m0_sns_cm_ag_is_frozen_on(struct m0_cm_aggr_group *ag, struct m0_cm_proxy *pxy)
struct m0_cm_proxy_in_count sag_proxy_in_count
M0_INTERNAL bool m0_sns_cm_ag_has_incoming_from(struct m0_cm_aggr_group *ag, struct m0_cm_proxy *proxy)
uint32_t sag_incoming_cp_nr
M0_INTERNAL struct m0_cm * snsag2cm(const struct m0_sns_cm_ag *sag)
struct m0_sns_cm_file_ctx * sag_fctx
M0_INTERNAL int m0_sns_cm_ag_init(struct m0_sns_cm_ag *sag, struct m0_cm *cm, const struct m0_cm_ag_id *id, const struct m0_cm_aggr_group_ops *ag_ops, bool has_incoming)
uint32_t sag_local_tgts_nr
M0_INTERNAL int m0_sns_cm_ag__next(struct m0_sns_cm *scm, const struct m0_cm_ag_id *id_curr, struct m0_cm_ag_id *id_next)
M0_INTERNAL bool m0_sns_cm_ag_has_data(struct m0_sns_cm_file_ctx *fctx, uint64_t group)
uint32_t sag_incoming_units_nr
uint32_t sag_cp_created_nr
struct m0_poolmach * ai_pm
static struct m0_sns_cm_file_ctx fctx
struct m0_cm_ag_id ai_id_next
struct m0_cm_aggr_group sag_base
M0_INTERNAL struct m0_sns_cm_ag * ag2snsag(const struct m0_cm_aggr_group *ag)
struct m0_cm_ag_id ai_id_curr
M0_INTERNAL int m0_sns_cm_ag_iter_init(struct m0_sns_cm_ag_iter *ai)