Lines Matching refs:io_req

520 			struct io_thread_req *io_req = (*irq_req_buffer)[count];  in ubd_handler()  local
522 if ((io_req->error == BLK_STS_NOTSUPP) && (req_op(io_req->req) == REQ_OP_DISCARD)) { in ubd_handler()
523 blk_queue_max_discard_sectors(io_req->req->q, 0); in ubd_handler()
524 blk_queue_max_write_zeroes_sectors(io_req->req->q, 0); in ubd_handler()
525 blk_queue_flag_clear(QUEUE_FLAG_DISCARD, io_req->req->q); in ubd_handler()
527 if ((io_req->error) || (io_req->buffer == NULL)) in ubd_handler()
528 blk_mq_end_request(io_req->req, io_req->error); in ubd_handler()
530 if (!blk_update_request(io_req->req, io_req->error, io_req->length)) in ubd_handler()
531 __blk_mq_end_request(io_req->req, io_req->error); in ubd_handler()
533 kfree(io_req); in ubd_handler()
1316 struct io_thread_req *io_req; in ubd_queue_one_vec() local
1319 io_req = kmalloc(sizeof(struct io_thread_req), GFP_ATOMIC); in ubd_queue_one_vec()
1320 if (!io_req) in ubd_queue_one_vec()
1323 io_req->req = req; in ubd_queue_one_vec()
1325 io_req->fds[0] = dev->cow.fd; in ubd_queue_one_vec()
1327 io_req->fds[0] = dev->fd; in ubd_queue_one_vec()
1328 io_req->error = 0; in ubd_queue_one_vec()
1331 io_req->buffer = page_address(bvec->bv_page) + bvec->bv_offset; in ubd_queue_one_vec()
1332 io_req->length = bvec->bv_len; in ubd_queue_one_vec()
1334 io_req->buffer = NULL; in ubd_queue_one_vec()
1335 io_req->length = blk_rq_bytes(req); in ubd_queue_one_vec()
1338 io_req->sectorsize = SECTOR_SIZE; in ubd_queue_one_vec()
1339 io_req->fds[1] = dev->fd; in ubd_queue_one_vec()
1340 io_req->cow_offset = -1; in ubd_queue_one_vec()
1341 io_req->offset = off; in ubd_queue_one_vec()
1342 io_req->sector_mask = 0; in ubd_queue_one_vec()
1343 io_req->offsets[0] = 0; in ubd_queue_one_vec()
1344 io_req->offsets[1] = dev->cow.data_offset; in ubd_queue_one_vec()
1347 cowify_req(io_req, dev->cow.bitmap, in ubd_queue_one_vec()
1350 ret = os_write_file(thread_fd, &io_req, sizeof(io_req)); in ubd_queue_one_vec()
1351 if (ret != sizeof(io_req)) { in ubd_queue_one_vec()
1354 kfree(io_req); in ubd_queue_one_vec()