494         mcp_resp_t *r;  in proxy_backend_drive_machine()  local
503             r = p->client_resp;  in proxy_backend_drive_machine()
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()
554                     P_DEBUG("%s: mcmc_read failed [%d]\n", __func__, r->status);  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()
573                 bool oom = proxy_bufmem_checkadd(r->thread, r->blen + extra_space);  in proxy_backend_drive_machine()
578                     r->blen = 0;  in proxy_backend_drive_machine()
583             r->buf = malloc(r->blen + extra_space);  in proxy_backend_drive_machine()
584             if (r->buf == NULL) {  in proxy_backend_drive_machine()
586                 pthread_mutex_lock(&r->thread->proxy_limit_lock);  in proxy_backend_drive_machine()
587                 r->thread->proxy_buffer_memory_used -= r->blen + extra_space;  in proxy_backend_drive_machine()
588                 pthread_mutex_unlock(&r->thread->proxy_limit_lock);  in proxy_backend_drive_machine()
591                 r->blen = 0;  in proxy_backend_drive_machine()
596 …BUG("%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()
624             r = p->client_resp;  in proxy_backend_drive_machine()
639                         memcpy(r->buf+r->blen, ENDSTR, ENDLEN);  in proxy_backend_drive_machine()
640                         r->blen += 5;  in proxy_backend_drive_machine()
642                         r->extra = 5;  in proxy_backend_drive_machine()
662             r = p->client_resp;  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()
667             size_t tocopy = be->rbufused < r->blen - r->bread ?  in proxy_backend_drive_machine()
668                 be->rbufused : r->blen - r->bread;  in proxy_backend_drive_machine()
669             memcpy(r->buf+r->bread, be->rbuf, tocopy);  in proxy_backend_drive_machine()
670             r->bread += tocopy;  in proxy_backend_drive_machine()
672             if (r->bread >= r->blen) {  in proxy_backend_drive_machine()
674                 if (r->resp.type == MCMC_RESP_GET) {  in proxy_backend_drive_machine()
1087             mcmc_resp_t r;  in proxy_bevalidate_tls_handler()  local
1089             int status = mcmc_parse_buf(be->rbuf, be->rbufused, &r);  in proxy_bevalidate_tls_handler()
1093                 if (r.code == MCMC_WANT_READ) {  in proxy_bevalidate_tls_handler()
1102             if (r.code != MCMC_CODE_VERSION) {  in proxy_bevalidate_tls_handler()
1256             mcmc_resp_t r;  in proxy_beconn_handler()  local
1259             int status = mcmc_parse_buf(be->rbuf, be->rbufused, &r);  in proxy_beconn_handler()
1263                 if (r.code == MCMC_WANT_READ) {  in proxy_beconn_handler()
1272             if (r.code != MCMC_CODE_VERSION) {  in proxy_beconn_handler()