23 #define M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_CM 78 uint64_t proxy_id,
const char *
ep,
172 #undef M0_TRACE_SUBSYSTEM M0_INTERNAL void m0_cm_ag_id_copy(struct m0_cm_ag_id *dst, const struct m0_cm_ag_id *src)
#define M0_ALLOC_ARR(arr, nr)
struct m0_cm_sw swo_in_interval
#define M0_LOG(level,...)
struct m0_cm_sw px_last_sw_onwire_sent
M0_INTERNAL void m0_cm_ag_in_interval(const struct m0_cm *cm, struct m0_cm_sw *in_interval)
struct m0_cm_local_ep swo_cm_ep
M0_INTERNAL bool m0_cm_proxy_is_updated(struct m0_cm_proxy *proxy, struct m0_cm_sw *in_interval)
M0_INTERNAL bool m0_cm_ag_id_is_set(const struct m0_cm_ag_id *id)
M0_INTERNAL void m0_cm_sw_set(struct m0_cm_sw *dst, const struct m0_cm_ag_id *lo, const struct m0_cm_ag_id *hi)
return M0_ERR(-EOPNOTSUPP)
M0_INTERNAL void m0_cm_sw_copy(struct m0_cm_sw *dst, const struct m0_cm_sw *src)
M0_INTERNAL bool m0_cm_sw_is_set(const struct m0_cm_sw *sw)
M0_INTERNAL int m0_cm_ag_id_cmp(const struct m0_cm_ag_id *id0, const struct m0_cm_ag_id *id1)
M0_INTERNAL int m0_cm_sw_onwire_init(struct m0_cm *cm, struct m0_cm_sw_onwire *sw_onwire, uint64_t proxy_id, const char *ep, const struct m0_cm_sw *sw, const struct m0_cm_sw *out_interval)
struct m0_cm_sw swo_out_interval
bool px_send_final_update
bool m0_cm_cp_pump_is_complete(const struct m0_cm_cp_pump *cp_pump)
struct m0_cm_sw_update cm_sw_update
M0_INTERNAL void m0_cm_ag_out_interval(const struct m0_cm *cm, struct m0_cm_sw *out_interval)
M0_INTERNAL int m0_cm_sw_remote_update(struct m0_cm *cm)
M0_INTERNAL int m0_cm_ag_advance(struct m0_cm *cm)
M0_INTERNAL bool m0_cm_aggr_group_tlists_are_empty(struct m0_cm *cm)
static int start(struct m0_fom *fom)
M0_INTERNAL enum m0_cm_state m0_cm_state_get(const struct m0_cm *cm)
struct m0_cm_cp_pump cm_cp_pump
M0_INTERNAL bool m0_cm_is_locked(const struct m0_cm *cm)
#define m0_tl_for(name, head, obj)
M0_INTERNAL bool m0_cm_sw_cmp(const struct m0_cm_sw *sw0, const struct m0_cm_sw *sw1)
M0_INTERNAL int m0_cm_proxy_remote_update(struct m0_cm_proxy *proxy, struct m0_cm_sw *in_interval, struct m0_cm_sw *out_interval)
struct m0_pdclust_src_addr src
struct m0_cm_ag_id cm_sw_last_updated_hi
M0_INTERNAL int m0_cm_sw_local_update(struct m0_cm *cm)