Lines Matching refs:resp

306         io->client_resp->resp.code = MCMC_CODE_SERVER_ERROR;  in _proxy_flush_backend_queue()
504 r->status = mcmc_parse_buf(be->rbuf, be->rbufused, &r->resp); in proxy_backend_drive_machine()
507 if (r->resp.code == MCMC_WANT_READ) { in proxy_backend_drive_machine()
516 switch (r->resp.type) { in proxy_backend_drive_machine()
527 assert(r->resp.vlen == 0); in proxy_backend_drive_machine()
530 be->rbufused -= r->resp.reslen; in proxy_backend_drive_machine()
532 memmove(be->rbuf, be->rbuf+r->resp.reslen, be->rbufused); in proxy_backend_drive_machine()
547 if (r->resp.code != MCMC_CODE_SERVER_ERROR) { in proxy_backend_drive_machine()
560 P_DEBUG("%s: Unhandled response from backend: %d\n", __func__, r->resp.type); in proxy_backend_drive_machine()
571 r->blen = r->resp.reslen + r->resp.vlen; in proxy_backend_drive_machine()
596 …UG("%s: r->status: %d, r->bread: %d, r->vlen: %lu\n", __func__, r->status, r->bread, r->resp.vlen); in proxy_backend_drive_machine()
597 if (r->resp.vlen != r->resp.vlen_read) { in proxy_backend_drive_machine()
600 assert(be->rbufused == r->resp.reslen+r->resp.vlen_read); in proxy_backend_drive_machine()
603 memcpy(r->buf, be->rbuf, r->resp.reslen + r->resp.vlen_read); in proxy_backend_drive_machine()
604 r->bread = r->resp.reslen + r->resp.vlen_read; in proxy_backend_drive_machine()
613 memcpy(r->buf, be->rbuf, r->resp.reslen+r->resp.vlen_read); in proxy_backend_drive_machine()
617 be->rbufused -= r->resp.reslen + r->resp.vlen_read; in proxy_backend_drive_machine()
619 memmove(be->rbuf, be->rbuf+r->resp.reslen+r->resp.vlen_read, be->rbufused); in proxy_backend_drive_machine()
665 P_DEBUG("%s: [want_read] r->bread: %d vlen: %lu\n", __func__, r->bread, r->resp.vlen); in proxy_backend_drive_machine()
674 if (r->resp.type == MCMC_RESP_GET) { in proxy_backend_drive_machine()
889 io->client_resp->resp.code = MCMC_CODE_SERVER_ERROR; in _reset_bad_backend()