Home
last modified time | relevance | path

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

/memcached-1.6.32/
Dproxy_tls.c203 int mcp_tls_writev(struct mcp_backendconn_s *be, int iovcnt) { in mcp_tls_writev() argument
223 for (int i = 0; i < iovcnt; i++) { in mcp_tls_writev()
251 int mcp_tls_writev(struct mcp_backendconn_s *be, int iovcnt) { in mcp_tls_writev() argument
253 (void)iovcnt; in mcp_tls_writev()
Dproxy_tls.h26 int mcp_tls_writev(struct mcp_backendconn_s *be, int iovcnt);
36 int mcp_tls_writev(struct mcp_backendconn_s *be, int iovcnt);
Dproxy_network.c936 if (io->iovcnt + iovused > BE_IOV_MAX) { in _prep_pending_write()
941 memcpy(&iovs[iovused], io->iov, sizeof(struct iovec)*io->iovcnt); in _prep_pending_write()
942 iovused += io->iovcnt; in _prep_pending_write()
963 for (int x = 0; x < io->iovcnt; x++) { in _post_pending_write()
1014 int iovcnt = _prep_pending_write(be); in _flush_pending_write() local
1016 ssize_t sent = writev(mcmc_fd(be->client), be->write_iovs, iovcnt); in _flush_pending_write()
1043 int iovcnt = _prep_pending_write(be); in _flush_pending_tls_write() local
1045 int sent = mcp_tls_writev(be, iovcnt); in _flush_pending_tls_write()
Dextstore.h83 unsigned int iovcnt; /* number of IOV's */ member
Dstorage.c166 for (x = 1; x < io->iovcnt; x++) { in _storage_get_item_cb()
215 resp->iovcnt = 1; in _storage_get_item_cb()
332 eio->iovcnt = ciovcnt; in storage_get_item()
336 p->iovec_data = resp->iovcnt; in storage_get_item()
Dextstore.c824 for (x = 0; x < io->iovcnt; x++) { in _read_from_wbuf()
909 ret = readv(p->fd, cur_io->iov, cur_io->iovcnt); in extstore_io_thread()
916 … ret = preadv(p->fd, cur_io->iov, cur_io->iovcnt, p->offset + cur_io->offset); in extstore_io_thread()
Dmemcached.c1008 resp->iovcnt = 0; in resp_reset()
1015 assert(resp->iovcnt < MC_RESP_IOVCOUNT); in resp_add_iov()
1016 int x = resp->iovcnt; in resp_add_iov()
1019 resp->iovcnt++; in resp_add_iov()
1027 resp->chunked_data_iov = resp->iovcnt; in resp_add_chunked_iov()
2590 while (resp && iovused + resp->iovcnt < IOV_MAX-1) {
2603 for (x = 0; x < resp->iovcnt; x++) {
2640 memcpy(&iovs[iovused], resp->iov, sizeof(struct iovec)*resp->iovcnt);
2641 iovused += resp->iovcnt;
2676 for (x = 0; x < resp->iovcnt; x++) {
Dproxy_request.c602 p->iovcnt = 1; in mcp_request_attach()
607 p->iovcnt = 2; in mcp_request_attach()
Dproxy_internal.c107 resp->iovcnt = 1; in _storage_get_item_cb()
172 io->iovec_data = resp->iovcnt; in proxy_storage_get()
1736 resp->iovcnt--; in mcplib_internal_run()
Dproto_proxy.c833 for (int x = 0; x < tresp->iovcnt; x++) { in _proxy_run_tresp_to_resp()
844 resp->iovcnt = tresp->iovcnt; in _proxy_run_tresp_to_resp()
Dproxy.h546 int iovcnt; // 1 or 2... member
Dmemcached.h779 uint8_t iovcnt; member
/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
926 for (int i = 0; i < iovcnt; i++) { 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);