Lines Matching refs:io

87     io_pending_proxy_t *io = (io_pending_proxy_t *)eio->data;  in _storage_get_item_cb()  local
88 assert(io->active == true); in _storage_get_item_cb()
89 mc_resp *resp = io->tresp; in _storage_get_item_cb()
102 io->badcrc = true; in _storage_get_item_cb()
108 if (io->gettype == PROXY_STORAGE_GET) { in _storage_get_item_cb()
109 if (io->ascii_multiget) { in _storage_get_item_cb()
118 } else if (io->gettype == PROXY_STORAGE_MG) { in _storage_get_item_cb()
128 resp->iov[io->iovec_data].iov_base = ITEM_data(read_it); in _storage_get_item_cb()
130 io->miss = miss; in _storage_get_item_cb()
131 io->active = false; in _storage_get_item_cb()
135 return_io_pending((io_pending_t *)io); in _storage_get_item_cb()
150 io_pending_proxy_t *io = do_cache_alloc(t->io_cache); in proxy_storage_get() local
153 memset(io, 0, sizeof(io_pending_proxy_t)); in proxy_storage_get()
154 io->active = true; in proxy_storage_get()
156 io->hdr_it = it; in proxy_storage_get()
157 io->tresp = resp; // our mc_resp is a temporary object. in proxy_storage_get()
158 io->io_queue_type = IO_QUEUE_EXTSTORE; in proxy_storage_get()
159 io->io_type = IO_PENDING_TYPE_EXTSTORE; // proxy specific sub-type. in proxy_storage_get()
160 io->gettype = type; in proxy_storage_get()
161 io->thread = t; in proxy_storage_get()
162 io->return_cb = proxy_return_rctx_cb; in proxy_storage_get()
163 io->finalize_cb = proxy_finalize_rctx_cb; in proxy_storage_get()
164 obj_io *eio = &io->eio; in proxy_storage_get()
168 do_cache_free(t->io_cache, io); in proxy_storage_get()
172 io->iovec_data = resp->iovcnt; in proxy_storage_get()
176 resp->io_pending = (io_pending_t *)io; in proxy_storage_get()
179 eio->data = (void *)io; in proxy_storage_get()
1767 io_pending_proxy_t *io = (io_pending_proxy_t *)rctx->resp->io_pending; in mcplib_internal_run() local
1769 io->eio.next = q->stack_ctx; in mcplib_internal_run()
1770 q->stack_ctx = &io->eio; in mcplib_internal_run()
1774 io->rctx = rctx; in mcplib_internal_run()
1775 io->c = rctx->c; in mcplib_internal_run()
1776 io->ascii_multiget = rq->ascii_multiget; in mcplib_internal_run()
1778 r->buf = io->eio.buf; in mcplib_internal_run()