Home
last modified time | relevance | path

Searched refs:it (Results 1 – 25 of 38) sorted by relevance

12

/memcached-1.6.32/
Ditems.c312 it->next = it->prev = 0; in do_item_alloc()
423 if (it->next) it->next->prev = it; in do_item_link_q()
466 assert(it->next != it); in do_item_unlink_q()
467 assert(it->prev != it); in do_item_unlink_q()
469 if (it->next) it->next->prev = it->prev; in do_item_unlink_q()
470 if (it->prev) it->prev->next = it->next; in do_item_unlink_q()
671 it = it->next; in item_cachedump()
686 it = it->next; in item_cachedump()
1320 be->it = it; in lru_bump_async()
1788 if (it->next) it->next->prev = it->prev; in do_item_unlinktail_q()
[all …]
Dassoc.c71 item *it; in assoc_find() local
86 while (it) { in assoc_find()
87 if ((nkey == it->nkey) && (memcmp(key, ITEM_key(it), nkey) == 0)) { in assoc_find()
88 ret = it; in assoc_find()
91 it = it->h_next; in assoc_find()
168 MEMCACHED_ASSOC_INSERT(ITEM_key(it), it->nkey); in assoc_insert()
214 for (it = old_hashtable[expand_bucket]; NULL != it; it = next) { in assoc_maintenance_thread()
299 item *it; member
319 *it = NULL; in assoc_iterate()
325 *it = iter->it; in assoc_iterate()
[all …]
Dproxy_internal.c240 if (it) { in process_get_cmd()
246 memcpy(p, ITEM_key(it), it->nkey); in process_get_cmd()
263 resp_add_iov(resp, ITEM_data(it), it->nbytes); in process_get_cmd()
265 resp_add_chunked_iov(resp, it, it->nbytes); in process_get_cmd()
269 resp_add_iov(resp, ITEM_data(it), it->nbytes); in process_get_cmd()
271 resp_add_chunked_iov(resp, it, it->nbytes); in process_get_cmd()
316 item *it; in process_update_cmd() local
467 item *it; in process_delete_cmd() local
484 if (it) { in process_delete_cmd()
904 META_KEY(p, ITEM_key(it), it->nkey, (it->it_flags & ITEM_KEY_BINARY)); in process_mget_cmd()
[all …]
Dslabs.c194 if (it->next) it->next->prev = it; in slabs_fixup()
430 if (it->next) it->next->prev = 0; in do_slabs_alloc()
457 it->prev = 0; in do_slabs_free_chunked()
472 it->prev = 0; in do_slabs_free_chunked()
474 if (it->next) it->next->prev = it; in do_slabs_free_chunked()
475 p->slots = it; in do_slabs_free_chunked()
500 item *it; in do_slabs_free() local
515 if (it->next) it->next->prev = it; in do_slabs_free()
828 if (it->next) it->next->prev = it->prev; in slab_rebalance_cut_free()
829 if (it->prev) it->prev->next = it->next; in slab_rebalance_cut_free()
[all …]
Ditems.h17 void item_free(item *it);
23 void do_item_remove(item *it);
25 void do_item_update_nolock(item *it);
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; member
61 void item_stats_sizes_add(item *it);
[all …]
Dproto_text.c98 META_KEY(p, ITEM_key(it), it->nkey, (it->it_flags & ITEM_KEY_BINARY)); in _finalize_mset()
208 MEMCACHED_COMMAND_CAS(c->sfd, ITEM_key(it), it->nkey, it->nbytes, in complete_nread_ascii()
550 item *it; in process_get_command() local
599 memcpy(p, ITEM_key(it), it->nkey); in process_get_command()
862 if (it) { in process_meta_command()
1078 item *it; in process_mget_command() local
1158 if (it) { in process_mget_command()
1241 META_KEY(p, ITEM_key(it), it->nkey, (it->it_flags & ITEM_KEY_BINARY)); in process_mget_command()
1386 if (it) { in process_mget_command()
1398 item *it; in process_mset_command() local
[all …]
Dproto_bin.c258 item *it; in complete_incr_bin() local
371 *(ITEM_data(it) + it->nbytes - 2) = '\r'; in complete_update_bin()
372 *(ITEM_data(it) + it->nbytes - 1) = '\n'; in complete_update_bin()
392 MEMCACHED_COMMAND_ADD(c->sfd, ITEM_key(it), it->nkey, in complete_update_bin()
457 item *it; in process_bin_get_or_touch() local
485 if (it) { in process_bin_get_or_touch()
752 if (it == 0 || (it->it_flags & ITEM_CHUNKED)) { in process_bin_sasl_auth()
1084 item *it; in process_bin_update() local
1193 item *it; in process_bin_append_prepend() local
1283 item *it; in process_bin_delete() local
[all …]
Dcrawler.c274 if ((it->exptime != 0 && it->exptime < current_time) in crawler_metadump_eval()
276 refcount_decr(it); in crawler_metadump_eval()
282 uriencode(ITEM_key(it), keybuf, it->nkey, KEY_MAX_URI_ENCODED_LENGTH); in crawler_metadump_eval()
286 (it->exptime == 0) ? -1 : (long)(it->exptime + process_started), in crawler_metadump_eval()
293 refcount_decr(it); in crawler_metadump_eval()
329 if ((it->exptime != 0 && it->exptime < current_time) in crawler_mgdump_eval()
344 memcpy(p, ITEM_key(it), it->nkey); in crawler_mgdump_eval()
345 p += it->nkey; in crawler_mgdump_eval()
351 refcount_decr(it); in crawler_mgdump_eval()
449 item *it = NULL; in item_crawl_hash() local
[all …]
Dstorage.c265 new_it = item_alloc(ITEM_key(it), it->nkey, flags, it->exptime, it->nbytes); in storage_get_item()
288 p->hdr_it = it; in storage_get_item()
337 int iovtotal = (c->protocol == binary_prot) ? it->nbytes - 2 : it->nbytes; in storage_get_item()
456 slabs_free(it, ITEM_ntotal(it), ITEM_clsid(it)); in recache_or_free()
496 it_info.it = NULL; in storage_write()
504 item *it = it_info.it; in storage_write() local
511 item *hdr_it = do_item_alloc(ITEM_key(it), it->nkey, flags, it->exptime, sizeof(item_hdr)); in storage_write()
543 int hdrtotal = ITEM_ntotal(it) - it->nbytes; in storage_write()
572 item_replace(it, hdr_it, it_info.hv, ITEM_get_cas(it)); in storage_write()
582 do_item_remove(it); in storage_write()
[all …]
Drestart.c383 if (it->it_flags & ITEM_LINKED) { in restart_fixup()
385 if (it->next) { 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()
389 if (it->prev) { 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()
395 do_item_link_fixup(it); in restart_fixup()
400 if (it->it_flags & ITEM_CHUNKED) { in restart_fixup()
401 ch = (item_chunk *) ITEM_schunk(it); in restart_fixup()
[all …]
Dstorage.h4 void storage_delete(void *e, item *it);
6 #define STORAGE_delete(e, it) \ argument
8 storage_delete(e, it); \
17 bool storage_validate_item(void *e, item *it);
18 int storage_get_item(conn *c, item *it, mc_resp *resp);
Dlogger.c64 item *it = (item *)entry; in _logger_log_evictions() local
70 le->nkey = it->nkey; in _logger_log_evictions()
71 le->nbytes = it->nbytes; in _logger_log_evictions()
73 memcpy(le->key, ITEM_key(it), it->nkey); in _logger_log_evictions()
78 item *it = (item *)entry; in _logger_log_ext_write() local
85 le->nkey = it->nkey; in _logger_log_ext_write()
88 memcpy(le->key, ITEM_key(it), it->nkey); in _logger_log_ext_write()
141 item *it = (item *)entry; in _logger_log_item_deleted() local
144 le->nkey = it->nkey; in _logger_log_item_deleted()
146 le->nbytes = it->nbytes; in _logger_log_item_deleted()
[all …]
Dmemcached.h172 #define FLAGS_CONV(it, flag) { \ argument
173 if ((it)->it_flags & ITEM_CFLAGS) { \
174 flag = *((client_flags_t *)ITEM_suffix((it))); \
653 static inline char *ITEM_schunk(item *it) { in ITEM_schunk() argument
654 int offset = it->nkey + 1 in ITEM_schunk()
661 return ((char *) &(it->data)) + offset; in ITEM_schunk()
1010 int item_link(item *it);
1011 void item_remove(item *it);
1013 void item_unlink(item *it);
1022 #define refcount_incr(it) ++(it->refcount) argument
[all …]
Dmemcached.c1733 stored, comm, ITEM_key(it), it->nkey, it->nbytes, it->exptime, in do_store_item()
2220 item *it; in limited_get() local
2226 if (it && it->refcount > IT_REFCOUNT_LIMIT) { in limited_get()
2233 return it; in limited_get()
2241 item *it; in limited_get_locked() local
2243 if (it && it->refcount > IT_REFCOUNT_LIMIT) { in limited_get_locked()
2251 return it; in limited_get_locked()
2273 item *it; local
2276 if (!it) {
2338 memset(ITEM_data(it) + res, ' ', it->nbytes - res - 2);
[all …]
Dthread.c868 item *it; in item_alloc() local
871 return it; in item_alloc()
879 item *it; in item_get() local
883 it = do_item_get(key, nkey, hv, t, do_update); in item_get()
885 return it; in item_get()
892 item *it; in item_get_locked() local
895 it = do_item_get(key, nkey, *hv, t, do_update); in item_get_locked()
896 return it; in item_get_locked()
900 item *it; in item_touch() local
904 it = do_item_touch(key, nkey, exptime, hv, t); in item_touch()
[all …]
Dassoc.h14 bool assoc_iterate(void *iterp, item **it);
DREADME.md30 don't swap. memcached does non-blocking network I/O, but not disk. (it
31 should never go to disk, or you've lost the whole point of it)
DHACKING36 Because the version number changes on each commit, it's good to use a
56 support, it can be debugged in one of two ways:
/memcached-1.6.32/scripts/
Dmemcached-tool264 my $it = $items{$n};
265 next if (0 == $it->{total_pages});
266 my $size = $it->{chunk_size} < 1024 ?
267 "$it->{chunk_size}B" :
268 sprintf("%.1fK", $it->{chunk_size} / 1024.0);
269 my $full = $it->{used_chunks} == $it->{total_chunks} ? "yes" : " no";
271 $n, $size, $it->{age}, $it->{total_pages},
272 $it->{number}, $full, $it->{evicted},
273 $it->{evicted_time}, $it->{outofmemory});
D[email protected]1 # It's not recommended to modify this file in-place, because it will be
12 # whatever port you'd like. If /etc/sysconfig/memcached.<port> exists, it
40 # the pseudo TTY subsystem) to it, but no physical devices such as /dev/sda.
70 # mechanism. Almost no services need to write to these at runtime; it is hence
77 # to the control groups hierarchies; it is hence recommended to turn this
Dmemcached.service1 # It's not recommended to modify this file in-place, because it will be
35 # the pseudo TTY subsystem) to it, but no physical devices such as /dev/sda.
65 # mechanism. Almost no services need to write to these at runtime; it is hence
72 # to the control groups hierarchies; it is hence recommended to turn this
/memcached-1.6.32/doc/
Dstorage.txt8 indicates caller can try again another time. IE: it might be busy freeing
12 so it can give spurious failures (good for testing integration)
15 adds it to the end of a queue. It then signals the IO thread to run. Once an
28 processing to a minimum. Callbacks may be issued out of order, and it is the
29 caller's responsibility to know when its stack has been fully processed so it
57 anything we want to keep, pull it back into RAM before pages is freed.
83 time, it will have a chance of getting recached. "recache_rate" is a simple
85 instances of an item being hit twice within ~60s it will be recached into
100 means it has to rewrite 10 pages to free one page.
Dprotocol.txt11 just close the connection at any moment it no longer needs it. Note,
25 unstructured data in exactly the same way it received it, as a byte
36 data from a server, it must use the length of the data block (which it
253 it's followed by an empty data block).
403 without fetching it.
682 recaching this item. If there is data supplied it may use it, or the client
844 it as stale. This means when it is later fetched by metaget, the client will
1567 before it expired.
1649 If an error happens, it will return:
1754 | | of parsing it or executing it. |
[all …]
Dthreads.txt25 to avoid deadlocks. If a bucket is in use (and not by that thread) it will
35 - ITEM_LINKED must not be set before an item has a key copied into it.
55 point of a percent, and it does not improve scalability.
/memcached-1.6.32/m4/
Dc99-backport.m44 # option to output variable CC to make it so. This macro tries
6 # considers the compiler to be in ISO C99 mode if it handles _Bool,
148 dnl Solaris (unused because it causes the compiler to assume C99 semantics for
161 # helps, append it to CC. If eventually successful, run ACTION-IF-AVAILABLE,

12