Lines Matching refs:io_req

521 			struct io_thread_req *io_req = (*irq_req_buffer)[count];  in ubd_handler()  local
523 if ((io_req->error == BLK_STS_NOTSUPP) && (req_op(io_req->req) == REQ_OP_DISCARD)) { in ubd_handler()
524 blk_queue_max_discard_sectors(io_req->req->q, 0); in ubd_handler()
525 blk_queue_max_write_zeroes_sectors(io_req->req->q, 0); in ubd_handler()
526 blk_queue_flag_clear(QUEUE_FLAG_DISCARD, io_req->req->q); in ubd_handler()
528 if ((io_req->error) || (io_req->buffer == NULL)) in ubd_handler()
529 blk_mq_end_request(io_req->req, io_req->error); in ubd_handler()
531 if (!blk_update_request(io_req->req, io_req->error, io_req->length)) in ubd_handler()
532 __blk_mq_end_request(io_req->req, io_req->error); in ubd_handler()
534 kfree(io_req); in ubd_handler()
1317 struct io_thread_req *io_req; in ubd_queue_one_vec() local
1320 io_req = kmalloc(sizeof(struct io_thread_req), GFP_ATOMIC); in ubd_queue_one_vec()
1321 if (!io_req) in ubd_queue_one_vec()
1324 io_req->req = req; in ubd_queue_one_vec()
1326 io_req->fds[0] = dev->cow.fd; in ubd_queue_one_vec()
1328 io_req->fds[0] = dev->fd; in ubd_queue_one_vec()
1329 io_req->error = 0; in ubd_queue_one_vec()
1332 io_req->buffer = page_address(bvec->bv_page) + bvec->bv_offset; in ubd_queue_one_vec()
1333 io_req->length = bvec->bv_len; in ubd_queue_one_vec()
1335 io_req->buffer = NULL; in ubd_queue_one_vec()
1336 io_req->length = blk_rq_bytes(req); in ubd_queue_one_vec()
1339 io_req->sectorsize = SECTOR_SIZE; in ubd_queue_one_vec()
1340 io_req->fds[1] = dev->fd; in ubd_queue_one_vec()
1341 io_req->cow_offset = -1; in ubd_queue_one_vec()
1342 io_req->offset = off; in ubd_queue_one_vec()
1343 io_req->sector_mask = 0; in ubd_queue_one_vec()
1344 io_req->offsets[0] = 0; in ubd_queue_one_vec()
1345 io_req->offsets[1] = dev->cow.data_offset; in ubd_queue_one_vec()
1348 cowify_req(io_req, dev->cow.bitmap, in ubd_queue_one_vec()
1351 ret = os_write_file(thread_fd, &io_req, sizeof(io_req)); in ubd_queue_one_vec()
1352 if (ret != sizeof(io_req)) { in ubd_queue_one_vec()
1355 kfree(io_req); in ubd_queue_one_vec()