Lines Matching refs:io_req
481 struct io_thread_req *io_req = (*irq_req_buffer)[count]; in ubd_handler() local
483 if ((io_req->error == BLK_STS_NOTSUPP) && (req_op(io_req->req) == REQ_OP_DISCARD)) { in ubd_handler()
484 blk_queue_max_discard_sectors(io_req->req->q, 0); in ubd_handler()
485 blk_queue_max_write_zeroes_sectors(io_req->req->q, 0); in ubd_handler()
487 blk_mq_end_request(io_req->req, io_req->error); in ubd_handler()
488 kfree(io_req); in ubd_handler()
1258 static void ubd_map_req(struct ubd *dev, struct io_thread_req *io_req, in ubd_map_req() argument
1264 unsigned long byte_offset = io_req->offset; in ubd_map_req()
1268 io_req->io_desc[0].buffer = NULL; in ubd_map_req()
1269 io_req->io_desc[0].length = blk_rq_bytes(req); in ubd_map_req()
1272 BUG_ON(i >= io_req->desc_cnt); in ubd_map_req()
1274 io_req->io_desc[i].buffer = bvec_virt(&bvec); in ubd_map_req()
1275 io_req->io_desc[i].length = bvec.bv_len; in ubd_map_req()
1281 for (i = 0; i < io_req->desc_cnt; i++) { in ubd_map_req()
1282 cowify_req(io_req, &io_req->io_desc[i], byte_offset, in ubd_map_req()
1285 byte_offset += io_req->io_desc[i].length; in ubd_map_req()
1294 struct io_thread_req *io_req; in ubd_alloc_req() local
1297 io_req = kmalloc(sizeof(*io_req) + in ubd_alloc_req()
1300 if (!io_req) in ubd_alloc_req()
1303 io_req->req = req; in ubd_alloc_req()
1305 io_req->fds[0] = dev->cow.fd; in ubd_alloc_req()
1307 io_req->fds[0] = dev->fd; in ubd_alloc_req()
1308 io_req->error = 0; in ubd_alloc_req()
1309 io_req->sectorsize = SECTOR_SIZE; in ubd_alloc_req()
1310 io_req->fds[1] = dev->fd; in ubd_alloc_req()
1311 io_req->offset = (u64) blk_rq_pos(req) << SECTOR_SHIFT; in ubd_alloc_req()
1312 io_req->offsets[0] = 0; in ubd_alloc_req()
1313 io_req->offsets[1] = dev->cow.data_offset; in ubd_alloc_req()
1316 io_req->io_desc[i].sector_mask = 0; in ubd_alloc_req()
1317 io_req->io_desc[i].cow_offset = -1; in ubd_alloc_req()
1320 return io_req; in ubd_alloc_req()
1326 struct io_thread_req *io_req; in ubd_submit_request() local
1337 io_req = ubd_alloc_req(dev, req, segs); in ubd_submit_request()
1338 if (!io_req) in ubd_submit_request()
1341 io_req->desc_cnt = segs; in ubd_submit_request()
1343 ubd_map_req(dev, io_req, req); in ubd_submit_request()
1345 ret = os_write_file(thread_fd, &io_req, sizeof(io_req)); in ubd_submit_request()
1346 if (ret != sizeof(io_req)) { in ubd_submit_request()
1349 kfree(io_req); in ubd_submit_request()