| /memcached-1.6.32/ |
| D | crc32c.c | 175 : "r"(next), "m"(*next)); in crc32c_hw()
176 next++; in crc32c_hw()
193 : "r"(next), "m"(*next)); in crc32c_hw()
213 : "r"(next), "m"(*next)); in crc32c_hw()
229 : "r"(next), "m"(*next)); in crc32c_hw()
239 : "r"(next), "m"(*next)); in crc32c_hw()
240 next++; in crc32c_hw()
305 next++; in crc32c_hw()
319 next += 64; in crc32c_hw()
325 next += 8; in crc32c_hw()
[all …]
|
| D | restart.c | 48 while (finder->next != NULL) { in restart_register()
49 finder = finder->next; in restart_register()
51 finder->next = cb; in restart_register()
171 cb = cb->next; in restart_get_kv()
255 cb = cb->next; in restart_save()
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()
412 if (ch->next) { in restart_fixup()
413 ch->next = (item_chunk *)((mc_ptr_t)ch->next - (mc_ptr_t)orig_addr); in restart_fixup()
[all …]
|
| D | stats_prefix.c | 25 PREFIX_STATS *cur, *next; in stats_prefix_clear() local
26 for (cur = prefix_stats[i]; cur != NULL; cur = next) { in stats_prefix_clear()
27 next = cur->next; in stats_prefix_clear()
58 for (pfs = prefix_stats[hashval]; NULL != pfs; pfs = pfs->next) { in stats_prefix_find()
80 pfs->next = prefix_stats[hashval]; in stats_prefix_find()
154 for (pfs = prefix_stats[i]; NULL != pfs; pfs = pfs->next) { in stats_prefix_dump()
|
| D | extstore.c | 46 struct __store_wbuf *next; member
73 struct _store_page *next; member
506 wbuf->next = 0; in _allocate_wbuf()
549 io->next = e->io_stack; in _wbuf_cb()
562 e->io_stack = io->next; in _submit_wbuf()
569 io->next = NULL; in _submit_wbuf()
683 tio = tio->next; in _extstore_submit()
875 obj_io *next = cur_io->next; in extstore_io_thread() local
943 cur_io = next; in extstore_io_thread()
966 prev->next = tmp->next; in _free_page()
[all …]
|
| D | items.c | 243 ch->next = nch; in do_item_alloc_chunk()
245 nch->next = 0; in do_item_alloc_chunk()
423 if (it->next) it->next->prev = it; in do_item_link_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()
607 next = iter->next; in item_flush_expired()
1289 if (b->next) b->next->prev = b; in lru_bump_buf_link_q()
1762 it->next = 0; in do_item_linktail_q()
1788 if (it->next) it->next->prev = it->prev; in do_item_unlinktail_q()
1789 if (it->prev) it->prev->next = it->next; in do_item_unlinktail_q()
[all …]
|
| D | slabs.c | 193 it->next = p->slots; in slabs_fixup()
194 if (it->next) it->next->prev = it; in slabs_fixup()
429 p->slots = it->next; in do_slabs_alloc()
430 if (it->next) it->next->prev = 0; in do_slabs_alloc()
462 if (chunk->next) { in do_slabs_free_chunked()
473 it->next = p->slots; in do_slabs_free_chunked()
474 if (it->next) it->next->prev = it; in do_slabs_free_chunked()
487 if (chunk->next) chunk->next->prev = chunk; in do_slabs_free_chunked()
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()
[all …]
|
| D | assoc.c | 205 item *it, *next; in assoc_maintenance_thread() local
214 for (it = old_hashtable[expand_bucket]; NULL != it; it = next) { in assoc_maintenance_thread()
215 next = it->h_next; in assoc_maintenance_thread()
300 item *next; member
322 if (iter->next != NULL) { in assoc_iterate()
323 iter->it = iter->next; in assoc_iterate()
324 iter->next = iter->it->h_next; in assoc_iterate()
346 iter->next = iter->it->h_next; in assoc_iterate()
|
| D | proxy_config.c | 18 struct _mcp_luafile *next; member
107 STAILQ_FOREACH(g, &head, next) { in _proxy_manager_thread()
302 } else if (ce->next <= now.tv_sec) { in proxy_run_crons()
327 if (ctx->cron_next > ce->next) { in proxy_run_crons()
328 ctx->cron_next = ce->next; in proxy_run_crons()
435 while (list->next) { in proxy_init_startfiles()
436 list = list->next; in proxy_init_startfiles()
438 assert(list->next == NULL); in proxy_init_startfiles()
439 list->next = db; in proxy_init_startfiles()
477 db = db->next; in proxy_load_files()
[all …]
|
| D | memcached.c | 1083 b->next = 0; in resp_allocate()
1119 if (b->next) b->next->prev = b->prev; in resp_free()
1120 if (b->prev) b->prev->next = b->next; in resp_free()
1137 if (b->next) b->next->prev = b; in resp_free()
1205 mc_resp *next = resp->next; in resp_finish() local
1237 return next; in resp_finish()
1472 if (dch->next) { in _store_item_copy_chunks()
2547 conn *next; local
2549 for (next = listen_conn; next; next = next->next) {
3515 for (next= ai; next; next= next->ai_next) {
[all …]
|
| D | extstore.h | 63 struct extstore_conf_file *next; member
80 struct _obj_io *next; member
|
| D | stats_prefix.h | 49 PREFIX_STATS *next; member
|
| D | memcached.h | 592 struct _stritem *next; member
621 struct _stritem *next; member
639 struct _strchunk *next; /* points within its own chain. */ member
770 struct _mc_resp *next; // choo choo. member
805 struct _mc_resp_bundle *next; member
902 conn *next; /* Used for generating a list of conn structures */ member
|
| D | logger.c | 588 l->next = logger_stack_head; in logger_link_q()
589 if (l->next) l->next->prev = l; in logger_link_q()
633 for (l = logger_stack_head; l != NULL; l=l->next) { in logger_set_flags()
911 for (l = logger_stack_head; l != NULL; l=l->next) { in logger_thread()
|
| D | logger.h | 185 struct _logger *next; member
|
| D | proxy.h | 359 uint32_t next; member
542 struct _io_pending_proxy_t *next; // stack for IO submission member
558 STAILQ_ENTRY(mcp_globalobj_s) next;
|
| D | proxy_lua.c | 185 ce->next = now.tv_sec + ce->every; in mcplib_register_cron()
197 ce->next = oldce->next; in mcplib_register_cron()
207 if (ctx->cron_next > ce->next) { in mcplib_register_cron()
208 ctx->cron_next = ce->next; in mcplib_register_cron()
962 STAILQ_INSERT_TAIL(&ctx->manager_head, &p->g, next); in mcplib_pool_proxy_gc()
|
| D | proto_proxy.c | 118 struct timeval next = { PROXY_GC_BACKGROUND_SECONDS, 0 }; in proxy_gc_timerpoke() local
119 evtimer_add(t->proxy_gc_timer, &next); in proxy_gc_timerpoke()
519 p = p->next; in proxy_submit_cb()
537 p = p->next; in proxy_submit_cb()
1354 p->next = q->stack_ctx; in mcp_queue_rctx_io()
1399 STAILQ_INSERT_TAIL(&ctx->manager_head, g, next); in mcp_gobj_enqueue()
|
| D | storage.c | 351 eio->next = q->stack_ctx; in storage_get_item()
459 p->io_ctx.next = NULL; in recache_or_free()
553 sch = sch->next; in storage_write()
1110 wrap.io.next = NULL; in storage_compact_thread()
1499 tmp->next = cf->storage_file; in storage_read_config()
|
| D | crawler.c | 711 crawlers[sid].next = 0; in do_lru_crawler_start()
|
| D | proto_bin.c | 377 ch = ch->next; in complete_update_bin()
|
| D | proxy_internal.c | 1769 io->eio.next = q->stack_ctx; in mcplib_internal_run()
|
| /memcached-1.6.32/vendor/mcmc/ |
| D | mcmc.c | 808 struct addrinfo *next = NULL; in mcmc_connect() local
830 for (next = ai; next != NULL; next = next->ai_next) { in mcmc_connect()
831 sock = socket(next->ai_family, next->ai_socktype, in mcmc_connect()
832 next->ai_protocol); in mcmc_connect()
859 if (connect(sock, next->ai_addr, next->ai_addrlen) != -1) { in mcmc_connect()
868 if (connect(sock, next->ai_addr, next->ai_addrlen) != -1) in mcmc_connect()
876 if (next == NULL) { in mcmc_connect()
|
| /memcached-1.6.32/doc/ |
| D | storage.txt | 56 then chunk and look up objects. Then read next 1MB chunk/etc. If there's
|
| D | protocol.txt | 121 flag and before the next space or newline, ie 'Oopaque' or 'Kuserkey'. Flags
|