| /memcached-1.6.32/ |
| D | items.h | 17 void item_free(item *it);
23 void do_item_remove(item *it);
25 void do_item_update_nolock(item *it);
26 int do_item_replace(item *it, item *new_it, const uint32_t hv, const uint64_t cas);
27 void do_item_link_fixup(item *it);
29 int item_is_flushed(item *it);
32 void do_item_linktail_q(item *it);
33 void do_item_unlinktail_q(item *it);
34 item *do_item_crawl_q(item *it);
43 item *it;
[all …]
|
| D | thread.c | 620 c = conn_new(item->sfd, item->init_state, item->event_flags, in thread_libevent_process()
622 me->base, item->ssl, item->conntag, item->bproto); in thread_libevent_process()
868 item *it; in item_alloc()
879 item *it; in item_get()
892 item *it; in item_get_locked()
900 item *it; in item_touch()
913 void item_remove(item *item) { in item_remove() argument
915 hv = hash(ITEM_key(item), item->nkey); in item_remove()
934 void item_unlink(item *item) { in item_unlink() argument
936 hv = hash(ITEM_key(item), item->nkey); in item_unlink()
[all …]
|
| D | memcached.h | 135 #define ITEM_key(item) (((char*)&((item)->data)) \ argument
138 #define ITEM_suffix(item) ((char*) &((item)->data) + (item)->nkey + 1 \ argument
141 #define ITEM_data(item) ((char*) &((item)->data) + (item)->nkey + 1 \ argument
145 #define ITEM_ntotal(item) (sizeof(struct _stritem) + (item)->nkey + 1 \ argument
146 + (item)->nbytes \
150 #define ITEM_clsid(item) ((item)->slabs_clsid & ~(3<<6)) argument
151 #define ITEM_lruid(item) ((item)->slabs_clsid & (3<<6)) argument
180 #define FLAGS_SIZE(item) (((item)->it_flags & ITEM_CFLAGS) ? sizeof(client_flags_t) : 0) argument
613 } item; typedef
664 #define ITEM_schunk(item) ((char*) &((item)->data) + (item)->nkey + 1 \ argument
[all …]
|
| D | assoc.c | 38 static item** primary_hashtable = 0;
44 static item** old_hashtable = 0;
71 item *it; in assoc_find()
82 item *ret = NULL; in assoc_find()
104 item **pos; in _hashitem_before()
153 int assoc_insert(item *it, const uint32_t hv) { in assoc_insert()
176 item *nxt; in assoc_delete()
205 item *it, *next; in assoc_maintenance_thread()
299 item *it;
300 item *next;
[all …]
|
| D | assoc.h | 4 item *assoc_find(const char *key, const size_t nkey, const uint32_t hv);
5 int assoc_insert(item *item, const uint32_t hv);
14 bool assoc_iterate(void *iterp, item **it);
|
| D | storage.h | 4 void storage_delete(void *e, item *it);
17 bool storage_validate_item(void *e, item *it);
18 int storage_get_item(conn *c, item *it, mc_resp *resp);
39 #define STORE_OFFSET offsetof(item, nbytes)
|
| D | items.c | 94 item *it;
168 item *it = NULL; in do_item_alloc_pull()
257 item *it = NULL; in do_item_alloc()
390 item **head, **tail; in do_item_link_fixup()
414 item **head, **tail; in do_item_link_q()
595 item *iter, *next; in item_flush_expired()
649 item *it; in item_cachedump()
1108 item *it = NULL; in lru_pull_tail()
1115 item *search; in lru_pull_tail()
1116 item *next_it; in lru_pull_tail()
[all …]
|
| D | proto_bin.c | 38 if (c->item) { in complete_nread_binary()
258 item *it; in complete_incr_bin()
363 item *it = c->item; in complete_update_bin()
439 c->item = 0; in complete_update_bin()
457 item *it; in process_bin_get_or_touch()
779 if (nkey > ((item*) c->item)->nkey) { in process_bin_complete_sasl_auth()
786 memcpy(mech, ITEM_key((item*)c->item), nkey); in process_bin_complete_sasl_auth()
794 if (vlen > ((item*) c->item)->nbytes) { in process_bin_complete_sasl_auth()
1084 item *it; in process_bin_update()
1193 item *it; in process_bin_append_prepend()
[all …]
|
| D | restart.c | 369 item *it = (item *)((char *)mmap_base + checked); in restart_fixup()
386 it->next = (item *)((mc_ptr_t)it->next - (mc_ptr_t)orig_addr); in restart_fixup()
387 it->next = (item *)((mc_ptr_t)it->next + (mc_ptr_t)mmap_base); in restart_fixup()
390 it->prev = (item *)((mc_ptr_t)it->prev - (mc_ptr_t)orig_addr); in restart_fixup()
391 it->prev = (item *)((mc_ptr_t)it->prev + (mc_ptr_t)mmap_base); in restart_fixup()
421 ch->head = (item *)((mc_ptr_t)ch->head - (mc_ptr_t)orig_addr); in restart_fixup()
422 ch->head = (item *)((mc_ptr_t)ch->head + (mc_ptr_t)mmap_base); in restart_fixup()
|
| D | sizes.c | 17 display("Item (no cas)", sizeof(item)); in main()
18 display("Item (cas)", sizeof(item) + sizeof(uint64_t)); in main()
|
| D | slabs.c | 168 item *it = (item *)chunk; in slabs_fixup()
309 memset(ptr, 0, sizeof(item)); in slabs_prefill_global()
410 item *it = NULL; in do_slabs_alloc()
428 it = (item *)p->slots; in do_slabs_alloc()
500 item *it; in do_slabs_free()
509 it = (item *)ptr; in do_slabs_free()
793 item *new_it = NULL; in slab_rebalance_alloc()
873 item *it = slab_rebal.slab_pos; in slab_rebalance_move()
954 item *new_it = NULL; in slab_rebalance_move()
1128 item *it = slab_rebal.slab_pos; in slab_rebalance_finish()
[all …]
|
| D | crawler.c | 39 typedef void (*crawler_eval_func)(crawler_module_t *cm, item *it, uint32_t hv, int slab_cls);
64 static void crawler_expired_eval(crawler_module_t *cm, item *search, uint32_t hv, int i);
76 static void crawler_metadump_eval(crawler_module_t *cm, item *search, uint32_t hv, int i);
89 static void crawler_mgdump_eval(crawler_module_t *cm, item *search, uint32_t hv, int i);
270 static void crawler_metadump_eval(crawler_module_t *cm, item *it, uint32_t hv, int i) { in crawler_metadump_eval()
326 static void crawler_mgdump_eval(crawler_module_t *cm, item *it, uint32_t hv, int i) { in crawler_mgdump_eval()
434 do_item_unlinktail_q((item *)&crawlers[i]); in lru_crawler_class_done()
449 item *it = NULL; in item_crawl_hash()
540 item *search = NULL; in item_crawler_thread()
562 search = do_item_crawl_q((item *)&crawlers[i]); in item_crawler_thread()
[all …]
|
| D | proxy_result.c | 139 if (cresp->item) { in mcp_response_cleanup()
140 item_remove(cresp->item); in mcp_response_cleanup()
141 cresp->item = NULL; in mcp_response_cleanup()
|
| D | storage.c | 40 item *hdr_it; /* original header item. */
54 bool storage_validate_item(void *e, item *it) { in storage_validate_item()
63 void storage_delete(void *e, item *it) { in storage_delete()
150 item *read_it = (item *)io->buf; in _storage_get_item_cb()
259 item *new_it; in storage_get_item()
400 item *it = (item *)io->buf; in recache_or_free()
433 item *h_it = p->hdr_it; in recache_or_free()
504 item *it = it_info.it; in storage_write()
533 item *buf_it = (item *) io.buf; in storage_write()
913 item *hdr_it = NULL; in storage_compact_readback()
[all …]
|
| D | proxy_internal.c | 90 item *read_it = (item *)eio->buf; in _storage_get_item_cb()
288 resp->item = it; in process_get_cmd()
291 resp->item = it; in process_get_cmd()
316 item *it; in process_update_cmd()
467 item *it; in process_delete_cmd()
510 item *it; in process_touch_cmd()
750 item *it; in process_mget_cmd()
968 resp->item = it; in process_mget_cmd()
979 resp->item = it; in process_mget_cmd()
1059 item *it; in process_mset_cmd()
[all …]
|
| D | proto_text.c | 54 item *it = c->item; in _finalize_mset()
135 item *it = c->item; in complete_nread_ascii()
240 c->item = 0; in complete_nread_ascii()
550 item *it; in process_get_command()
1078 item *it; in process_mget_command()
1398 item *it; in process_mset_command()
1572 c->item = it; in process_mset_command()
2001 item *it; in process_update_command()
2080 c->item = it; in process_update_command()
2100 item *it; in process_touch_command()
[all …]
|
| D | memcached.c | 743 c->item = 0; in conn_new()
814 if (c->item) { in conn_release_items()
821 c->item = 0; in conn_release_items()
990 if (resp->item) { in resp_reset()
1206 if (resp->item) { in resp_finish()
1468 static int _store_item_copy_chunks(item *d_it, item *s_it, const int len) { in _store_item_copy_chunks()
1538 static int _store_item_copy_data(int comm, item *old_it, item *new_it, item *add_it) { in _store_item_copy_data()
2220 item *it; in limited_get()
2241 item *it; in limited_get_locked()
2273 item *it;
[all …]
|
| D | proto_proxy.c | 720 if (strncmp((char *)c->item + rq->pr.vlen - 2, "\r\n", 2) != 0) { in complete_nread_proxy()
733 rq->pr.vbuf = c->item; in complete_nread_proxy()
734 c->item = NULL; in complete_nread_proxy()
853 resp->item = tresp->item; // will be populated if not extstore fetch in _proxy_run_tresp_to_resp()
854 tresp->item = NULL; // move ownership of the item to resp from tresp in _proxy_run_tresp_to_resp()
1196 c->item = NULL; in proxy_process_command()
1203 c->item = malloc(pr.vlen); in proxy_process_command()
1205 if (c->item == NULL) { in proxy_process_command()
1217 c->ritem = c->item; in proxy_process_command()
|
| D | logger.c | 64 item *it = (item *)entry; in _logger_log_evictions()
78 item *it = (item *)entry; in _logger_log_ext_write()
141 item *it = (item *)entry; in _logger_log_item_deleted()
|
| D | ChangeLog | 76 * New stat: Last accessed time for last evicted item per slab class.
111 * Add per-item-class tracking of evictions and OOM errors (dormando)
576 * big bug fix: item exptime 0 meant expire immediately, not never
|
| /memcached-1.6.32/doc/ |
| D | threads.txt | 14 - A secondary small hash table of locks is used to lock an item by its hash
15 value. This prevents multiple threads from acting on the same item at the
20 - atomic refcounts per item are used to manage garbage collection and
23 - When pulling an item off of the LRU tail for eviction or re-allocation, the
24 system must attempt to lock the item's bucket, which is done with a trylock
26 walk up the LRU a little in an attempt to fetch a non-busy item.
33 - item_lock must be held while modifying an item.
34 - slabs_lock must be held while modifying the ITEM_SLABBED flag bit within an item.
35 - ITEM_LINKED must not be set before an item has a key copied into it.
50 item or lru locks.
|
| D | protocol.txt | 319 this specific item.
459 this specific item.
564 - X: item is stale
634 create a stub item with the key and TTL as supplied. If such an item is
649 the right to recache an item. This allows refreshing an item before it leads to
669 - X: item is stale
821 stored item.
833 - x: removes the item value, but leaves the item.
843 Instead of removing an item, this will give the item a new CAS value and mark
862 - x: removes the item value, but leaves the item.
[all …]
|
| D | protocol-binary.txt | 548 If the item exist on the server the following packet is returned,
699 MUST only succeed if the item exists and has a CAS value identical to
702 Add MUST fail if the item already exist.
704 Replace MUST fail if the item doesn't exist.
706 Set should store the data unconditionally if the item exists or not.
791 succeeds, the CAS value for the item is returned in the CAS-field of
836 Delete the item with the specific key.
847 The following figure shows a delete message for the item "Hello".
1526 contains the name of the statistical item and the body contains the
|
| D | storage.txt | 20 item has been removed from that page. It's important to call this as items are
85 instances of an item being hit twice within ~60s it will be recached into
|
| D | new_lru.txt | 32 most item reads, largely during sets and from the background thread. Also the
|