25 #ifndef __MOTR_HA_EPOCH_H__ 26 #define __MOTR_HA_EPOCH_H__
M0_INTERNAL void m0_ha_global_fini(void)
M0_INTERNAL void m0_ha_domain_put_read(struct m0_ha_domain *dom)
M0_INTERNAL int m0_ha_client_del(struct m0_confc *confc)
M0_INTERNAL void m0_ha_clients_iterate(m0_ha_client_cb_t iter, const void *data, uint64_t data2)
static struct m0_rpc_item * item
M0_INTERNAL uint64_t m0_ha_domain_get_read(struct m0_ha_domain *dom)
M0_INTERNAL void m0_ha_domain_fini(struct m0_ha_domain *dom)
M0_INTERNAL int m0_ha_global_init(void)
void client(struct client_params *params)
static struct m0_confc * confc
static struct m0_stob_domain * dom
M0_INTERNAL int m0_ha_epoch_check(const struct m0_rpc_item *item)
M0_INTERNAL void m0_ha_domain_put_write(struct m0_ha_domain *dom, uint64_t epoch)
M0_INTERNAL void m0_ha_domain_init(struct m0_ha_domain *dom, uint64_t epoch)
struct m0_ha_epoch_monitor hdo_default_mon
M0_EXTERN const uint64_t M0_HA_EPOCH_NONE
struct m0_rwlock hdo_lock
int(* hem_past)(struct m0_ha_epoch_monitor *self, uint64_t epoch, const struct m0_rpc_item *item)
int(* hem_future)(struct m0_ha_epoch_monitor *self, uint64_t epoch, const struct m0_rpc_item *item)
struct m0_ha_domain * hem_domain
struct m0_tlink hem_linkage
M0_INTERNAL int m0_ha_client_add(struct m0_confc *confc)
M0_INTERNAL uint64_t m0_ha_domain_get_write(struct m0_ha_domain *dom)
M0_INTERNAL void m0_ha_domain_monitor_del(struct m0_ha_domain *dom, struct m0_ha_epoch_monitor *mon)
M0_INTERNAL void m0_ha_domain_monitor_add(struct m0_ha_domain *dom, struct m0_ha_epoch_monitor *mon)
void(* m0_ha_client_cb_t)(void *client, const void *data, uint64_t data2)
struct m0_tl hdo_monitors