Lines Matching refs:bucket

162     void **slot, nxt_uint_t nlvl, uint32_t *bucket);
231 uint32_t *bucket, *e; in nxt_lvlhsh_bucket_find() local
235 bucket = nxt_lvlhsh_bucket(lhq->proto, bkt); in nxt_lvlhsh_bucket_find()
237 e = bucket; in nxt_lvlhsh_bucket_find()
259 bkt = *nxt_lvlhsh_next_bucket(lhq->proto, bucket); in nxt_lvlhsh_bucket_find()
290 uint32_t *bucket; in nxt_lvlhsh_new_bucket() local
292 bucket = lhq->proto->alloc(lhq->pool, nxt_lvlhsh_bucket_size(lhq->proto)); in nxt_lvlhsh_new_bucket()
294 if (nxt_fast_path(bucket != NULL)) { in nxt_lvlhsh_new_bucket()
296 nxt_lvlhsh_set_entry_value(bucket, lhq->value); in nxt_lvlhsh_new_bucket()
297 nxt_lvlhsh_set_entry_key(bucket, lhq->key_hash); in nxt_lvlhsh_new_bucket()
299 *nxt_lvlhsh_next_bucket(lhq->proto, bucket) = NULL; in nxt_lvlhsh_new_bucket()
301 nxt_lvlhsh_store_bucket(*slot, bucket); in nxt_lvlhsh_new_bucket()
350 uint32_t *bucket, *e, *vacant_entry; in nxt_lvlhsh_bucket_insert() local
364 bucket = nxt_lvlhsh_bucket(proto, *bkt); in nxt_lvlhsh_bucket_insert()
366 e = bucket; in nxt_lvlhsh_bucket_insert()
407 if (e < nxt_lvlhsh_bucket_end(proto, bucket)) { in nxt_lvlhsh_bucket_insert()
418 bkt = nxt_lvlhsh_next_bucket(proto, bucket); in nxt_lvlhsh_bucket_insert()
436 ret = nxt_lvlhsh_convert_bucket_to_level(lhq, slot, nlvl, bucket); in nxt_lvlhsh_bucket_insert()
453 nxt_uint_t nlvl, uint32_t *bucket) in nxt_lvlhsh_convert_bucket_to_level() argument
486 end = nxt_lvlhsh_bucket_end(proto, bucket); in nxt_lvlhsh_convert_bucket_to_level()
488 for (e = bucket; e < end; e += NXT_LVLHSH_ENTRY_SIZE) { in nxt_lvlhsh_convert_bucket_to_level()
505 proto->free(lhq->pool, bucket); in nxt_lvlhsh_convert_bucket_to_level()
554 uint32_t *bucket, *e; in nxt_lvlhsh_bucket_convertion_insert() local
563 bucket = nxt_lvlhsh_bucket(proto, *bkt); in nxt_lvlhsh_bucket_convertion_insert()
565 e = bucket + n * NXT_LVLHSH_ENTRY_SIZE; in nxt_lvlhsh_bucket_convertion_insert()
567 if (nxt_fast_path(e < nxt_lvlhsh_bucket_end(proto, bucket))) { in nxt_lvlhsh_bucket_convertion_insert()
576 bkt = nxt_lvlhsh_next_bucket(proto, bucket); in nxt_lvlhsh_bucket_convertion_insert()
586 ret = nxt_lvlhsh_convert_bucket_to_level(lhq, slot, nlvl, bucket); in nxt_lvlhsh_bucket_convertion_insert()
688 uint32_t *bucket, *e; in nxt_lvlhsh_bucket_delete() local
695 bucket = nxt_lvlhsh_bucket(proto, *bkt); in nxt_lvlhsh_bucket_delete()
697 e = bucket; in nxt_lvlhsh_bucket_delete()
709 *bkt = *nxt_lvlhsh_next_bucket(proto, bucket); in nxt_lvlhsh_bucket_delete()
710 proto->free(lhq->pool, bucket); in nxt_lvlhsh_bucket_delete()
730 bkt = nxt_lvlhsh_next_bucket(proto, bucket); in nxt_lvlhsh_bucket_delete()
743 if (lhe->bucket == NXT_LVLHSH_BUCKET_DONE) { in nxt_lvlhsh_each()
751 if (nxt_slow_path(lhe->bucket == NULL)) { in nxt_lvlhsh_each()
766 lhe->bucket = nxt_lvlhsh_bucket(lhe->proto, slot); in nxt_lvlhsh_each()
800 if (lhe->bucket != NXT_LVLHSH_BUCKET_DONE) { in nxt_lvlhsh_level_each()
802 lhe->bucket = nxt_lvlhsh_bucket(lhe->proto, slot); in nxt_lvlhsh_level_each()
809 lhe->bucket = NULL; in nxt_lvlhsh_level_each()
834 uint32_t *bucket; in nxt_lvlhsh_bucket_each() local
838 bucket = &lhe->bucket[lhe->entry]; in nxt_lvlhsh_bucket_each()
841 } while (nxt_lvlhsh_free_entry(bucket)); in nxt_lvlhsh_bucket_each()
843 value = nxt_lvlhsh_entry_value(bucket); in nxt_lvlhsh_bucket_each()
848 next = *nxt_lvlhsh_next_bucket(lhe->proto, lhe->bucket); in nxt_lvlhsh_bucket_each()
850 lhe->bucket = (next == NULL) ? NXT_LVLHSH_BUCKET_DONE in nxt_lvlhsh_bucket_each()
938 uint32_t *bucket, *entry; in nxt_lvlhsh_bucket_peek() local
941 bucket = nxt_lvlhsh_bucket(peek->proto, *bkt); in nxt_lvlhsh_bucket_peek()
945 for (entry = bucket; in nxt_lvlhsh_bucket_peek()
958 *bkt = *nxt_lvlhsh_next_bucket(proto, bucket); in nxt_lvlhsh_bucket_peek()
959 proto->free(peek->pool, bucket); in nxt_lvlhsh_bucket_peek()