Home
last modified time | relevance | path

Searched refs:p (Results 1 – 25 of 43) sorted by relevance

12

/memcached-1.6.32/
Ditoa_ljust.c75 return p + 2; in out2()
86 *p = out1('0'+*d, *p); in digits()
94 case 10: d = u / 100000000; p = out2( d, p ); in itoa()
96 case 8: d = u / 1000000; p = out2( d, p ); in itoa()
98 case 6: d = u / 10000; p = out2( d, p ); in itoa()
100 case 4: d = u / 100; p = out2( d, p ); in itoa()
102 case 2: d = u / 1; p = out2( d, p ); in itoa()
105 *p = '\0'; in itoa()
106 return p; in itoa()
135 p = itoa_u64(upper, p); in itoa_u64()
[all …]
Dextstore.c205 pd[p->id].version = p->version; in extstore_get_page_data()
210 if (p->active || p->free) { in extstore_get_page_data()
215 pd[p->id].bucket = p->bucket; in extstore_get_page_data()
217 if ((p->obj_count == 0 || p->closed) && p->refcount == 0) { in extstore_get_page_data()
614 ((!p->wbuf || p->wbuf->full) && p->allocated >= e->page_size)) { in extstore_write_request()
626 if (p->wbuf && p->wbuf->free < io->len && !p->wbuf->full) { in extstore_write_request()
637 if (p->wbuf && !p->wbuf->full && p->wbuf->free >= io->len) { in extstore_write_request()
655 io->offset = p->wbuf->offset + (p->wbuf->size - p->wbuf->free); in extstore_write()
748 if (p->obj_count == 0 && p->refcount == 0 && !p->active) { in extstore_delete()
776 if (!p->closed && !p->active && p->version == page_version) { in extstore_close_page()
[all …]
Dproxy_internal.c207 p++; in make_ascii_get_suffix()
210 p++; in make_ascii_get_suffix()
215 p = itoa_u32(nbytes-2, p+1); in make_ascii_get_suffix()
219 p = itoa_u64(ITEM_get_cas(it), p+1); in make_ascii_get_suffix()
559 p++; \
823 p = itoa_u32(it->nbytes-2, p+3); in process_mget_cmd()
853 p = itoa_u32(it->nbytes-2, p); in process_mget_cmd()
1232 p = itoa_u64(cas, p); in process_mset_cmd()
1239 p = itoa_u32(nbytes-2, p); in process_mset_cmd()
1546 p = itoa_u32(vlen, p+3); in process_marithmetic_cmd()
[all …]
Dslabs.c167 slabclass_t *p; in slabs_fixup() local
177 p->slab_list[p->slabs++] = (char*)chunk; in slabs_fixup()
185 p->slab_list[p->slabs++] = chunk; in slabs_fixup()
310 p->slab_list[p->slabs++] = ptr; in slabs_prefill_global()
339 if (p->slabs == p->list_size) { in grow_slab_list()
364 char *ret = p->slab_list[p->slabs - 1]; in get_page_from_global_pool()
365 p->slabs--; in get_page_from_global_pool()
374 : p->size * p->perslab; in do_slabs_newslab()
399 p->slab_list[p->slabs++] = ptr; in do_slabs_newslab()
476 p->sl_curr++; in do_slabs_free_chunked()
[all …]
Dproto_text.c21 p++; \
27 p += 2; \
83 p += 2; in _finalize_mset()
104 p = itoa_u64(cas, p); in _finalize_mset()
111 p = itoa_u32(nbytes-2, p); in _finalize_mset()
113 p = itoa_u32(it->nbytes-2, p); in _finalize_mset()
525 p++; in make_ascii_get_suffix()
533 p = itoa_u32(nbytes-2, p+1); in make_ascii_get_suffix()
537 p = itoa_u64(ITEM_get_cas(it), p+1); in make_ascii_get_suffix()
1161 p = itoa_u32(it->nbytes-2, p+3); in process_mget_command()
[all …]
Dproxy_request.c509 p++; in mcp_request_render()
521 p++; in mcp_request_render()
533 p += 2; in mcp_request_render()
563 *p = ' '; in mcp_request_append()
564 p++; in mcp_request_append()
568 p++; in mcp_request_append()
576 p += 2; in mcp_request_append()
1114 if (!p) { in mcplib_request_match_res()
1125 } else if (*p == 'k' || *p == 'O') { in mcplib_request_match_res()
1145 while (p != e && !isspace(*p)) { in mcplib_request_match_res()
[all …]
Dstorage.c148 conn *c = p->c; in _storage_get_item_cb()
280 p->active = true; in storage_get_item()
281 p->miss = false; in storage_get_item()
288 p->hdr_it = it; in storage_get_item()
289 p->resp = resp; in storage_get_item()
348 p->c = c; in storage_get_item()
397 conn *c = p->c; in recache_or_free()
403 if (p->active) { in recache_or_free()
1197 if (p == NULL) in storage_conf_parse()
1208 unit = tolower(p[strlen(p)-1]); in storage_conf_parse()
[all …]
Dproxy_lua.c623 mcp_gobj_finalize(&p->g); in mcplib_pool_gc()
749 mcp_pool_be_t *s = &p->pool[x-1 + (offset * p->pool_size)]; in _mcplib_pool_make_be_loop()
795 if (p->use_iothread) { in _mcplib_pool_make_be()
818 memset(p, 0, plen); in mcplib_pool()
819 p->pool_size = n; in mcplib_pool()
958 p->g.refcount--; in mcplib_pool_proxy_gc()
973 if (p->key_filter) { in mcplib_pool_proxy_call_helper()
974 key = p->key_filter(p->key_filter_conf, key, len, &len); in mcplib_pool_proxy_call_helper()
977 uint64_t hash = p->key_hasher(key, len, p->hash_seed); in mcplib_pool_proxy_call_helper()
978 uint32_t lookup = p->phc.selector_func(hash, p->phc.ctx); in mcplib_pool_proxy_call_helper()
[all …]
Dproto_proxy.c502 while (p) { in proxy_submit_cb()
519 p = p->next; in proxy_submit_cb()
537 p = p->next; in proxy_submit_cb()
584 if (p->client_resp && p->client_resp->blen) { in proxy_return_rctx_cb()
600 io_queue_t *q = conn_io_queue_get(p->c, p->io_queue_type); in proxy_return_rctx_cb()
602 conn *c = p->c; in proxy_return_rctx_cb()
607 do_cache_free(p->thread->io_cache, p); in proxy_return_rctx_cb()
1324 p->c = c; in mcp_queue_rctx_io()
1331 p->rctx = rctx; in mcp_queue_rctx_io()
1358 return p; in mcp_queue_rctx_io()
[all …]
Dproxy_config.c164 char *p = namebuf + 1; in proxy_config_stats_prep() local
180 e->cname = p - namebuf; in proxy_config_stats_prep()
183 memcpy(p, newname, nlen); in proxy_config_stats_prep()
184 p += nlen; in proxy_config_stats_prep()
186 p++; in proxy_config_stats_prep()
415 p != NULL; in proxy_init_startfiles()
424 db->fname = strdup(p); in proxy_init_startfiles()
522 pp->main = p; in _copy_pool()
523 if (p->use_iothread) { in _copy_pool()
524 pp->pool = p->pool; in _copy_pool()
[all …]
Drestart.c158 char *p = line; in restart_get_kv() local
159 while (*p != '\n') { in restart_get_kv()
160 p++; in restart_get_kv()
162 *p = '\0'; in restart_get_kv()
179 char *p = line+1; // start just ahead of the token. in restart_get_kv() local
182 *key = p; in restart_get_kv()
186 while (*p != ' ' && (p - line < len)) { in restart_get_kv()
187 p++; in restart_get_kv()
189 *p = '\0'; in restart_get_kv()
190 p++; in restart_get_kv()
[all …]
Dproxy_mutator.c287 p->src = cmd; in mut_step_n()
288 p->slen = clen; in mut_step_n()
294 memcpy(run->d_pos, p->src, p->slen); in mut_step_r()
295 run->d_pos += p->slen; in mut_step_r()
325 return p->slen; in mut_step_n()
329 memcpy(run->d_pos, p->src, p->slen); in mut_step_r()
457 p->slen = len; in mut_step_n()
465 if (p->slen < 2) { in mut_step_r()
468 memcpy(run->d_pos, p->src, p->slen); in mut_step_r()
712 if (p->slen) { in mut_step_r()
[all …]
Dcrawler.c336 char *start = p; in crawler_mgdump_eval()
337 memcpy(p, "mg ", 3); in crawler_mgdump_eval()
338 p += 3; in crawler_mgdump_eval()
341 memcpy(p, " b\r\n", 4); in crawler_mgdump_eval()
342 p += 4; in crawler_mgdump_eval()
344 memcpy(p, ITEM_key(it), it->nkey); in crawler_mgdump_eval()
345 p += it->nkey; in crawler_mgdump_eval()
346 memcpy(p, "\r\n", 2); in crawler_mgdump_eval()
347 p += 2; in crawler_mgdump_eval()
349 int total = p - start; in crawler_mgdump_eval()
[all …]
Dproxy_luafgen.c856 p->background = true; in _mcp_start_rctx_process_error()
875 p->background = true; in mcp_start_subrctx()
887 p->background = true; in mcp_start_subrctx()
964 mcp_rcontext_t *rctx = p->rctx; in proxy_return_rqu_dummy_cb()
973 do_cache_free(p->thread->io_cache, p); in proxy_return_rqu_dummy_cb()
1111 mcp_rcontext_t *rctx = p->rctx; in proxy_return_rqu_cb()
1113 if (p->client_resp) { in proxy_return_rqu_cb()
1114 mcp_process_rqueue_return(rctx, p->queue_handle, p->client_resp); in proxy_return_rqu_cb()
1125 do_cache_free(p->thread->io_cache, p); in proxy_return_rqu_cb()
1144 p->queue_handle = handle; in mcp_run_rcontext_handle()
[all …]
/memcached-1.6.32/t/
Dproxyrctxtimeout.lua13 function cond_timeout(p)
15 local near = fgen:new_handle(p.z1)
17 fgen:new_handle(p.z3) }
44 function enqueue_timeout(p)
48 fgen:new_handle(p.z3) }
73 function wait_handle_timeout(p)
77 fgen:new_handle(p.z3) }
103 function wait_more(p)
124 function wait_double(p)
147 function rctx_sleep(p)
[all …]
Dproxyslotcache.lua12 function basic_fgen(p)
14 local h = fgen:new_handle(p)
34 function mcp_config_routes(p)
36 ["one"] = basic_fgen(p),
37 ["two"] = basic_fgen(basic_fgen(p)),
38 ["three"] = basic_fgen(basic_fgen(basic_fgen(p))),
43 basic_fgen(p)
Dproxyfuncgen.lua52 local p = {p = {b1z, b2z, b3z}, b = b4z}
55 return p
95 local p = arg.pattern
104 local handle = map[string.match(key, p)]
114 local h = fgen:new_handle(arg.p)
130 local h = fgen:new_handle(arg.p)
618 function mcp_config_routes(p)
619 local b_pool = p.b
620 p = p.p
621 local single = new_direct_factory({ p = p[1], name = "single" })
[all …]
Dproxytags.lua10 local p = mcp.pool({ be })
11 return p
14 function mcp_config_routes(p)
17 local h = fg:new_handle(p)
Dstartfile.lua230 local p = pattern
235 local i, j, match = string.find(r:key(), p)
252 local p = pattern
257 local route = l[string.match(r:key(), p)]
289 local p = {}
292 table.insert(p, v)
294 local x = #p
296 local restable = mcp.await(r, p)
Dproxyconfigmulti2.lua2 function mcp_config_routes(p)
4 local h = fg:new_handle(p)
Dproxymut.lua9 function mcp_config_routes(p)
11 local mgfgh = mgfg:new_handle(p)
13 local msfgh = msfg:new_handle(p)
Dproxybestats.lua13 function mcp_config_routes(p)
15 fg:new_handle(p) -- lock the pool from collection
Dproxydepthlim.lua11 function mcp_config_routes(p)
13 local h = fg:new_handle(p)
Dproxyins.lua6 function mcp_config_routes(p)
8 local mgsepkeyh = mgsepkey:new_handle(p)
72 local mgreshasfh = mgreshasf:new_handle(p)
117 local mgreqkeyh = mgreqkey:new_handle(p)
/memcached-1.6.32/vendor/mcmc/
Dmcmc.c158 const char *key = p; in _mcmc_parse_value_line()
160 p = memchr(p, ' ', l - 6); in _mcmc_parse_value_line()
161 if (p == NULL) { in _mcmc_parse_value_line()
165 keylen = p - key; in _mcmc_parse_value_line()
176 p = n; in _mcmc_parse_value_line()
183 p = n; in _mcmc_parse_value_line()
222 p = memchr(p, ' ', l-5); in _mcmc_parse_stat_line()
223 if (p == NULL) { in _mcmc_parse_stat_line()
228 while (*p == ' ') { in _mcmc_parse_stat_line()
229 p++; in _mcmc_parse_stat_line()
[all …]

12