| /memcached-1.6.32/ |
| D | testapp.c | 1087 memset(request, 0, sizeof(*request)); in storage_command()
1089 request->message.header.request.opcode = cmd; in storage_command()
1091 request->message.header.request.extlen = 8; in storage_command()
1119 memset(request, 0, sizeof(*request)); in ext_command()
1121 request->message.header.request.opcode = cmd; in ext_command()
1159 memset(request, 0, sizeof(*request)); in flush_command()
1161 request->message.header.request.opcode = cmd; in flush_command()
1186 memset(request, 0, sizeof(*request)); in touch_command()
1191 request->message.header.request.extlen = 4; in touch_command()
1214 memset(request, 0, sizeof(*request)); in arithmetic_command()
[all …]
|
| D | proxy_request.c | 11 const char *s = pr->request; in _process_tokenize()
60 pr->tokens[curtoken] = s - pr->request; in _process_tokenize()
82 if (pr->request[pr->parsed-1] == ' ') { in _process_request_key()
118 return cur - pr->request; in _process_request_next_key()
316 pr->request = command; in process_request()
463 memcpy(rq->request, command, cmdlen); in mcp_new_request()
464 rq->pr.request = rq->request; in mcp_new_request()
481 rq->pr.request = rq->request; in mcp_set_request()
535 memcpy(rq->request, temp, p - temp); in mcp_request_render()
555 const char *start = pr->request; in mcp_request_append()
[all …]
|
| D | proto_bin.c | 73 c->binary_header.request.keylen = ntohs(req->request.keylen); in try_read_command_binary()
74 c->binary_header.request.bodylen = ntohl(req->request.bodylen); in try_read_command_binary()
75 c->binary_header.request.cas = ntohll(req->request.cas); in try_read_command_binary()
99 c->cmd = c->binary_header.request.opcode; in try_read_command_binary()
100 c->keylen = c->binary_header.request.keylen; in try_read_command_binary()
276 nkey = c->binary_header.request.keylen; in complete_incr_bin()
291 if (c->binary_header.request.cas != 0) { in complete_incr_bin()
292 cas = c->binary_header.request.cas; in complete_incr_bin()
1090 nkey = c->binary_header.request.keylen; in process_bin_update()
1096 vlen = c->binary_header.request.bodylen - (nkey + c->binary_header.request.extlen); in process_bin_update()
[all …]
|
| D | proxy_internal.c | 229 const char *key = &pr->request[pr->tokens[pr->keytoken]]; in process_get_cmd()
548 const char *s = pr->request + pr->tokens[token]; in _process_token_len()
549 const char *e = pr->request + pr->tokens[token+1]; in _process_token_len()
612 uint8_t o = (uint8_t)pr->request[pr->tokens[i]]; in _meta_flag_preparse()
721 of->mode = pr->request[pr->tokens[i]+1]; in _meta_flag_preparse()
830 switch (pr->request[pr->tokens[i]]) { in process_mget_cmd()
1022 switch (pr->request[pr->tokens[i]]) { in process_mget_cmd()
1216 switch (pr->request[pr->tokens[i]]) { in process_mset_cmd()
1300 switch (pr->request[pr->tokens[i]]) { in process_mdelete_cmd()
1553 switch (pr->request[pr->tokens[i]]) { in process_marithmetic_cmd()
[all …]
|
| D | proxy.h | 329 const char *request; member
348 #define MCP_PARSER_KEY(pr) (&pr.request[pr.tokens[pr.keytoken]])
354 char request[]; member
749 mcp_request_t *request; // ptr to the above reference. member
|
| D | memcached_dtrace.d | 174 probe process__command__start(int connid, const void *request, int size);
|
| D | proto_proxy.c | 718 mcp_request_t *rq = rctx->request; in complete_nread_proxy()
1097 memcpy(cur, pr.request, pr.tokens[pr.keytoken]); in proxy_process_command()
1101 memcpy(cur, &pr.request[keyoff], pr.klen); in proxy_process_command()
1180 mcp_set_request(&pr, rctx->request, command, cmdlen); in proxy_process_command()
1181 rctx->request->ascii_multiget = multiget; in proxy_process_command()
1265 if (rq->request[rq->pr.tokens[x]] == 'q') { in mcp_set_resobj()
1266 rq->request[rq->pr.tokens[x]] = ' '; in mcp_set_resobj()
1271 rq->request[rq->pr.reqlen - 3] = 'Y'; in mcp_set_resobj()
|
| D | protocol_binary.h | 162 } request; member
|
| D | proxy_mutator.c | 281 const char *cmd = srq->pr.request; in mut_step_n()
1010 run->d_pos = rq->request; in mcp_mut_run()
1016 if (process_request(&rq->pr, rq->request, run->d_pos - rq->request) != 0) { in mcp_mut_run()
|
| D | proxy_luafgen.c | 246 subrctx->request = NULL; in _mcplib_funcgen_gencall()
337 if (rctx->request) { in _mcp_funcgen_return_rctx()
338 mcp_request_cleanup(fgen->thread, rctx->request); in _mcp_funcgen_return_rctx()
456 rctx->request = rq; in mcp_funcgen_start()
1571 const char *key = &pr->request[pr->tokens[pr->keytoken]]; in mcp_funcgen_route()
|
| D | proxy_lua.c | 1393 …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()
|
| /memcached-1.6.32/doc/ |
| D | protocol-binary-range.txt | 147 When a Get or GetQ request is made via UDP, and the value of the key
148 for which the request was made is larger than can be placed into a
164 and a Message ID corresponding to its Get request, shall then know
174 MAY choose to request the remaining portion of the value by sending
179 The Get Range request is primarily intended for use over a UDP
180 transport to request byte ranges of the value for a key. In the
184 Extra data for get range request:
203 The Get Range request is primarily intended for use over a UDP
|
| D | protocol-binary.txt | 509 get request:
733 Add request:
849 Delete request:
966 Increment request:
1129 Quit request:
1201 following values in the request
1237 Flush request:
1295 Noop request:
1354 Version request:
1465 Append request:
[all …]
|
| D | napi_ids.txt | 6 selected based on the NIC HW RX queue on which the incoming request is
|
| D | protocol.txt | 64 request). The client sends a command line, which includes all the
123 supplied in the request. Sending an 't' flag with a get for an item with 20
260 reply. NOTE: if the request line is malformed, the server can't
323 If some of the keys appearing in a retrieval request are not sent back
511 If a response line appearing in a retrieval request is not sent back
535 If the request resulted in a miss, the response looks like:
593 and "3", to match up responses to the request.
1122 previous request.
1900 The request ID is supplied by the client. Typically it will be a
1903 contain the same ID as the incoming request. The client uses the request ID
[all …]
|
| D | tls.txt | 107 | Memcached request/ | |
|
| /memcached-1.6.32/t/ |
| D | proxyunits.lua | 181 map.request = {
185 local newReq = mcp.request("ms /request/edit 2\r\n", "ab\r\n")
193 local newReq = mcp.request("mg /request/new c\r\n")
197 local newReq = mcp.request("ms /request/a " .. res:vlen() .. "\r\n", res)
|
| D | startfile.lua | 206 local new_req = mcp.request
|
| /memcached-1.6.32/vendor/mcmc/ |
| D | mcmc.h | 111 const char *request; member
128 int mcmc_send_request(void *c, const char *request, int len, int count);
|
| D | mcmc.c | 892 int mcmc_send_request(void *c, const char *request, int len, int count) { in mcmc_send_request() argument
896 const char *r = request + ctx->sent_bytes_partial; in mcmc_send_request()
|