Home
last modified time | relevance | path

Searched refs:nkey (Results 1 – 17 of 17) sorted by relevance

/memcached-1.6.32/
Dproto_bin.c260 size_t nkey; in complete_incr_bin() local
443 if (nkey) { in write_bin_miss_response()
445 0, nkey, nkey); in write_bin_miss_response()
511 bodylen += nkey; in process_bin_get_or_touch()
512 keylen = nkey; in process_bin_get_or_touch()
619 if (nkey == 0) { in process_bin_stat()
779 if (nkey > ((item*) c->item)->nkey) { in process_bin_complete_sasl_auth()
785 char mech[nkey+1]; in process_bin_complete_sasl_auth()
787 mech[nkey] = 0x00; in process_bin_complete_sasl_auth()
1082 uint16_t nkey; in process_bin_update() local
[all …]
Dassoc.c70 item *assoc_find(const char *key, const size_t nkey, const uint32_t hv) { in assoc_find() argument
87 if ((nkey == it->nkey) && (memcmp(key, ITEM_key(it), nkey) == 0)) { in assoc_find()
96 MEMCACHED_ASSOC_FIND(key, nkey, depth); in assoc_find()
103 static item** _hashitem_before (const char *key, const size_t nkey, const uint32_t hv) { in _hashitem_before() argument
115 while (*pos && ((nkey != (*pos)->nkey) || memcmp(key, ITEM_key(*pos), nkey))) { in _hashitem_before()
168 MEMCACHED_ASSOC_INSERT(ITEM_key(it), it->nkey); in assoc_insert()
172 void assoc_delete(const char *key, const size_t nkey, const uint32_t hv) { in assoc_delete() argument
173 item **before = _hashitem_before(key, nkey, hv); in assoc_delete()
180 MEMCACHED_ASSOC_DELETE(key, nkey); in assoc_delete()
216 bucket = hash(ITEM_key(it), it->nkey) & hashmask(hashpower); in assoc_maintenance_thread()
Dstats_prefix.c37 PREFIX_STATS *stats_prefix_find(const char *key, const size_t nkey) { in stats_prefix_find() argument
45 for (length = 0; length < nkey && key[length] != '\0'; length++) { in stats_prefix_find()
89 void stats_prefix_record_get(const char *key, const size_t nkey, const bool is_hit) { in stats_prefix_record_get() argument
93 pfs = stats_prefix_find(key, nkey); in stats_prefix_record_get()
103 void stats_prefix_record_delete(const char *key, const size_t nkey) { in stats_prefix_record_delete() argument
107 pfs = stats_prefix_find(key, nkey); in stats_prefix_record_delete()
114 void stats_prefix_record_set(const char *key, const size_t nkey) { in stats_prefix_record_set() argument
118 pfs = stats_prefix_find(key, nkey); in stats_prefix_record_set()
Dstats_prefix.h25 void stats_prefix_record_get(const char *key, const size_t nkey, const bool is_hit);
28 void stats_prefix_record_delete(const char *key, const size_t nkey);
31 void stats_prefix_record_set(const char *key, const size_t nkey);
57 PREFIX_STATS *stats_prefix_find(const char *key, const size_t nkey);
Dproxy_internal.c230 int nkey = pr->klen; in process_get_cmd() local
247 p += it->nkey; in process_get_cmd()
311 size_t nkey = pr->klen; in process_update_cmd() local
424 size_t nkey = pr->klen; in process_arithmetic_cmd() local
466 size_t nkey = pr->klen; in process_delete_cmd() local
507 size_t nkey = pr->klen; in process_touch_cmd() local
571 memcpy(p, key, nkey); \
572 p += nkey; \
749 size_t nkey = pr->klen; in process_mget_cmd() local
1057 size_t nkey = pr->klen; in process_mset_cmd() local
[all …]
Dproto_text.c38 p += nkey; \
549 size_t nkey; in process_get_command() local
857 nkey = ret; in process_meta_command()
1077 size_t nkey; in process_mget_command() local
1397 size_t nkey; in process_mset_command() local
1612 size_t nkey; in process_mdelete_command() local
1764 size_t nkey; in process_marithmetic_command() local
1995 size_t nkey; in process_update_command() local
2097 size_t nkey; in process_touch_command() local
2143 size_t nkey; in process_arithmetic_command() local
[all …]
Dlogger.c70 le->nkey = it->nkey; in _logger_log_evictions()
73 memcpy(le->key, ITEM_key(it), it->nkey); in _logger_log_evictions()
85 le->nkey = it->nkey; in _logger_log_ext_write()
88 memcpy(le->key, ITEM_key(it), it->nkey); in _logger_log_ext_write()
99 int nkey = va_arg(ap, int); in _logger_log_item_get() local
106 le->nkey = nkey; in _logger_log_item_get()
109 memcpy(le->key, key, nkey); in _logger_log_item_get()
118 int nkey = va_arg(ap, int); in _logger_log_item_store() local
127 le->nkey = nkey; in _logger_log_item_store()
135 memcpy(le->key, key, nkey); in _logger_log_item_store()
[all …]
Dlogger.h79 uint8_t nkey; member
88 uint8_t nkey; member
96 uint8_t nkey; member
107 uint8_t nkey; member
117 uint8_t nkey; member
Ditems.c164 return sizeof(item) + nkey + *nsuffix + nbytes; in item_make_header()
331 it->nkey = nkey; in do_item_alloc()
333 memcpy(ITEM_key(it), key, nkey); in do_item_alloc()
392 uint32_t hv = hash(ITEM_key(it), it->nkey); in do_item_link_fixup()
522 assoc_delete(ITEM_key(it), it->nkey, hv); in do_item_unlink()
538 assoc_delete(ITEM_key(it), it->nkey, hv); in do_item_unlink_nolock()
668 assert(it->nkey <= KEY_MAX_LENGTH); in item_cachedump()
675 strncpy(key_temp, ITEM_key(it), it->nkey); in item_cachedump()
676 key_temp[it->nkey] = 0x00; /* terminate */ in item_cachedump()
981 item *it = assoc_find(key, nkey, hv); in do_item_get()
[all …]
Ditems.h14 item *do_item_alloc(const char *key, const size_t nkey, const client_flags_t flags, const rel_time_…
18 bool item_size_ok(const size_t nkey, const client_flags_t flags, const int nbytes);
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…
Dmemcached.h138 #define ITEM_suffix(item) ((char*) &((item)->data) + (item)->nkey + 1 \
141 #define ITEM_data(item) ((char*) &((item)->data) + (item)->nkey + 1 \
145 #define ITEM_ntotal(item) (sizeof(struct _stritem) + (item)->nkey + 1 \
602 uint8_t nkey; /* key length, w/terminating null and padding */ member
630 uint8_t nkey; /* key length, w/terminating null and padding */ member
654 int offset = it->nkey + 1 in ITEM_schunk()
664 #define ITEM_schunk(item) ((char*) &((item)->data) + (item)->nkey + 1 \
951 const size_t nkey, const bool incr,
998 const size_t nkey, bool incr,
1009 item *item_touch(const char *key, const size_t nkey, uint32_t exptime, LIBEVENT_THREAD *t);
[all …]
Dassoc.h4 item *assoc_find(const char *key, const size_t nkey, const uint32_t hv);
6 void assoc_delete(const char *key, const size_t nkey, const uint32_t hv);
Dthread.c870 it = do_item_alloc(key, nkey, flags, exptime, nbytes); in item_alloc()
881 hv = hash(key, nkey); in item_get()
883 it = do_item_get(key, nkey, hv, t, do_update); in item_get()
893 *hv = hash(key, nkey); in item_get_locked()
895 it = do_item_get(key, nkey, *hv, t, do_update); in item_get_locked()
902 hv = hash(key, nkey); in item_touch()
904 it = do_item_touch(key, nkey, exptime, hv, t); in item_touch()
915 hv = hash(ITEM_key(item), item->nkey); in item_remove()
936 hv = hash(ITEM_key(item), item->nkey); in item_unlink()
952 hv = hash(key, nkey); in add_delta()
[all …]
Dcrawler.c234 for (ii = 0; ii < search->nkey; ++ii) { in crawler_expired_eval()
282 uriencode(ITEM_key(it), keybuf, it->nkey, KEY_MAX_URI_ENCODED_LENGTH); in crawler_metadump_eval()
340 …p += base64_encode((unsigned char *) ITEM_key(it), it->nkey, (unsigned char*) p, LRU_CRAWLER_MINBU… in crawler_mgdump_eval()
344 memcpy(p, ITEM_key(it), it->nkey); in crawler_mgdump_eval()
345 p += it->nkey; in crawler_mgdump_eval()
570 uint32_t hv = hash(ITEM_key(search), search->nkey); in item_crawler_thread()
709 crawlers[sid].nkey = 0; in do_lru_crawler_start()
Dstorage.c265 new_it = item_alloc(ITEM_key(it), it->nkey, flags, it->exptime, it->nbytes); in storage_get_item()
511 item *hdr_it = do_item_alloc(ITEM_key(it), it->nkey, flags, it->exptime, sizeof(item_hdr)); in storage_write()
918 if (it->nkey == 0) { in storage_compact_readback()
926 hdr_it = assoc_find(ITEM_key(it), it->nkey, hv); in storage_compact_readback()
982 …item *new_it = do_item_alloc(ITEM_key(hdr_it), hdr_it->nkey, flags, hdr_it->exptime, sizeof(item_h… in storage_compact_readback()
Dmemcached.c1572 item *old_it = do_item_get(key, it->nkey, hv, t, DONT_UPDATE); in do_store_item()
1733 stored, comm, ITEM_key(it), it->nkey, it->nbytes, it->exptime, in do_store_item()
2018 bool get_stats(const char *stat_type, int nkey, ADD_STAT add_stats, void *c) { in get_stats() argument
2031 } else if (nz_strcmp(nkey, stat_type, "items") == 0) { in get_stats()
2033 } else if (nz_strcmp(nkey, stat_type, "slabs") == 0) { in get_stats()
2035 } else if (nz_strcmp(nkey, stat_type, "sizes") == 0) { in get_stats()
2222 it = item_touch(key, nkey, exptime, t); in limited_get()
2224 it = item_get(key, nkey, t, do_update); in limited_get()
2242 it = item_get_locked(key, nkey, t, do_update, hv); in limited_get_locked()
2275 it = do_item_get(key, nkey, hv, t, DONT_UPDATE);
[all …]
Dslabs.c903 hv = hash(ITEM_key(it), it->nkey); in slab_rebalance_move()