Lines Matching refs:io
144 static void _storage_get_item_cb(void *e, obj_io *io, int ret) { in _storage_get_item_cb() argument
146 io_pending_storage_t *p = (io_pending_storage_t *)io->data; in _storage_get_item_cb()
150 item *read_it = (item *)io->buf; in _storage_get_item_cb()
161 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()
166 for (x = 1; x < io->iovcnt; x++) { 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()
170 crc2 = crc32c(0, (char *)read_it+STORE_OFFSET, io->len-STORE_OFFSET); in _storage_get_item_cb()
398 obj_io *io = &p->io_ctx; in recache_or_free() local
399 assert(io != NULL); in recache_or_free()
400 item *it = (item *)io->buf; in recache_or_free()
479 obj_io *io = &p->io_ctx; in storage_finalize_cb() local
481 if (io->iov) { in storage_finalize_cb()
482 free(io->iov); in storage_finalize_cb()
483 io->iov = NULL; in storage_finalize_cb()
503 obj_io io; in storage_write() local
523 io.len = orig_ntotal; in storage_write()
524 io.mode = OBJ_IO_WRITE; in storage_write()
530 if (extstore_write_request(storage, bucket, bucket, &io) == 0) { in storage_write()
533 item *buf_it = (item *) io.buf; in storage_write()
544 … memcpy((char *)io.buf+STORE_OFFSET, (char *)it+STORE_OFFSET, hdrtotal - STORE_OFFSET); in storage_write()
549 memcpy((char *)io.buf+copied, sch->data, sch->used); in storage_write()
556 … memcpy((char *)io.buf+STORE_OFFSET, (char *)it+STORE_OFFSET, io.len-STORE_OFFSET); in storage_write()
560 buf_it->exptime = crc32c(0, (char*)io.buf+STORE_OFFSET, orig_ntotal-STORE_OFFSET); in storage_write()
561 extstore_write(storage, &io); in storage_write()
563 hdr->page_version = io.page_version; in storage_write()
564 hdr->page_id = io.page_id; in storage_write()
565 hdr->offset = io.offset; in storage_write()
895 obj_io io; member
957 obj_io io; in storage_compact_readback() local
958 io.len = ntotal; in storage_compact_readback()
959 io.mode = OBJ_IO_WRITE; in storage_compact_readback()
961 if (extstore_write_request(storage, bucket, bucket, &io) == 0) { in storage_compact_readback()
962 memcpy(io.buf, it, io.len); in storage_compact_readback()
963 extstore_write(storage, &io); in storage_compact_readback()
974 hdr->page_version = io.page_version; in storage_compact_readback()
975 hdr->page_id = io.page_id; in storage_compact_readback()
976 hdr->offset = io.offset; in storage_compact_readback()
993 new_hdr->page_version = io.page_version; in storage_compact_readback()
994 new_hdr->page_id = io.page_id; in storage_compact_readback()
995 new_hdr->offset = io.offset; in storage_compact_readback()
1041 static void _storage_compact_cb(void *e, obj_io *io, int ret) { in _storage_compact_cb() argument
1042 struct storage_compact_wrap *wrap = (struct storage_compact_wrap *)io->data; in _storage_compact_cb()
1083 wrap.io.data = &wrap; in storage_compact_thread()
1084 wrap.io.iov = NULL; in storage_compact_thread()
1085 wrap.io.buf = (void *)readback_buf; in storage_compact_thread()
1087 wrap.io.len = settings.ext_wbuf_size; in storage_compact_thread()
1088 wrap.io.mode = OBJ_IO_READ; in storage_compact_thread()
1089 wrap.io.cb = _storage_compact_cb; in storage_compact_thread()
1106 wrap.io.page_version = page_version; in storage_compact_thread()
1107 wrap.io.page_id = page_id; in storage_compact_thread()
1108 wrap.io.offset = page_offset; in storage_compact_thread()
1110 wrap.io.next = NULL; in storage_compact_thread()
1114 extstore_submit_bg(storage, &wrap.io); in storage_compact_thread()