Home
last modified time | relevance | path

Searched refs:aiocb (Results 1 – 25 of 25) sorted by relevance

/openbmc/linux/tools/build/feature/
H A Dtest-libaio.c6 struct aiocb aiocb; in main() local
8 aiocb.aio_fildes = 0; in main()
9 aiocb.aio_offset = 0; in main()
10 aiocb.aio_buf = 0; in main()
11 aiocb.aio_nbytes = 0; in main()
12 aiocb.aio_reqprio = 0; in main()
13 aiocb.aio_sigevent.sigev_notify = 1 /*SIGEV_NONE*/; in main()
15 return (int)aio_return(&aiocb); in main()
/openbmc/qemu/tests/unit/
H A Dtest-thread-pool.c14 BlockAIOCB *aiocb; member
40 data->aiocb = NULL; in done_cb()
59 data.aiocb = thread_pool_submit_aio(worker_cb, &data, in test_submit_aio()
152 data[i].aiocb = thread_pool_submit_aio(long_cb, &data[i], in do_test_cancel()
176 bdrv_aio_cancel(data[i].aiocb); in do_test_cancel()
178 bdrv_aio_cancel_async(data[i].aiocb); in do_test_cancel()
187 if (data[i].aiocb && qatomic_read(&data[i].n) < 4) { in do_test_cancel()
190 bdrv_aio_cancel(data[i].aiocb); in do_test_cancel()
192 bdrv_aio_cancel_async(data[i].aiocb); in do_test_cancel()
203 g_assert(data[i].aiocb == NULL); in do_test_cancel()
/openbmc/qemu/block/
H A Dfile-posix.c1604 RawPosixAIOData *aiocb = opaque; in handle_aiocb_ioctl() local
1608 ioctl(aiocb->aio_fildes, aiocb->ioctl.cmd, aiocb->ioctl.buf) in handle_aiocb_ioctl()
1620 RawPosixAIOData *aiocb = opaque; in handle_aiocb_flush() local
1621 BDRVRawState *s = aiocb->bs->opaque; in handle_aiocb_flush()
1628 ret = qemu_fdatasync(aiocb->aio_fildes); in handle_aiocb_flush()
1687 static ssize_t handle_aiocb_rw_vector(RawPosixAIOData *aiocb) in handle_aiocb_rw_vector() argument
1692 (aiocb->aio_type & (QEMU_AIO_WRITE | QEMU_AIO_ZONE_APPEND)) ? in handle_aiocb_rw_vector()
1693 qemu_pwritev(aiocb->aio_fildes, in handle_aiocb_rw_vector()
1694 aiocb->io.iov, in handle_aiocb_rw_vector()
1695 aiocb->io.niov, in handle_aiocb_rw_vector()
[all …]
H A Dfile-win32.c72 static size_t handle_aiocb_rw(RawWin32AIOData *aiocb) in handle_aiocb_rw() argument
77 for (i = 0; i < aiocb->aio_niov; i++) { in handle_aiocb_rw()
82 ov.Offset = (aiocb->aio_offset + offset); in handle_aiocb_rw()
83 ov.OffsetHigh = (aiocb->aio_offset + offset) >> 32; in handle_aiocb_rw()
84 len = aiocb->aio_iov[i].iov_len; in handle_aiocb_rw()
85 if (aiocb->aio_type & QEMU_AIO_WRITE) { in handle_aiocb_rw()
86 ret = WriteFile(aiocb->hfile, aiocb->aio_iov[i].iov_base, in handle_aiocb_rw()
89 ret = ReadFile(aiocb->hfile, aiocb->aio_iov[i].iov_base, in handle_aiocb_rw()
107 RawWin32AIOData *aiocb = arg; in aio_worker() local
111 switch (aiocb->aio_type & QEMU_AIO_TYPE_MASK) { in aio_worker()
[all …]
H A Dlinux-aio.c293 struct qemu_laiocb *aiocb; in ioq_submit() local
302 QSIMPLEQ_FOREACH(aiocb, &s->io_q.pending, next) { in ioq_submit()
303 iocbs[len++] = &aiocb->iocb; in ioq_submit()
315 aiocb = QSIMPLEQ_FIRST(&s->io_q.pending); in ioq_submit()
318 aiocb->ret = ret; in ioq_submit()
319 qemu_laio_process_completion(aiocb); in ioq_submit()
325 aiocb = container_of(iocbs[ret - 1], struct qemu_laiocb, iocb); in ioq_submit()
326 QSIMPLEQ_SPLIT_AFTER(&s->io_q.pending, aiocb, next, &completed); in ioq_submit()
H A Dtrace-events71 luring_process_completion(void *s, void *aiocb, int ret) "LuringState %p luringcb %p ret %d"
/openbmc/linux/tools/perf/util/
H A Dmmap.h14 struct aiocb;
35 struct aiocb *cblocks;
36 struct aiocb **aiocb; member
H A Dmmap.c153 map->aio.aiocb = calloc(map->aio.nr_cblocks, sizeof(struct aiocb *)); in perf_mmap__aio_mmap()
154 if (!map->aio.aiocb) { in perf_mmap__aio_mmap()
158 map->aio.cblocks = calloc(map->aio.nr_cblocks, sizeof(struct aiocb)); in perf_mmap__aio_mmap()
210 zfree(&map->aio.aiocb); in perf_mmap__aio_munmap()
/openbmc/qemu/hw/scsi/
H A Dscsi-disk.c336 assert(r->req.aiocb != NULL); in scsi_aio_complete()
337 r->req.aiocb = NULL; in scsi_aio_complete()
380 assert(r->req.aiocb == NULL); in scsi_write_do_fua()
386 r->req.aiocb = blk_aio_flush(s->qdev.conf.blk, scsi_aio_complete, r); in scsi_write_do_fua()
396 assert(r->req.aiocb == NULL); in scsi_dma_complete_noio()
420 assert(r->req.aiocb != NULL); in scsi_dma_complete()
421 r->req.aiocb = NULL; in scsi_dma_complete()
441 assert(r->req.aiocb == NULL); in scsi_read_complete_noio()
461 assert(r->req.aiocb != NULL); in scsi_read_complete()
462 r->req.aiocb = NULL; in scsi_read_complete()
[all …]
H A Dscsi-generic.c80 assert(r->req.aiocb == NULL); in scsi_command_complete_noio()
113 assert(r->req.aiocb != NULL); in scsi_command_complete()
114 r->req.aiocb = NULL; in scsi_command_complete()
139 r->req.aiocb = blk_aio_ioctl(blk, SG_IO, &r->io_header, complete, r); in execute_command()
140 if (r->req.aiocb == NULL) { in execute_command()
273 assert(r->req.aiocb != NULL); in scsi_read_complete()
274 r->req.aiocb = NULL; in scsi_read_complete()
385 assert(r->req.aiocb != NULL); in scsi_write_complete()
386 r->req.aiocb = NULL; in scsi_write_complete()
H A Dscsi-bus.c1632 assert(req->aiocb); in scsi_req_cancel_async()
1639 if (req->aiocb) { in scsi_req_cancel_async()
1640 blk_aio_cancel_async(req->aiocb); in scsi_req_cancel_async()
1657 if (req->aiocb) { in scsi_req_cancel()
1658 blk_aio_cancel(req->aiocb); in scsi_req_cancel()
/openbmc/qemu/hw/ide/
H A Dmacio.c117 s->bus->dma->aiocb = dma_blk_read(s->blk, &s->sg, offset, 0x1, in pmac_ide_atapi_transfer_cb()
182 s->bus->dma->aiocb = dma_blk_read(s->blk, &s->sg, offset, 0x1, in pmac_ide_transfer_cb()
186 s->bus->dma->aiocb = dma_blk_write(s->blk, &s->sg, offset, 0x1, in pmac_ide_transfer_cb()
190 s->bus->dma->aiocb = dma_blk_io(blk_get_aio_context(s->blk), &s->sg, in pmac_ide_transfer_cb()
250 if (s->bus->dma->aiocb) { in pmac_ide_flush()
H A Dcore.c423 BlockAIOCB *aiocb; member
437 if (iocb->aiocb) { in trim_aio_cancel()
438 blk_aio_cancel_async(iocb->aiocb); in trim_aio_cancel()
439 iocb->aiocb = NULL; in trim_aio_cancel()
502 iocb->aiocb = blk_aio_pdiscard(s->blk, in ide_issue_trim_cb()
517 iocb->aiocb = NULL; in ide_issue_trim_cb()
755 if (s->bus->dma->aiocb) { in ide_cancel_dma_sync()
758 assert(s->bus->dma->aiocb == NULL); in ide_cancel_dma_sync()
841 s->bus->dma->aiocb = NULL; in ide_set_inactive()
895 s->bus->dma->aiocb = NULL; in ide_dma_cb()
[all …]
H A Dahci.c689 if (ncq_tfs->aiocb) { in ahci_reset_port()
690 blk_aio_cancel(ncq_tfs->aiocb); in ahci_reset_port()
691 ncq_tfs->aiocb = NULL; in ahci_reset_port()
1051 ncq_tfs->aiocb = NULL; in ncq_cb()
1103 ncq_tfs->aiocb = dma_blk_read(ide_state->blk, &ncq_tfs->sglist, in execute_ncq_command()
1113 ncq_tfs->aiocb = dma_blk_write(ide_state->blk, &ncq_tfs->sglist, in execute_ncq_command()
H A Dahci-internal.h295 BlockAIOCB *aiocb; member
H A Datapi.c356 s->bus->dma->aiocb = NULL; in ide_atapi_cmd_read_dma_cb()
408 s->bus->dma->aiocb = ide_buffered_readv(s, (int64_t)s->lba << 2, in ide_atapi_cmd_read_dma_cb()
/openbmc/qemu/hw/nvme/
H A Dctrl.c710 req->aiocb = NULL; in nvme_req_clear()
1460 req->aiocb = dma_blk_read(blk, &req->sg.qsg, offset, align, cb, req); in nvme_blk_read()
1462 req->aiocb = blk_aio_preadv(blk, offset, &req->sg.iov, 0, cb, req); in nvme_blk_read()
1473 req->aiocb = dma_blk_write(blk, &req->sg.qsg, offset, align, cb, req); in nvme_blk_write()
1475 req->aiocb = blk_aio_pwritev(blk, offset, &req->sg.iov, 0, cb, req); in nvme_blk_write()
2220 req->aiocb = blk_aio_pwrite_zeroes(blk, offset, mlen, in nvme_rw_cb()
2326 req->aiocb = blk_aio_preadv(blk, offset, &ctx->mdata.iov, 0, in nvme_verify_mdata_in_cb()
2482 req->aiocb = blk_aio_preadv(blk, offset, &ctx->mdata.iov, 0, in nvme_compare_data_cb()
2499 BlockAIOCB *aiocb; member
2508 static void nvme_dsm_cancel(BlockAIOCB *aiocb) in nvme_dsm_cancel() argument
[all …]
H A Ddif.c506 req->aiocb = blk_aio_preadv(blk, offset, &ctx->mdata.iov, 0, in nvme_dif_rw_mdata_in_cb()
530 req->aiocb = blk_aio_pwritev(blk, offset, &ctx->mdata.iov, 0, in nvme_dif_rw_mdata_out_cb()
627 req->aiocb = blk_aio_pwrite_zeroes(blk, offset, len, flags, in nvme_dif_rw()
650 req->aiocb = blk_aio_preadv(ns->blkconf.blk, offset, &ctx->data.iov, 0, in nvme_dif_rw()
696 req->aiocb = blk_aio_pwritev(ns->blkconf.blk, offset, &ctx->data.iov, 0, in nvme_dif_rw()
H A Dnvme.h423 BlockAIOCB *aiocb; member
/openbmc/qemu/include/hw/ide/
H A Dide-dma.h34 BlockAIOCB *aiocb; member
/openbmc/linux/fs/
H A Daio.c1731 struct aio_kiocb *aiocb = container_of(iocb, struct aio_kiocb, rw); in aio_poll_cancel() local
1732 struct poll_iocb *req = &aiocb->poll; in aio_poll_cancel()
1737 schedule_work(&aiocb->poll.work); in aio_poll_cancel()
1853 static int aio_poll(struct aio_kiocb *aiocb, const struct iocb *iocb) in aio_poll() argument
1855 struct kioctx *ctx = aiocb->ki_ctx; in aio_poll()
1856 struct poll_iocb *req = &aiocb->poll; in aio_poll()
1878 apt.iocb = aiocb; in aio_poll()
1912 list_add_tail(&aiocb->ki_list, &ctx->active_reqs); in aio_poll()
1913 aiocb->ki_cancel = aio_poll_cancel; in aio_poll()
1919 aiocb->ki_res.res = mangle_poll(mask); in aio_poll()
[all …]
/openbmc/linux/tools/perf/
H A Dbuiltin-record.c277 static int record__aio_write(struct aiocb *cblock, int trace_fd, in record__aio_write()
302 static int record__aio_complete(struct mmap *md, struct aiocb *cblock) in record__aio_complete()
350 struct aiocb **aiocb = md->aio.aiocb; in record__aio_sync() local
351 struct aiocb *cblocks = md->aio.cblocks; in record__aio_sync()
360 aiocb[i] = NULL; in record__aio_sync()
369 aiocb[i] = &cblocks[i]; in record__aio_sync()
376 while (aio_suspend((const struct aiocb **)aiocb, md->aio.nr_cblocks, &timeout)) { in record__aio_sync()
/openbmc/qemu/include/hw/scsi/
H A Dscsi.h49 BlockAIOCB *aiocb; member
/openbmc/qemu/util/
H A Dmeson.build81 util_ss.add(files('aiocb.c', 'async.c'))
/openbmc/linux/
H A Dopengrok1.0.log[all...]