720     if (strncmp((char *)c->item + rq->pr.vlen - 2, "\r\n", 2) != 0) {  in complete_nread_proxy()
733     rq->pr.vbuf = c->item;  in complete_nread_proxy()
738     thr->proxy_buffer_memory_used += rq->pr.vlen;  in complete_nread_proxy()
1012     mcp_parser_t pr = {0};  in proxy_process_command()  local
1019     int ret = process_request(&pr, command, cmdlen);  in proxy_process_command()
1034     struct proxy_hook *hook = &hooks[pr.command];  in proxy_process_command()
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()
1077         while (pr.klen != 0) {  in proxy_process_command()
1083             if (pr.tokens[pr.keytoken] > MAX_CMD_PREFIX) {  in proxy_process_command()
1089             } else if (pr.klen > KEY_MAX_LENGTH) {  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()
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()
1113             keyoff = _process_request_next_key(&pr);  in proxy_process_command()
1155     istats->counters[pr.command]++;  in proxy_process_command()
1162         if (pr.vlen != 0) {  in proxy_process_command()
1163             c->sbytes = pr.vlen;  in proxy_process_command()
1170     mcp_rcontext_t *rctx = mcp_funcgen_start(L, hook_ref.ctx, &pr);  in proxy_process_command()
1173         if (pr.vlen != 0) {  in proxy_process_command()
1174             c->sbytes = pr.vlen;  in proxy_process_command()
1180     mcp_set_request(&pr, rctx->request, command, cmdlen);  in proxy_process_command()
1195     if (pr.vlen != 0) {  in proxy_process_command()
1203             c->item = malloc(pr.vlen);  in proxy_process_command()
1212             c->sbytes = pr.vlen;  in proxy_process_command()
1218         c->rlbytes = pr.vlen;  in proxy_process_command()
1261     if (rq->pr.noreply) {  in mcp_set_resobj()
1262         if (rq->pr.cmd_type == CMD_TYPE_META) {  in mcp_set_resobj()
1264             for (int x = 2; x < rq->pr.ntokens; x++) {  in mcp_set_resobj()
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()
1277     r->cmd = rq->pr.command;  in mcp_set_resobj()