| /memcached-1.6.32/ |
| D | proxy_request.c | 78 pr->klen = _process_token_len(pr, pr->keytoken); in _process_request_key()
80 pr->parsed = pr->tokens[pr->keytoken] + pr->klen + 1; in _process_request_key()
111 pr->klen = s - cur; in _process_request_next_key()
114 pr->klen = remain; in _process_request_next_key()
679 lua_pushlstring(L, MCP_PARSER_KEY(rq->pr), rq->pr.klen); in mcplib_request_key()
693 if (totrim > rq->pr.klen) { in mcplib_request_ltrimkey()
698 rq->pr.klen -= totrim; in mcplib_request_ltrimkey()
709 if (totrim > rq->pr.klen) { in mcplib_request_rtrimkey()
713 memset(key + (rq->pr.klen - totrim), ' ', totrim); in mcplib_request_rtrimkey()
714 rq->pr.klen -= totrim; in mcplib_request_rtrimkey()
[all …]
|
| D | proxy_inspector.c | 207 const char *end = key + rq->pr.klen; in mcp_inspector_sepkey_r()
271 int klen = rq->pr.klen; in mcp_inspector_keybegin_r() local
274 if (c->len < klen && strncmp(key, str, c->len) == 0) { in mcp_inspector_keybegin_r()
288 int klen = rq->pr.klen; in mcp_inspector_keyis_r() local
291 if (c->len == klen && strncmp(key, str, c->len) == 0) { in mcp_inspector_keyis_r()
|
| D | proxy_lua.c | 20 if (klen == 0) { in _mcplib_append_stats()
28 lua_pushlstring(L, key, klen); in _mcplib_append_stats()
38 if (klen == 0) { in _mcplib_append_section_stats()
70 lua_pushlstring(L, key, klen); in _mcplib_append_section_stats()
641 *newlen = klen; in mcp_key_hash_filter_stop()
642 if (klen > KEY_MAX_LENGTH) { in mcp_key_hash_filter_stop()
647 memcpy(temp, key, klen); in mcp_key_hash_filter_stop()
648 temp[klen+1] = '\0'; in mcp_key_hash_filter_stop()
669 *newlen = klen; in mcp_key_hash_filter_tag()
671 const char *t1 = memchr(key, conf[0], klen); in mcp_key_hash_filter_tag()
[all …]
|
| D | proxy_luafgen.c | 1497 end = memchr(key, needle, klen); in _mcp_router_shortsep()
1516 end = memchr(key, needle[0], klen); in _mcp_router_longsep()
1523 const char *last = key + (klen - nlen); in _mcp_router_longsep()
1544 return _mcp_router_shortsep(key+1, klen-1, needle[1], len); in _mcp_router_anchorsm()
1551 if (slen+2 > klen || memcmp(key, conf->start, slen) != 0) { in _mcp_router_anchorbig()
1556 return _mcp_router_longsep(key+slen, klen-slen, conf->stop, len); in _mcp_router_anchorbig()
1568 if (pr->klen == 0) { in mcp_funcgen_route()
1582 lookup = _mcp_router_shortsep(key, pr->klen, fr->conf.sep, &lookuplen); in mcp_funcgen_route()
1585 lookup = _mcp_router_longsep(key, pr->klen, fr->conf.lsep, &lookuplen); in mcp_funcgen_route()
1588 lookup = _mcp_router_anchorsm(key, pr->klen, fr->conf.anchorsm, &lookuplen); in mcp_funcgen_route()
[all …]
|
| D | proxy_internal.c | 230 int nkey = pr->klen; in process_get_cmd()
311 size_t nkey = pr->klen; in process_update_cmd()
424 size_t nkey = pr->klen; in process_arithmetic_cmd()
466 size_t nkey = pr->klen; in process_delete_cmd()
507 size_t nkey = pr->klen; in process_touch_cmd()
749 size_t nkey = pr->klen; in process_mget_cmd()
1057 size_t nkey = pr->klen; in process_mset_cmd()
1267 size_t nkey = pr->klen; in process_mdelete_cmd()
1412 size_t nkey = pr->klen; in process_marithmetic_cmd()
|
| D | memcached.h | 163 klen = snprintf(key_str, STAT_KEY_LEN, name_fmt, num, name); \
165 add_stats(key_str, klen, val_str, vlen, c);
191 typedef void (*ADD_STAT)(const char *key, const uint16_t klen,
1067 void append_stats(const char *key, const uint16_t klen,
|
| D | memcached.c | 1317 uint32_t bodylen = klen + vlen; in append_bin_stats()
1321 .response.keylen = (uint16_t)htons(klen), in append_bin_stats()
1330 if (klen > 0) { in append_bin_stats()
1331 memcpy(buf, key, klen); in append_bin_stats()
1332 buf += klen; in append_bin_stats()
1350 if (klen == 0 && vlen == 0) { in append_ascii_stats()
1394 void append_stats(const char *key, const uint16_t klen, in append_stats() argument
1399 if (klen == 0 && vlen > 0) { in append_stats()
1410 append_bin_stats(key, klen, val, vlen, c); in append_stats()
1416 append_ascii_stats(key, klen, val, vlen, c); in append_stats()
[all …]
|
| D | proto_proxy.c | 1077 while (pr.klen != 0) { in proxy_process_command()
1089 } else if (pr.klen > KEY_MAX_LENGTH) { in proxy_process_command()
1101 memcpy(cur, &pr.request[keyoff], pr.klen); in proxy_process_command()
1102 cur += pr.klen; in proxy_process_command()
1108 … P_DEBUG("%s: new multiget sub request: %s [%u/%u]\n", __func__, temp, keyoff, pr.klen); in proxy_process_command()
|
| D | proxy.h | 295 typedef const char *(*key_hash_filter_func)(const char *conf, const char *key, size_t klen, size_t …
339 uint32_t klen; // length of key. member
|
| D | slabs.c | 572 int klen = 0, vlen = 0; in do_slabs_stats() local
|
| D | proxy_mutator.c | 323 p->slen = srq->pr.klen; in mut_step_n()
|
| D | storage.c | 81 int klen = 0, vlen = 0; in process_extstore_stats() local
|
| D | items.c | 805 int klen = 0, vlen = 0; in item_stats() local
|
| /memcached-1.6.32/vendor/mcmc/ |
| D | mcmc.h | 84 size_t klen; member
116 uint8_t klen; // length of key. member
|
| D | mcmc.c | 205 r->klen = keylen; in _mcmc_parse_value_line()
|