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