Home
last modified time | relevance | path

Searched refs:bucket (Results 1 – 12 of 12) sorted by relevance

/memcached-1.6.32/
Dassoc.c206 uint64_t bucket; in assoc_maintenance_thread() local
218 primary_hashtable[bucket] = it; in assoc_maintenance_thread()
298 uint64_t bucket; member
328 item_unlock(iter->bucket); in assoc_iterate()
330 iter->bucket++; in assoc_iterate()
338 if (iter->bucket != hashsize(hashpower)) { in assoc_iterate()
340 item_lock(iter->bucket); in assoc_iterate()
343 iter->it = primary_hashtable[iter->bucket]; in assoc_iterate()
350 item_unlock(iter->bucket); in assoc_iterate()
352 iter->bucket++; in assoc_iterate()
[all …]
Dproxy_ratelim.c7 uint32_t bucket; member
74 lim->bucket = lim->limit; in _setup_tbf()
110 lim->bucket += toadd * lim->fill_rate; in _update_tbf()
111 if (lim->bucket > lim->limit) { in _update_tbf()
112 lim->bucket = lim->limit; in _update_tbf()
116 if (lim->bucket > take) { in _update_tbf()
117 lim->bucket -= take; in _update_tbf()
Dextstore.c215 pd[p->id].bucket = p->bucket; in extstore_get_page_data()
469 assert(!e->page_buckets[bucket] || e->page_buckets[bucket]->allocated == e->page_size); in _allocate_page()
482 tmp->next = e->page_buckets[bucket]; in _allocate_page()
483 e->page_buckets[bucket] = tmp; in _allocate_page()
488 tmp->bucket = bucket; in _allocate_page()
595 if (bucket >= e->page_bucketcount) in extstore_write_request()
599 p = e->page_buckets[bucket]; in extstore_write_request()
605 _evict_page(e, bucket, free_bucket); in extstore_write_request()
620 _evict_page(e, bucket, free_bucket); in extstore_write_request()
962 tmp = e->page_buckets[p->bucket]; in _free_page()
[all …]
Dextstore.h10 unsigned int bucket; member
61 unsigned int bucket; // free page bucket member
106 int extstore_write_request(void *ptr, unsigned int bucket, unsigned int free_bucket, obj_io *io);
Dstorage.c100 st.page_data[i].bucket); in process_extstore_stats()
516 int bucket = (it->it_flags & ITEM_CHUNKED) ? in storage_write() local
520 bucket = PAGE_BUCKET_LOWTTL; in storage_write()
530 if (extstore_write_request(storage, bucket, bucket, &io) == 0) { in storage_write()
575 LOGGER_LOG(NULL, LOG_EVICTIONS, LOGGER_EXTSTORE_WRITE, it, bucket); in storage_write()
746 unsigned int bucket; member
929 int bucket = flags.use_old ? PAGE_BUCKET_OLD : PAGE_BUCKET_COMPACT; in storage_compact_readback() local
945 bucket = PAGE_BUCKET_COLDCOMPACT; in storage_compact_readback()
961 if (extstore_write_request(storage, bucket, bucket, &io) == 0) { in storage_compact_readback()
1008 if (bucket == PAGE_BUCKET_COLDCOMPACT) { in storage_compact_readback()
[all …]
Ditems.c939 int bucket = ntotal / 32; in item_stats_sizes_add() local
940 if ((ntotal % 32) != 0) bucket++; in item_stats_sizes_add()
941 if (bucket < stats_sizes_buckets) stats_sizes_hist[bucket]++; in item_stats_sizes_add()
951 int bucket = ntotal / 32; in item_stats_sizes_remove() local
952 if ((ntotal % 32) != 0) bucket++; in item_stats_sizes_remove()
953 if (bucket < stats_sizes_buckets) stats_sizes_hist[bucket]--; in item_stats_sizes_remove()
Dlogger.h90 uint8_t bucket; member
Dcrawler.c256 int bucket = ttl_remain / 60; in crawler_expired_eval() local
257 if (bucket <= 60) { in crawler_expired_eval()
258 s->histo[bucket]++; in crawler_expired_eval()
Dlogger.c87 le->bucket = (uint8_t)ew_bucket; in _logger_log_ext_write()
296 (long long int)le->exptime, le->latime, le->clsid, le->bucket); in _logger_parse_extw()
DChangeLog430 * avva: bucket/generation patch (old, but Brad's just finally
/memcached-1.6.32/doc/
Dthreads.txt19 thread may read or write against a particular hash table bucket.
24 system must attempt to lock the item's bucket, which is done with a trylock
25 to avoid deadlocks. If a bucket is in use (and not by that thread) it will
Dstorage.txt45 goes into bucket 0, rest into bucket 1. Co-locating low TTL items means
48 2) Extended: "low TTL" is one bucket, and then one bucket per slab class.
102 In memcached's integration, a second bucket is used for objects rewritten via