| /memcached-1.6.32/ |
| D | thread.c | 880 uint32_t hv; in item_get() local
882 item_lock(hv); in item_get()
901 uint32_t hv; in item_touch() local
903 item_lock(hv); in item_touch()
914 uint32_t hv; in item_remove() local
917 item_lock(hv); in item_remove()
935 uint32_t hv; in item_unlink() local
937 item_lock(hv); in item_unlink()
950 uint32_t hv; in add_delta() local
953 item_lock(hv); in add_delta()
[all …]
|
| D | items.h | 20 int do_item_link(item *it, const uint32_t hv, const uint64_t cas); /** may fail if transgresse…
21 void do_item_unlink(item *it, const uint32_t hv);
22 void do_item_unlink_nolock(item *it, const uint32_t hv);
26 int do_item_replace(item *it, item *new_it, const uint32_t hv, const uint64_t cas);
44 uint32_t hv; member
73 item *do_item_get(const char *key, const size_t nkey, const uint32_t hv, LIBEVENT_THREAD *t, const …
74 item *do_item_touch(const char *key, const size_t nkey, uint32_t exptime, const uint32_t hv, LIBEVE…
75 void do_item_bump(LIBEVENT_THREAD *t, item *it, const uint32_t hv);
|
| D | assoc.c | 70 item *assoc_find(const char *key, const size_t nkey, const uint32_t hv) { in assoc_find() argument
75 (oldbucket = (hv & hashmask(hashpower - 1))) >= expand_bucket) in assoc_find()
79 it = primary_hashtable[hv & hashmask(hashpower)]; in assoc_find()
108 (oldbucket = (hv & hashmask(hashpower - 1))) >= expand_bucket) in _hashitem_before()
112 pos = &primary_hashtable[hv & hashmask(hashpower)]; in _hashitem_before()
153 int assoc_insert(item *it, const uint32_t hv) { in assoc_insert() argument
159 (oldbucket = (hv & hashmask(hashpower - 1))) >= expand_bucket) in assoc_insert()
164 it->h_next = primary_hashtable[hv & hashmask(hashpower)]; in assoc_insert()
165 primary_hashtable[hv & hashmask(hashpower)] = it; in assoc_insert()
172 void assoc_delete(const char *key, const size_t nkey, const uint32_t hv) { in assoc_delete() argument
[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);
6 void assoc_delete(const char *key, const size_t nkey, const uint32_t hv);
|
| D | items.c | 95 uint32_t hv; member
393 assoc_insert(it, hv); in do_item_link_fixup()
505 assoc_insert(it, hv); in do_item_link()
589 do_item_unlink(it, hv); in do_item_replace()
590 return do_item_link(new_it, hv, cas); in do_item_replace()
1022 do_item_unlink(it, hv); in do_item_get()
1034 do_item_unlink(it, hv); in do_item_get()
1246 ret_it->hv = hv; in lru_pull_tail()
1321 be->hv = hv; in lru_bump_async()
1362 item_lock(be->hv); in lru_maintainer_bumps()
[all …]
|
| D | proxy_internal.c | 468 uint32_t hv; in process_delete_cmd() local
502 item_unlock(hv); in process_delete_cmd()
990 item_unlock(hv); in process_mget_cmd()
1157 item_unlock(hv); in process_mset_cmd()
1270 uint32_t hv; in process_mdelete_cmd() local
1394 item_unlock(hv); in process_mdelete_cmd()
1405 item_unlock(hv); in process_mdelete_cmd()
1426 uint32_t hv = 0; in process_marithmetic_cmd() local
1471 item_lock(hv); in process_marithmetic_cmd()
1622 item_unlock(hv); in process_marithmetic_cmd()
[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);
209 static void crawler_expired_eval(crawler_module_t *cm, item *search, uint32_t hv, int i) { in crawler_expired_eval() argument
245 do_item_unlink_nolock(search, hv); in crawler_expired_eval()
270 static void crawler_metadump_eval(crawler_module_t *cm, item *it, uint32_t hv, int i) { in crawler_metadump_eval() argument
326 static void crawler_mgdump_eval(crawler_module_t *cm, item *it, uint32_t hv, int i) { in crawler_mgdump_eval() argument
570 uint32_t hv = hash(ITEM_key(search), search->nkey); in item_crawler_thread() local
574 if ((hold_lock = item_trylock(hv)) == NULL) { in item_crawler_thread()
[all …]
|
| D | proto_text.c | 1327 item_unlock(hv); in process_mget_command()
1566 item_unlock(hv); in process_mset_command()
1615 uint32_t hv = 0; in process_mdelete_command() local
1746 item_unlock(hv); in process_mdelete_command()
1757 item_unlock(hv); in process_mdelete_command()
1778 uint32_t hv = 0; in process_marithmetic_command() local
1827 item_lock(hv); in process_marithmetic_command()
1976 item_unlock(hv); in process_marithmetic_command()
1988 item_unlock(hv); in process_marithmetic_command()
2193 uint32_t hv; in process_delete_command() local
[all …]
|
| D | memcached.h | 953 uint64_t *cas, const uint32_t hv,
955 enum store_item_type do_store_item(item *item, int comm, LIBEVENT_THREAD *t, const uint32_t hv, int…
1008 …locked(const char *key, const size_t nkey, LIBEVENT_THREAD *t, const bool do_update, uint32_t *hv);
1012 int item_replace(item *it, item *new_it, const uint32_t hv, const uint64_t cas_in);
1015 void item_lock(uint32_t hv);
1016 void *item_trylock(uint32_t hv);
1018 void item_unlock(uint32_t hv);
1050 …ed(const char *key, size_t nkey, LIBEVENT_THREAD *t, bool do_update, uint32_t *hv, bool *overflow);
|
| D | slabs.c | 860 uint32_t hv; in slab_rebalance_move() local
871 hv = 0; in slab_rebalance_move()
903 hv = hash(ITEM_key(it), it->nkey); in slab_rebalance_move()
904 if ((hold_lock = item_trylock(hv)) == NULL) { in slab_rebalance_move()
929 do_item_unlink(it, hv); in slab_rebalance_move()
1007 do_item_replace(it, new_it, hv, ITEM_get_cas(it)); in slab_rebalance_move()
1044 do_item_unlink(it, hv); in slab_rebalance_move()
1053 do_item_unlink(it, hv); in slab_rebalance_move()
|
| D | storage.c | 429 uint32_t hv = (uint32_t)it->time; in recache_or_free() local
431 void *hold_lock = item_trylock(hv); in recache_or_free()
446 item_replace(h_it, it, hv, ITEM_get_cas(h_it)); in recache_or_free()
534 buf_it->time = it_info.hv; in storage_write()
572 item_replace(it, hdr_it, it_info.hv, ITEM_get_cas(it)); in storage_write()
583 item_unlock(it_info.hv); in storage_write()
923 uint32_t hv = (uint32_t)it->time; in storage_compact_readback() local
924 item_lock(hv); in storage_compact_readback()
926 hdr_it = assoc_find(ITEM_key(it), it->nkey, hv); in storage_compact_readback()
998 item_replace(hdr_it, new_it, hv, ITEM_get_cas(hdr_it)); in storage_compact_readback()
[all …]
|
| D | proto_bin.c | 1284 uint32_t hv; in process_bin_delete() local
1303 it = item_get_locked(key, nkey, c->thread, DONT_UPDATE, &hv); in process_bin_delete()
1311 do_item_unlink(it, hv); in process_bin_delete()
1324 item_unlock(hv); in process_bin_delete()
|
| D | memcached.c | 1570 enum store_item_type do_store_item(item *it, int comm, LIBEVENT_THREAD *t, const uint32_t hv, int *… in do_store_item() argument
1572 item *old_it = do_item_get(key, it->nkey, hv, t, DONT_UPDATE); in do_store_item()
1686 item_replace(old_it, it, hv, cas_in); in do_store_item()
1724 do_item_link(it, hv, cas_in); in do_store_item()
2240 …d(const char *key, size_t nkey, LIBEVENT_THREAD *t, bool do_update, uint32_t *hv, bool *overflow) { in limited_get_locked() argument
2242 it = item_get_locked(key, nkey, t, do_update, hv); in limited_get_locked()
2246 item_unlock(*hv); in limited_get_locked()
2268 const uint32_t hv, argument
2275 it = do_item_get(key, nkey, hv, t, DONT_UPDATE);
2351 item_replace(it, new_it, hv, (settings.use_cas) ? get_cas_id() : 0);
|