Lines Matching refs:mq_cap
193 size_t mq_cap; /* Capacity of the items */ member
228 mergeq_free(mqp->mq_items, sizeof (void *) * mqp->mq_cap); in mergeq_fini()
292 mqp->mq_cap = MERGEQ_DEFAULT_CAP; in mergeq_init()
302 if (mqp->mq_cap != 0) in mergeq_reset()
303 bzero(mqp->mq_items, sizeof (void *) * mqp->mq_cap); in mergeq_reset()
326 if (SIZE_MAX - mqp->mq_cap < MERGEQ_DEFAULT_CAP) in mergeq_grow()
329 ncap = mqp->mq_cap + MERGEQ_DEFAULT_CAP; in mergeq_grow()
335 bcopy(mqp->mq_items, items, mqp->mq_cap * sizeof (void *)); in mergeq_grow()
336 mergeq_free(mqp->mq_items, sizeof (mqp->mq_cap) * sizeof (void *)); in mergeq_grow()
338 mqp->mq_cap = ncap; in mergeq_grow()
351 if (mqp->mq_next == mqp->mq_cap) { in mergeq_add()
373 VERIFY(mqp->mq_next < mqp->mq_cap); in mergeq_slot()
378 VERIFY(mqp->mq_nproc != (mqp->mq_next + 1) % mqp->mq_cap); in mergeq_slot()
382 if (mqp->mq_next == mqp->mq_cap) { in mergeq_slot()
383 mqp->mq_next %= mqp->mq_cap; in mergeq_slot()
398 VERIFY(slot < mqp->mq_cap); in mergeq_push()
414 if (mqp->mq_ncommit == mqp->mq_cap) { in mergeq_push()
415 mqp->mq_ncommit %= mqp->mq_cap; in mergeq_push()
437 if (mqp->mq_nproc == mqp->mq_cap) { in mergeq_pop_one()
438 mqp->mq_nproc %= mqp->mq_cap; in mergeq_pop_one()
455 VERIFY(mqp->mq_nproc < mqp->mq_cap); in mergeq_pop()
560 if (mqp->mq_next == mqp->mq_cap) { in mergeq_merge()
561 mqp->mq_next %= mqp->mq_cap; in mergeq_merge()