791 static void _set_noreply_mode(mc_resp *resp, mcp_resp_t *r) {  in _set_noreply_mode()  argument
792     switch (r->mode) {  in _set_noreply_mode()
797             if (r->status == MCMC_OK) {  in _set_noreply_mode()
802             if (r->resp.code == MCMC_CODE_END) {  in _set_noreply_mode()
804             } else if (r->cmd != CMD_MG && r->resp.code == MCMC_CODE_OK) {  in _set_noreply_mode()
906             mcp_resp_t *r = NULL;  in proxy_run_rcontext()  local
908             if (type == LUA_TUSERDATA && (r = luaL_testudata(Lc, 1, "mcp.response")) != NULL) {  in proxy_run_rcontext()
909                 _set_noreply_mode(resp, r);  in proxy_run_rcontext()
910                 if (r->status != MCMC_OK && r->resp.type != MCMC_RESP_ERRMSG) {  in proxy_run_rcontext()
912                 } else if (r->cresp) {  in proxy_run_rcontext()
913                     mc_resp *tresp = r->cresp;  in proxy_run_rcontext()
918                 } else if (r->buf) {  in proxy_run_rcontext()
920                     resp->write_and_free = r->buf;  in proxy_run_rcontext()
921                     resp_add_iov(resp, r->buf, r->blen);  in proxy_run_rcontext()
923                     resp->wbytes = r->blen + r->extra;  in proxy_run_rcontext()
925                     r->buf = NULL;  in proxy_run_rcontext()
1234     mcp_resp_t *r = lua_newuserdatauv(L, sizeof(mcp_resp_t), 0);  in mcp_prep_bare_resobj()  local
1237     memset(r, 0, sizeof(mcp_resp_t));  in mcp_prep_bare_resobj()
1238     r->thread = t;  in mcp_prep_bare_resobj()
1239     assert(r->thread != NULL);  in mcp_prep_bare_resobj()
1240     gettimeofday(&r->start, NULL);  in mcp_prep_bare_resobj()
1245     return r;  in mcp_prep_bare_resobj()
1248 void mcp_set_resobj(mcp_resp_t *r, mcp_request_t *rq, mcp_backend_t *be, LIBEVENT_THREAD *t) {  in mcp_set_resobj()  argument
1249     memset(r, 0, sizeof(mcp_resp_t));  in mcp_set_resobj()
1250     r->buf = NULL;  in mcp_set_resobj()
1251     r->blen = 0;  in mcp_set_resobj()
1252     r->thread = t;  in mcp_set_resobj()
1253     assert(r->thread != NULL);  in mcp_set_resobj()
1254     gettimeofday(&r->start, NULL);  in mcp_set_resobj()
1263             r->mode = RESP_MODE_METAQUIET;  in mcp_set_resobj()
1270             r->mode = RESP_MODE_NOREPLY;  in mcp_set_resobj()
1274         r->mode = RESP_MODE_NORMAL;  in mcp_set_resobj()
1277     r->cmd = rq->pr.command;  in mcp_set_resobj()
1279     strncpy(r->be_name, be->name, MAX_NAMELEN+1);  in mcp_set_resobj()
1280     strncpy(r->be_port, be->port, MAX_PORTLEN+1);  in mcp_set_resobj()
1285     mcp_resp_t *r = lua_newuserdatauv(L, sizeof(mcp_resp_t), 0);  in mcp_prep_resobj()  local
1286     mcp_set_resobj(r, rq, be, t);  in mcp_prep_resobj()
1291     return r;  in mcp_prep_resobj()
1294 void mcp_resp_set_elapsed(mcp_resp_t *r) {  in mcp_resp_set_elapsed()  argument
1298     r->elapsed = (end.tv_sec - r->start.tv_sec) * 1000000 +  in mcp_resp_set_elapsed()
1299         (end.tv_usec - r->start.tv_usec);  in mcp_resp_set_elapsed()
1306 …y_t *mcp_queue_rctx_io(mcp_rcontext_t *rctx, mcp_request_t *rq, mcp_backend_t *be, mcp_resp_t *r) {  in mcp_queue_rctx_io()  argument
1325     p->client_resp = r;  in mcp_queue_rctx_io()