611 return q !=
NULL &&
q->cbcq_consumer != 0 &&
691 q->cbcq_nr > 0; ql = nql, --
q->cbcq_nr) {
696 q->cbcq_consumer = 0;
static void bev_cqueue_add(struct nlx_core_bev_cqueue *q, struct nlx_core_bev_link *ql)
static struct nlx_core_bev_link * bev_cqueue_get(struct nlx_core_bev_cqueue *q)
static struct m0_semaphore q
static size_t bev_cqueue_size(const struct nlx_core_bev_cqueue *q)
nlx_core_opaque_ptr_t cbl_c_next
struct nlx_core_kmem_loc cbl_p_next_loc
static void bev_cqueue_init(struct nlx_core_bev_cqueue *q, struct nlx_core_bev_link *ql1, struct nlx_core_bev_link *ql2)
static bool bev_cqueue_invariant(const struct nlx_core_bev_cqueue *q)
uint64_t nlx_core_opaque_ptr_t
struct nlx_core_kmem_loc cbl_p_self_loc
nlx_core_opaque_ptr_t cbl_c_self
static void m0_atomic64_dec(struct m0_atomic64 *a)
static bool bev_cqueue_is_empty(const struct nlx_core_bev_cqueue *q)
static int64_t m0_atomic64_get(const struct m0_atomic64 *a)
static void bev_cqueue_fini(struct nlx_core_bev_cqueue *q, void(*free_cb)(struct nlx_core_bev_link *))
static bool nlx_core_kmem_loc_invariant(const struct nlx_core_kmem_loc *loc)
static bool nlx_core_kmem_loc_is_empty(const struct nlx_core_kmem_loc *loc)
static void m0_atomic64_set(struct m0_atomic64 *a, int64_t num)