Home
last modified time | relevance | path

Searched refs:pr (Results 1 – 8 of 8) sorted by relevance

/memcached-1.6.32/
Dproxy_request.c78 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()
96 int remain = pr->endlen - pr->parsed; in _process_request_next_key()
230 if (pr->tokens[pr->ntokens] - pr->tokens[pr->ntokens-1] >= NOREPLYLEN in _process_request_noreply()
461 memcpy(&rq->pr, pr, sizeof(*pr)); in mcp_new_request()
478 memcpy(&rq->pr, pr, sizeof(*pr)); in mcp_set_request()
494 mcp_parser_t *pr = &rq->pr; in mcp_request_render() local
523 memcpy(p, &pr->request[pr->tokens[idx+1]], pr->tokens[pr->ntokens] - pr->tokens[idx+1]); in mcp_request_render()
524 p += pr->tokens[pr->ntokens] - pr->tokens[idx+1]; in mcp_request_render()
554 mcp_parser_t *pr = &rq->pr; in mcp_request_append() local
[all …]
Dproxy_internal.c229 const char *key = &pr->request[pr->tokens[pr->keytoken]]; in process_get_cmd()
310 const char *key = &pr->request[pr->tokens[pr->keytoken]]; in process_update_cmd()
423 const char *key = &pr->request[pr->tokens[pr->keytoken]]; in process_arithmetic_cmd()
465 const char *key = &pr->request[pr->tokens[pr->keytoken]]; in process_delete_cmd()
506 const char *key = &pr->request[pr->tokens[pr->keytoken]]; in process_touch_cmd()
748 const char *key = &pr->request[pr->tokens[pr->keytoken]]; in process_mget_cmd()
1056 const char *key = &pr->request[pr->tokens[pr->keytoken]]; in process_mset_cmd()
1216 switch (pr->request[pr->tokens[i]]) { in process_mset_cmd()
1266 const char *key = &pr->request[pr->tokens[pr->keytoken]]; in process_mdelete_cmd()
1411 const char *key = &pr->request[pr->tokens[pr->keytoken]]; in process_marithmetic_cmd()
[all …]
Dproto_proxy.c733 rq->pr.vbuf = c->item; in complete_nread_proxy()
1012 mcp_parser_t pr = {0}; in proxy_process_command() local
1075 if (!multiget && pr.cmd_type == CMD_TYPE_GET && pr.has_space) { in proxy_process_command()
1076 uint32_t keyoff = pr.tokens[pr.keytoken]; in proxy_process_command()
1083 if (pr.tokens[pr.keytoken] > MAX_CMD_PREFIX) { in proxy_process_command()
1097 memcpy(cur, pr.request, pr.tokens[pr.keytoken]); in proxy_process_command()
1098 cur += pr.tokens[pr.keytoken]; in proxy_process_command()
1101 memcpy(cur, &pr.request[keyoff], pr.klen); in proxy_process_command()
1162 if (pr.vlen != 0) { in proxy_process_command()
1195 if (pr.vlen != 0) { in proxy_process_command()
[all …]
Dproxy_mutator.c281 const char *cmd = srq->pr.request; in mut_step_n()
283 int clen = srq->pr.tokens[1]; in mut_step_n()
322 p->src = MCP_PARSER_KEY(srq->pr); in mut_step_n()
323 p->slen = srq->pr.klen; in mut_step_n()
669 if (srq->pr.t.meta.flags & c->bit) { in mut_step_n()
789 if (srq->pr.vbuf) { in mut_step_n()
790 run->vbuf = srq->pr.vbuf; in mut_step_n()
791 run->vlen = srq->pr.vlen; in mut_step_n()
1022 rq->pr.vbuf = malloc(run->vlen); in mcp_mut_run()
1023 if (rq->pr.vbuf == NULL) { in mcp_mut_run()
[all …]
Dproxy_inspector.c206 const char *key = MCP_PARSER_KEY(rq->pr); in mcp_inspector_sepkey_r()
207 const char *end = key + rq->pr.klen; in mcp_inspector_sepkey_r()
270 const char *key = MCP_PARSER_KEY(rq->pr); in mcp_inspector_keybegin_r()
271 int klen = rq->pr.klen; in mcp_inspector_keybegin_r()
287 const char *key = MCP_PARSER_KEY(rq->pr); in mcp_inspector_keyis_r()
288 int klen = rq->pr.klen; in mcp_inspector_keyis_r()
305 if (rq->pr.t.meta.flags & c->bit) { in mcp_inspector_hasflag_r()
335 if (rq->pr.t.meta.flags & c->bit) { in mcp_inspector_flagtoken_r()
369 if (rq->pr.t.meta.flags & c->bit) { in mcp_inspector_flagint_r()
441 if (rq->pr.t.meta.flags & c->bit) { in mcp_inspector_flagis_r()
Dproxy_luafgen.c432 fgen = mcp_funcgen_route(L, fgen, pr); in mcp_funcgen_start()
793 if (!rq->pr.keytoken) { in mcplib_rcontext_enqueue()
1136 … mcp_backend_t *be = mcplib_pool_proxy_call_helper(rqu->obj, MCP_PARSER_KEY(rq->pr), rq->pr.klen); in mcp_run_rcontext_handle()
1261 if (!rq->pr.keytoken) { in mcplib_rcontext_enqueue_and_wait()
1454 mcp_parser_t pr = {0}; in mcplib_rcontext_request_new() local
1456 mcp_new_request(L, &pr, " ", 1); in mcplib_rcontext_request_new()
1568 if (pr->klen == 0) { in mcp_funcgen_route()
1571 const char *key = &pr->request[pr->tokens[pr->keytoken]]; in mcp_funcgen_route()
1596 return _mcp_funcgen_route_fallback(fr, pr->command); in mcp_funcgen_route()
1607 return _mcp_funcgen_route_fallback(fr, pr->command); in mcp_funcgen_route()
[all …]
Dproxy.h348 #define MCP_PARSER_KEY(pr) (&pr.request[pr.tokens[pr.keytoken]]) argument
352 mcp_parser_t pr; // non-lua-specific parser handling. member
621 size_t _process_request_next_key(mcp_parser_t *pr);
622 int process_request(mcp_parser_t *pr, const char *command, size_t cmdlen);
623 mcp_request_t *mcp_new_request(lua_State *L, mcp_parser_t *pr, const char *command, size_t cmdlen);
624 void mcp_set_request(mcp_parser_t *pr, mcp_request_t *r, const char *command, size_t cmdlen);
782 mcp_rcontext_t *mcp_funcgen_start(lua_State *L, mcp_funcgen_t *fgen, mcp_parser_t *pr);
Dproxy_lua.c1393 …logger_log(l, LOGGER_PROXY_REQ, NULL, rq->pr.request, rq->pr.reqlen, elapsed, rtype, rcode, rstatu… in mcplib_log_req()
1470 …logger_log(l, LOGGER_PROXY_REQ, NULL, rq->pr.request, rq->pr.reqlen, elapsed, rtype, rcode, rstatu… in mcplib_log_reqsample()