25 #ifndef __MOTR_HA_MSG_QUEUE_H__ 26 #define __MOTR_HA_MSG_QUEUE_H__
struct m0_ha_msg_queue_cfg mq_cfg
static struct buffer * cur(struct m0_addb2_mach *mach, m0_bcount_t space)
m0_ha_msg_qitem_delivery_state
static uint64_t tag(uint8_t code, uint64_t id)
M0_INTERNAL struct m0_ha_msg_qitem * m0_ha_msg_queue_dequeue(struct m0_ha_msg_queue *mq)
M0_INTERNAL void m0_ha_msg_queue_enqueue(struct m0_ha_msg_queue *mq, struct m0_ha_msg_qitem *qitem)
M0_INTERNAL struct m0_ha_msg_qitem * m0_ha_msg_queue_find(struct m0_ha_msg_queue *mq, uint64_t tag)
M0_INTERNAL void m0_ha_msg_queue_fini(struct m0_ha_msg_queue *mq)
M0_INTERNAL void m0_ha_msg_queue_free(struct m0_ha_msg_queue *mq, struct m0_ha_msg_qitem *qitem)
M0_INTERNAL struct m0_ha_msg_qitem * m0_ha_msg_queue_alloc(struct m0_ha_msg_queue *mq)
M0_INTERNAL bool m0_ha_msg_queue_is_empty(struct m0_ha_msg_queue *mq)
M0_INTERNAL struct m0_ha_msg_qitem * m0_ha_msg_queue_next(struct m0_ha_msg_queue *mq, const struct m0_ha_msg_qitem *cur)
M0_INTERNAL struct m0_ha_msg_qitem * m0_ha_msg_queue_prev(struct m0_ha_msg_queue *mq, const struct m0_ha_msg_qitem *cur)
enum m0_ha_msg_qitem_delivery_state hmq_delivery_state
M0_INTERNAL void m0_ha_msg_queue_init(struct m0_ha_msg_queue *mq, struct m0_ha_msg_queue_cfg *cfg)
M0_INTERNAL void m0_ha_msg_queue_push_front(struct m0_ha_msg_queue *mq, struct m0_ha_msg_qitem *qitem)