Home
last modified time | relevance | path

Searched refs:iov (Results 1 – 14 of 14) sorted by relevance

/memcached-1.6.32/
Dstorage.c161 if (io->iov != NULL) { in _storage_get_item_cb()
163 … crc2 = crc32c(0, (char *)io->iov[0].iov_base+STORE_OFFSET, io->iov[0].iov_len-STORE_OFFSET); in _storage_get_item_cb()
165 io->iov[0].iov_len = 0; in _storage_get_item_cb()
167 crc2 = crc32c(crc2, (char *)io->iov[x].iov_base, io->iov[x].iov_len); in _storage_get_item_cb()
303 if (eio->iov == NULL) { in storage_get_item()
319 free(eio->iov); in storage_get_item()
321 eio->iov = NULL; in storage_get_item()
481 if (io->iov) { in storage_finalize_cb()
482 free(io->iov); in storage_finalize_cb()
483 io->iov = NULL; in storage_finalize_cb()
[all …]
Dextstore.c818 if (io->iov == NULL) { in _read_from_wbuf()
825 struct iovec *iov = &io->iov[x]; in _read_from_wbuf() local
826 memcpy(iov->iov_base, wbuf->buf + off, iov->iov_len); in _read_from_wbuf()
827 off += iov->iov_len; in _read_from_wbuf()
906 if (cur_io->iov == NULL) { in extstore_io_thread()
909 ret = readv(p->fd, cur_io->iov, cur_io->iovcnt); in extstore_io_thread()
913 if (cur_io->iov == NULL) { in extstore_io_thread()
916 … ret = preadv(p->fd, cur_io->iov, cur_io->iovcnt, p->offset + cur_io->offset); in extstore_io_thread()
Dproxy_network.c941 memcpy(&iovs[iovused], io->iov, sizeof(struct iovec)*io->iovcnt); in _prep_pending_write()
964 struct iovec *iov = &io->iov[x]; in _post_pending_write() local
965 if (sent >= iov->iov_len) { in _post_pending_write()
966 sent -= iov->iov_len; in _post_pending_write()
967 iov->iov_len = 0; in _post_pending_write()
969 iov->iov_len -= sent; in _post_pending_write()
970 iov->iov_base = (char *)iov->iov_base + sent; in _post_pending_write()
Dextstore.h82 struct iovec *iov; /* alternatively, use this iovec */ member
Dproxy_internal.c110 resp->iov[0].iov_len = 0; in _storage_get_item_cb()
111 resp->iov[0].iov_base = ""; in _storage_get_item_cb()
114 resp->iov[0].iov_len = 5; in _storage_get_item_cb()
115 resp->iov[0].iov_base = "END\r\n"; in _storage_get_item_cb()
119 resp->iov[0].iov_len = 4; in _storage_get_item_cb()
120 resp->iov[0].iov_base = "EN\r\n"; in _storage_get_item_cb()
128 resp->iov[io->iovec_data].iov_base = ITEM_data(read_it); in _storage_get_item_cb()
1731 mcmc_parse_buf(resp->iov[0].iov_base, resp->iov[0].iov_len, &r->resp); in mcplib_internal_run()
Dmemcached.c1017 resp->iov[x].iov_base = (void *)buf; in resp_add_iov()
1018 resp->iov[x].iov_len = len; in resp_add_iov()
2608 int todo = resp->iov[x].iov_len;
2633 iovs[iovused].iov_len = resp->iov[x].iov_len;
2677 struct iovec *iov = &resp->iov[x]; local
2678 if (res >= iov->iov_len) {
2679 resp->tosend -= iov->iov_len;
2680 res -= iov->iov_len;
2681 iov->iov_len = 0;
2688 iov->iov_base = (char *)iov->iov_base + res;
[all …]
Dproxy_request.c600 p->iov[0].iov_base = r; in mcp_request_attach()
601 p->iov[0].iov_len = len; in mcp_request_attach()
605 p->iov[1].iov_base = pr->vbuf; in mcp_request_attach()
606 p->iov[1].iov_len = pr->vlen; in mcp_request_attach()
Dproto_proxy.c831 memcpy(resp->wbuf, tresp->wbuf, tresp->iov[0].iov_len); in _proxy_run_tresp_to_resp()
834 resp->iov[x] = tresp->iov[x]; in _proxy_run_tresp_to_resp()
835 resp->tosend += tresp->iov[x].iov_len; in _proxy_run_tresp_to_resp()
841 if (tresp->iov[0].iov_base == tresp->wbuf) { in _proxy_run_tresp_to_resp()
842 resp->iov[0].iov_base = resp->wbuf; in _proxy_run_tresp_to_resp()
Dproxy_inspector.c73 #define res_buf(r) (r->cresp ? r->cresp->iov[0].iov_base : r->buf)
Dproxy.h545 struct iovec iov[2]; // request string + tail buffer member
Dmemcached.h777 struct iovec iov[MC_RESP_IOVCOUNT]; /* built-in iovecs to simplify network code */ member
/memcached-1.6.32/doc/
DCONTRIBUTORS19 Steven Grimm <[email protected]> -- iov writing (less CPU), UDP mode,
/memcached-1.6.32/vendor/mcmc/
Dmcmc.c922 int mcmc_request_writev(void *c, const struct iovec *iov, int iovcnt, ssize_t *sent, int count) { in mcmc_request_writev() argument
927 tosend += iov[i].iov_len; in mcmc_request_writev()
930 *sent = writev(ctx->fd, iov, iovcnt); in mcmc_request_writev()
Dmcmc.h129 int mcmc_request_writev(void *c, const struct iovec *iov, int iovcnt, ssize_t *sent, int count);