Searched refs:rs (Results 1 – 3 of 3) sorted by relevance
1034 mcp_resp_t *rs = run->arg; in mcp_mut_run() local1036 mcp_response_cleanup(t, rs); in mcp_mut_run()1039 rs->buf = malloc(total); in mcp_mut_run()1040 if (rs->buf == NULL) { in mcp_mut_run()1044 run->d_pos = rs->buf; in mcp_mut_run()1048 rs->tok.ntokens = 0; // TODO: handler from mcmc? in mcp_mut_run()1049 if (mcmc_parse_buf(rs->buf, run->d_pos - rs->buf, &rs->resp) != MCMC_OK) { in mcp_mut_run()1060 rs->blen = run->d_pos - rs->buf; in mcp_mut_run()1067 t->proxy_buffer_memory_used += rs->blen; in mcp_mut_run()
1382 rtype = rs->resp.type; in mcplib_log_req()1383 rcode = rs->resp.code; in mcplib_log_req()1384 rstatus = rs->status; in mcplib_log_req()1385 rname = rs->be_name; in mcplib_log_req()1386 rport = rs->be_port; in mcplib_log_req()1387 elapsed = rs->elapsed; in mcplib_log_req()1444 rtype = rs->resp.type; in mcplib_log_reqsample()1445 rcode = rs->resp.code; in mcplib_log_reqsample()1446 rstatus = rs->status; in mcplib_log_reqsample()1447 rname = rs->be_name; in mcplib_log_reqsample()[all …]
1099 mcp_resp_t *rs = luaL_checkudata(L, 2, "mcp.response"); in mcplib_request_match_res() local1107 mcmc_parse_buf(rs->buf, rs->blen, &reresp); in mcplib_request_match_res()