Lines Matching refs:io_req

528 			struct io_thread_req *io_req = (*irq_req_buffer)[count];  in ubd_handler()  local
530 if ((io_req->error == BLK_STS_NOTSUPP) && (req_op(io_req->req) == REQ_OP_DISCARD)) { in ubd_handler()
531 blk_queue_max_discard_sectors(io_req->req->q, 0); in ubd_handler()
532 blk_queue_max_write_zeroes_sectors(io_req->req->q, 0); in ubd_handler()
533 blk_queue_flag_clear(QUEUE_FLAG_DISCARD, io_req->req->q); in ubd_handler()
535 blk_mq_end_request(io_req->req, io_req->error); in ubd_handler()
536 kfree(io_req); in ubd_handler()
1318 static void ubd_map_req(struct ubd *dev, struct io_thread_req *io_req, in ubd_map_req() argument
1324 unsigned long byte_offset = io_req->offset; in ubd_map_req()
1328 io_req->io_desc[0].buffer = NULL; in ubd_map_req()
1329 io_req->io_desc[0].length = blk_rq_bytes(req); in ubd_map_req()
1332 BUG_ON(i >= io_req->desc_cnt); in ubd_map_req()
1334 io_req->io_desc[i].buffer = in ubd_map_req()
1336 io_req->io_desc[i].length = bvec.bv_len; in ubd_map_req()
1342 for (i = 0; i < io_req->desc_cnt; i++) { in ubd_map_req()
1343 cowify_req(io_req, &io_req->io_desc[i], byte_offset, in ubd_map_req()
1346 byte_offset += io_req->io_desc[i].length; in ubd_map_req()
1355 struct io_thread_req *io_req; in ubd_alloc_req() local
1358 io_req = kmalloc(sizeof(*io_req) + in ubd_alloc_req()
1361 if (!io_req) in ubd_alloc_req()
1364 io_req->req = req; in ubd_alloc_req()
1366 io_req->fds[0] = dev->cow.fd; in ubd_alloc_req()
1368 io_req->fds[0] = dev->fd; in ubd_alloc_req()
1369 io_req->error = 0; in ubd_alloc_req()
1370 io_req->sectorsize = SECTOR_SIZE; in ubd_alloc_req()
1371 io_req->fds[1] = dev->fd; in ubd_alloc_req()
1372 io_req->offset = (u64) blk_rq_pos(req) << SECTOR_SHIFT; in ubd_alloc_req()
1373 io_req->offsets[0] = 0; in ubd_alloc_req()
1374 io_req->offsets[1] = dev->cow.data_offset; in ubd_alloc_req()
1377 io_req->io_desc[i].sector_mask = 0; in ubd_alloc_req()
1378 io_req->io_desc[i].cow_offset = -1; in ubd_alloc_req()
1381 return io_req; in ubd_alloc_req()
1387 struct io_thread_req *io_req; in ubd_submit_request() local
1398 io_req = ubd_alloc_req(dev, req, segs); in ubd_submit_request()
1399 if (!io_req) in ubd_submit_request()
1402 io_req->desc_cnt = segs; in ubd_submit_request()
1404 ubd_map_req(dev, io_req, req); in ubd_submit_request()
1406 ret = os_write_file(thread_fd, &io_req, sizeof(io_req)); in ubd_submit_request()
1407 if (ret != sizeof(io_req)) { in ubd_submit_request()
1410 kfree(io_req); in ubd_submit_request()