31 #define M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_HA 52 ka =
M0_AMB(ka, hh, kah_handler);
64 .u.hed_keepalive_rep = {
66 msg->
hm_data.
u.hed_keepalive_req.kaq_id,
74 U128_P(&
rep->hm_data.u.hed_keepalive_rep.kap_id),
75 rep->hm_data.u.hed_keepalive_rep.kap_counter, tag_rep);
101 #undef M0_TRACE_SUBSYSTEM
static uint64_t tag(uint8_t code, uint64_t id)
#define M0_LOG(level,...)
M0_INTERNAL void m0_ha_send(struct m0_ha *ha, struct m0_ha_link *hl, const struct m0_ha_msg *msg, uint64_t *tag)
struct m0_ha_msg_data hm_data
M0_INTERNAL int m0_ha_keepalive_handler_init(struct m0_ha_keepalive_handler *ka, struct m0_ha_dispatcher *hd)
struct m0_ha_handler kah_handler
struct m0_fop_getxattr_rep * rep
#define M0_AMB(obj, ptr, field)
m0_time_t m0_time_now(void)
struct m0_ha_dispatcher * kah_dispatcher
M0_INTERNAL void m0_ha_dispatcher_attach(struct m0_ha_dispatcher *hd, struct m0_ha_handler *hh)
static void ha_keepalive_msg_received_cb(struct m0_ha_handler *hh, struct m0_ha *ha, struct m0_ha_link *hl, struct m0_ha_msg *msg, uint64_t tag, void *data)
union m0_ha_msg_data::@212 u
M0_INTERNAL void m0_ha_dispatcher_detach(struct m0_ha_dispatcher *hd, struct m0_ha_handler *hh)
#define M0_ALLOC_PTR(ptr)
struct m0_atomic64 kah_counter
M0_INTERNAL void m0_ha_keepalive_handler_fini(struct m0_ha_keepalive_handler *ka)
static int64_t m0_atomic64_add_return(struct m0_atomic64 *a, int64_t d)
static void m0_atomic64_set(struct m0_atomic64 *a, int64_t num)