Lines Matching refs:eio
86 static void _storage_get_item_cb(void *e, obj_io *eio, int ret) { in _storage_get_item_cb() argument
87 io_pending_proxy_t *io = (io_pending_proxy_t *)eio->data; in _storage_get_item_cb()
90 item *read_it = (item *)eio->buf; in _storage_get_item_cb()
98 crc2 = crc32c(0, (char *)read_it+STORE_OFFSET, eio->len-STORE_OFFSET); in _storage_get_item_cb()
164 obj_io *eio = &io->eio; in proxy_storage_get() local
166 eio->buf = malloc(ntotal); in proxy_storage_get()
167 if (eio->buf == NULL) { in proxy_storage_get()
179 eio->data = (void *)io; in proxy_storage_get()
183 eio->page_version = hdr.page_version; in proxy_storage_get()
184 eio->page_id = hdr.page_id; in proxy_storage_get()
185 eio->offset = hdr.offset; in proxy_storage_get()
187 eio->page_version = hdr->page_version; in proxy_storage_get()
188 eio->page_id = hdr->page_id; in proxy_storage_get()
189 eio->offset = hdr->offset; in proxy_storage_get()
191 eio->len = ntotal; in proxy_storage_get()
192 eio->mode = OBJ_IO_READ; in proxy_storage_get()
193 eio->cb = _storage_get_item_cb; in proxy_storage_get()
1769 io->eio.next = q->stack_ctx; in mcplib_internal_run()
1770 q->stack_ctx = &io->eio; in mcplib_internal_run()
1778 r->buf = io->eio.buf; in mcplib_internal_run()