Lines Matching refs:task
43 struct vhost_blk_task *task, in vhost_bdev_blk_readwrite() argument
55 for (i = 1; i < task->iovs_cnt - 1; i++) { in vhost_bdev_blk_readwrite()
56 if (task->dxfer_dir == BLK_DIR_TO_DEV) in vhost_bdev_blk_readwrite()
57 memcpy(bdev->data + offset, task->iovs[i].iov_base, in vhost_bdev_blk_readwrite()
58 task->iovs[i].iov_len); in vhost_bdev_blk_readwrite()
60 memcpy(task->iovs[i].iov_base, bdev->data + offset, in vhost_bdev_blk_readwrite()
61 task->iovs[i].iov_len); in vhost_bdev_blk_readwrite()
62 offset += task->iovs[i].iov_len; in vhost_bdev_blk_readwrite()
63 nbytes += task->iovs[i].iov_len; in vhost_bdev_blk_readwrite()
71 struct vhost_blk_task *task) in vhost_bdev_process_blk_commands() argument
75 if (unlikely(task->data_len > (bdev->blockcnt * bdev->blocklen))) { in vhost_bdev_process_blk_commands()
80 switch (task->req->type) { in vhost_bdev_process_blk_commands()
82 if (unlikely(task->data_len == 0 || in vhost_bdev_process_blk_commands()
83 (task->data_len & (512 - 1)) != 0)) { in vhost_bdev_process_blk_commands()
87 task->req->type ? "WRITE" : "READ", in vhost_bdev_process_blk_commands()
88 task->req_idx); in vhost_bdev_process_blk_commands()
92 task->dxfer_dir = BLK_DIR_FROM_DEV; in vhost_bdev_process_blk_commands()
93 vhost_bdev_blk_readwrite(bdev, task, in vhost_bdev_process_blk_commands()
94 task->req->sector, task->data_len); in vhost_bdev_process_blk_commands()
97 if (unlikely(task->data_len == 0 || in vhost_bdev_process_blk_commands()
98 (task->data_len & (512 - 1)) != 0)) { in vhost_bdev_process_blk_commands()
102 task->req->type ? "WRITE" : "READ", in vhost_bdev_process_blk_commands()
103 task->req_idx); in vhost_bdev_process_blk_commands()
107 task->dxfer_dir = BLK_DIR_TO_DEV; in vhost_bdev_process_blk_commands()
108 vhost_bdev_blk_readwrite(bdev, task, in vhost_bdev_process_blk_commands()
109 task->req->sector, task->data_len); in vhost_bdev_process_blk_commands()
112 if (!task->iovs_cnt || task->data_len) in vhost_bdev_process_blk_commands()
114 used_len = RTE_MIN((size_t)VIRTIO_BLK_ID_BYTES, task->data_len); in vhost_bdev_process_blk_commands()
115 vhost_strcpy_pad(task->iovs[0].iov_base, in vhost_bdev_process_blk_commands()