Lines Matching refs:rbuf
205 free(bec->rbuf); in _cleanup_backend()
504 r->status = mcmc_parse_buf(be->rbuf, be->rbufused, &r->resp); in proxy_backend_drive_machine()
532 memmove(be->rbuf, be->rbuf+r->resp.reslen, be->rbufused); in proxy_backend_drive_machine()
603 memcpy(r->buf, be->rbuf, 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()
619 memmove(be->rbuf, be->rbuf+r->resp.reslen+r->resp.vlen_read, be->rbufused); in proxy_backend_drive_machine()
629 if (memcmp(be->rbuf, ENDSTR, ENDLEN) != 0) { in proxy_backend_drive_machine()
648 memmove(be->rbuf, be->rbuf+ENDLEN, be->rbufused); in proxy_backend_drive_machine()
669 memcpy(r->buf+r->bread, be->rbuf, tocopy); in proxy_backend_drive_machine()
683 memmove(be->rbuf, be->rbuf+tocopy, be->rbufused); in proxy_backend_drive_machine()
900 … be->be_parent->name, be->be_parent->port, be->be_parent->label, depth, be->rbuf, be->rbufused, 0); in _reset_bad_backend()
1089 int status = mcmc_parse_buf(be->rbuf, be->rbufused, &r); in proxy_bevalidate_tls_handler()
1254 … int read = recv(mcmc_fd(be->client), be->rbuf + be->rbufused, READ_BUFFER_SIZE - be->rbufused, 0); in proxy_beconn_handler()
1259 int status = mcmc_parse_buf(be->rbuf, be->rbufused, &r); in proxy_beconn_handler()
1411 int read = recv(mcmc_fd(be->client), be->rbuf + be->rbufused, in proxy_backend_handler()