libaio.c revision e7d2e61694c62b90a2fb84c012b4edcc1973d72c
12866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe/* 2da751ca9665bcdeca56d2eec5b629a0953c07662Jens Axboe * libaio engine 3da751ca9665bcdeca56d2eec5b629a0953c07662Jens Axboe * 4da751ca9665bcdeca56d2eec5b629a0953c07662Jens Axboe * IO engine using the Linux native aio interface. 52866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe * 62866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe */ 72866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe#include <stdio.h> 82866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe#include <stdlib.h> 92866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe#include <unistd.h> 102866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe#include <errno.h> 112866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe#include <assert.h> 125f350952eff89948bfbf1eb6ac4d3d08a9109581Jens Axboe 135f350952eff89948bfbf1eb6ac4d3d08a9109581Jens Axboe#include "../fio.h" 142866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 1534cfcdafa994a0a75120e498c51eda08bde5df72Jens Axboe#ifdef FIO_HAVE_LIBAIO 1634cfcdafa994a0a75120e498c51eda08bde5df72Jens Axboe 172866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe#define ev_to_iou(ev) (struct io_u *) ((unsigned long) (ev)->obj) 182866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 192866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboestruct libaio_data { 202866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe io_context_t aio_ctx; 212866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe struct io_event *aio_events; 22755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe struct iocb **iocbs; 237e77dd026d85253936aef432ba8f3e89b96b805cJens Axboe struct io_u **io_us; 24755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe int iocbs_nr; 252866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe}; 262866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 277a16dd027f83d7ff8ff0e72bb6bb12fae046fcbfJens Axboestatic int fio_libaio_prep(struct thread_data fio_unused *td, struct io_u *io_u) 282866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe{ 2953cdc6864f7471b28cc9b40a5314ab43e5b1cb5eJens Axboe struct fio_file *f = io_u->file; 3053cdc6864f7471b28cc9b40a5314ab43e5b1cb5eJens Axboe 312866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe if (io_u->ddir == DDIR_READ) 32cec6b55da1c282b5b91ad346c7804171fccf151eJens Axboe io_prep_pread(&io_u->iocb, f->fd, io_u->xfer_buf, io_u->xfer_buflen, io_u->offset); 3387dc1ab1b4df7b977f60e3d43533a896e2ee665bJens Axboe else if (io_u->ddir == DDIR_WRITE) 34cec6b55da1c282b5b91ad346c7804171fccf151eJens Axboe io_prep_pwrite(&io_u->iocb, f->fd, io_u->xfer_buf, io_u->xfer_buflen, io_u->offset); 3587dc1ab1b4df7b977f60e3d43533a896e2ee665bJens Axboe else if (io_u->ddir == DDIR_SYNC) 3687dc1ab1b4df7b977f60e3d43533a896e2ee665bJens Axboe io_prep_fsync(&io_u->iocb, f->fd); 3787dc1ab1b4df7b977f60e3d43533a896e2ee665bJens Axboe else 3887dc1ab1b4df7b977f60e3d43533a896e2ee665bJens Axboe return 1; 392866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 402866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe return 0; 412866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe} 422866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 432866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboestatic struct io_u *fio_libaio_event(struct thread_data *td, int event) 442866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe{ 452866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe struct libaio_data *ld = td->io_ops->data; 46f423479dad8916c758792308863dcd833a1a36c8Jens Axboe struct io_event *ev; 47f423479dad8916c758792308863dcd833a1a36c8Jens Axboe struct io_u *io_u; 482866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 49f423479dad8916c758792308863dcd833a1a36c8Jens Axboe ev = ld->aio_events + event; 50f423479dad8916c758792308863dcd833a1a36c8Jens Axboe io_u = ev_to_iou(ev); 51f423479dad8916c758792308863dcd833a1a36c8Jens Axboe 52f423479dad8916c758792308863dcd833a1a36c8Jens Axboe if (ev->res != io_u->xfer_buflen) { 53f423479dad8916c758792308863dcd833a1a36c8Jens Axboe if (ev->res > io_u->xfer_buflen) 54f423479dad8916c758792308863dcd833a1a36c8Jens Axboe io_u->error = -ev->res; 55f423479dad8916c758792308863dcd833a1a36c8Jens Axboe else 56f423479dad8916c758792308863dcd833a1a36c8Jens Axboe io_u->resid = io_u->xfer_buflen - ev->res; 57f423479dad8916c758792308863dcd833a1a36c8Jens Axboe } else 58f423479dad8916c758792308863dcd833a1a36c8Jens Axboe io_u->error = 0; 59f423479dad8916c758792308863dcd833a1a36c8Jens Axboe 60f423479dad8916c758792308863dcd833a1a36c8Jens Axboe return io_u; 612866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe} 622866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 63e7d2e61694c62b90a2fb84c012b4edcc1973d72cJens Axboestatic int fio_libaio_getevents(struct thread_data *td, unsigned int min, 64e7d2e61694c62b90a2fb84c012b4edcc1973d72cJens Axboe unsigned int max, struct timespec *t) 652866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe{ 662866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe struct libaio_data *ld = td->io_ops->data; 672866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe long r; 682866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 692866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe do { 702866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe r = io_getevents(ld->aio_ctx, min, max, ld->aio_events, t); 71ccbb91cb902f5a1931681248735551815d12c653Jens Axboe if (r >= min) 72ccbb91cb902f5a1931681248735551815d12c653Jens Axboe break; 73ccbb91cb902f5a1931681248735551815d12c653Jens Axboe else if (r == -EAGAIN) { 742866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe usleep(100); 752866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe continue; 762866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe } else if (r == -EINTR) 772866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe continue; 7884585003d025a38b91749cb0d68f6b5653d1f1a3Jens Axboe else if (r != 0) 792866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe break; 802866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe } while (1); 812866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 8222819ec237297fc39435ed566bee01a4225bfb39Jens Axboe return r; 832866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe} 842866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 852866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboestatic int fio_libaio_queue(struct thread_data *td, struct io_u *io_u) 862866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe{ 872866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe struct libaio_data *ld = td->io_ops->data; 882866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 897101d9c24abec4be58a086d85d6d92ec6e6492e9Jens Axboe fio_ro_check(td, io_u); 907101d9c24abec4be58a086d85d6d92ec6e6492e9Jens Axboe 912dc1bbeb58edc85f2829eed6729862c438ea2353Jens Axboe if (ld->iocbs_nr == (int) td->o.iodepth) 92755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe return FIO_Q_BUSY; 93755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe 94755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe /* 95755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe * fsync is tricky, since it can fail and we need to do it 96755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe * serialized with other io. the reason is that linux doesn't 97755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe * support aio fsync yet. So return busy for the case where we 98755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe * have pending io, to let fio complete those first. 99755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe */ 100755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe if (io_u->ddir == DDIR_SYNC) { 101755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe if (ld->iocbs_nr) 102755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe return FIO_Q_BUSY; 103755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe if (fsync(io_u->file->fd) < 0) 104755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe io_u->error = errno; 105755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe 106755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe return FIO_Q_COMPLETED; 107755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe } 108755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe 109755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe ld->iocbs[ld->iocbs_nr] = &io_u->iocb; 1107e77dd026d85253936aef432ba8f3e89b96b805cJens Axboe ld->io_us[ld->iocbs_nr] = io_u; 111755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe ld->iocbs_nr++; 112755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe return FIO_Q_QUEUED; 113755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe} 114755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe 1157e77dd026d85253936aef432ba8f3e89b96b805cJens Axboestatic void fio_libaio_queued(struct thread_data *td, struct io_u **io_us, 1167e77dd026d85253936aef432ba8f3e89b96b805cJens Axboe unsigned int nr) 1177e77dd026d85253936aef432ba8f3e89b96b805cJens Axboe{ 1187e77dd026d85253936aef432ba8f3e89b96b805cJens Axboe struct timeval now; 1197e77dd026d85253936aef432ba8f3e89b96b805cJens Axboe unsigned int i; 1207e77dd026d85253936aef432ba8f3e89b96b805cJens Axboe 1217e77dd026d85253936aef432ba8f3e89b96b805cJens Axboe fio_gettime(&now, NULL); 1227e77dd026d85253936aef432ba8f3e89b96b805cJens Axboe 1237e77dd026d85253936aef432ba8f3e89b96b805cJens Axboe for (i = 0; i < nr; i++) { 1247e77dd026d85253936aef432ba8f3e89b96b805cJens Axboe struct io_u *io_u = io_us[i]; 1257e77dd026d85253936aef432ba8f3e89b96b805cJens Axboe 1267e77dd026d85253936aef432ba8f3e89b96b805cJens Axboe memcpy(&io_u->issue_time, &now, sizeof(now)); 1277e77dd026d85253936aef432ba8f3e89b96b805cJens Axboe io_u_queued(td, io_u); 1287e77dd026d85253936aef432ba8f3e89b96b805cJens Axboe } 1297e77dd026d85253936aef432ba8f3e89b96b805cJens Axboe} 1307e77dd026d85253936aef432ba8f3e89b96b805cJens Axboe 131755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboestatic int fio_libaio_commit(struct thread_data *td) 132755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe{ 133755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe struct libaio_data *ld = td->io_ops->data; 134755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe struct iocb **iocbs; 1357e77dd026d85253936aef432ba8f3e89b96b805cJens Axboe struct io_u **io_us; 136755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe int ret, iocbs_nr; 137755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe 138755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe if (!ld->iocbs_nr) 139755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe return 0; 140755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe 141755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe iocbs_nr = ld->iocbs_nr; 1427e77dd026d85253936aef432ba8f3e89b96b805cJens Axboe io_us = ld->io_us; 143755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe iocbs = ld->iocbs; 1442866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe do { 145755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe ret = io_submit(ld->aio_ctx, iocbs_nr, iocbs); 146755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe if (ret == iocbs_nr) { 1477e77dd026d85253936aef432ba8f3e89b96b805cJens Axboe fio_libaio_queued(td, io_us, ret); 148755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe ret = 0; 149755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe break; 150755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe } else if (ret > 0) { 1517e77dd026d85253936aef432ba8f3e89b96b805cJens Axboe fio_libaio_queued(td, io_us, ret); 1527e77dd026d85253936aef432ba8f3e89b96b805cJens Axboe io_us += ret; 153755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe iocbs += ret; 154755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe iocbs_nr -= ret; 155755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe continue; 156755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe } else if (ret == -EAGAIN || !ret) 1572866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe usleep(100); 1582866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe else if (ret == -EINTR) 1592866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe continue; 160755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe else 1612866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe break; 1622866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe } while (1); 1632866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 164755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe if (!ret) 165755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe ld->iocbs_nr = 0; 1662866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 16736167d82e5f49dee91c6d2cd426068edee90e36fJens Axboe return ret; 1682866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe} 1692866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 1702866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboestatic int fio_libaio_cancel(struct thread_data *td, struct io_u *io_u) 1712866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe{ 1722866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe struct libaio_data *ld = td->io_ops->data; 1732866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 1742866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe return io_cancel(ld->aio_ctx, &io_u->iocb, ld->aio_events); 1752866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe} 1762866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 1772866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboestatic void fio_libaio_cleanup(struct thread_data *td) 1782866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe{ 1792866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe struct libaio_data *ld = td->io_ops->data; 1802866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 1812866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe if (ld) { 1822866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe io_destroy(ld->aio_ctx); 1837e77dd026d85253936aef432ba8f3e89b96b805cJens Axboe free(ld->aio_events); 1847e77dd026d85253936aef432ba8f3e89b96b805cJens Axboe free(ld->iocbs); 1857e77dd026d85253936aef432ba8f3e89b96b805cJens Axboe free(ld->io_us); 1862866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe free(ld); 1872866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe td->io_ops->data = NULL; 1882866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe } 1892866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe} 1902866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 1912866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboestatic int fio_libaio_init(struct thread_data *td) 1922866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe{ 1932866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe struct libaio_data *ld = malloc(sizeof(*ld)); 1947d059f88c869f89a1456e492e0e4f11b3e2578ffJens Axboe static int warn_print; 195c1db2dced4750f2f506cf4df232dcc75ae05b950Jens Axboe int err; 1962866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 1977d059f88c869f89a1456e492e0e4f11b3e2578ffJens Axboe if (td->o.iodepth > 1 && !td->o.odirect && !warn_print) { 1987d059f88c869f89a1456e492e0e4f11b3e2578ffJens Axboe log_info("fio: libaio engine is only async for non-buffered IO\n"); 1997d059f88c869f89a1456e492e0e4f11b3e2578ffJens Axboe warn_print = 1; 2007d059f88c869f89a1456e492e0e4f11b3e2578ffJens Axboe } 2017d059f88c869f89a1456e492e0e4f11b3e2578ffJens Axboe 2022866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe memset(ld, 0, sizeof(*ld)); 203c1db2dced4750f2f506cf4df232dcc75ae05b950Jens Axboe 204c1db2dced4750f2f506cf4df232dcc75ae05b950Jens Axboe err = io_queue_init(td->o.iodepth, &ld->aio_ctx); 205c1db2dced4750f2f506cf4df232dcc75ae05b950Jens Axboe if (err) { 206c1db2dced4750f2f506cf4df232dcc75ae05b950Jens Axboe td_verror(td, -err, "io_queue_init"); 207cb781c758e5df7ff4c6f655c1e4f9df3043a4be9Jens Axboe free(ld); 2082866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe return 1; 2092866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe } 2102866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 2112dc1bbeb58edc85f2829eed6729862c438ea2353Jens Axboe ld->aio_events = malloc(td->o.iodepth * sizeof(struct io_event)); 2122dc1bbeb58edc85f2829eed6729862c438ea2353Jens Axboe memset(ld->aio_events, 0, td->o.iodepth * sizeof(struct io_event)); 2132dc1bbeb58edc85f2829eed6729862c438ea2353Jens Axboe ld->iocbs = malloc(td->o.iodepth * sizeof(struct iocb *)); 214755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe memset(ld->iocbs, 0, sizeof(struct iocb *)); 2152dc1bbeb58edc85f2829eed6729862c438ea2353Jens Axboe ld->io_us = malloc(td->o.iodepth * sizeof(struct io_u *)); 2162dc1bbeb58edc85f2829eed6729862c438ea2353Jens Axboe memset(ld->io_us, 0, td->o.iodepth * sizeof(struct io_u *)); 217755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe ld->iocbs_nr = 0; 218755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe 2192866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe td->io_ops->data = ld; 2202866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe return 0; 2212866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe} 2222866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 2235f350952eff89948bfbf1eb6ac4d3d08a9109581Jens Axboestatic struct ioengine_ops ioengine = { 2242866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe .name = "libaio", 2252866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe .version = FIO_IOOPS_VERSION, 2262866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe .init = fio_libaio_init, 2272866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe .prep = fio_libaio_prep, 2282866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe .queue = fio_libaio_queue, 229755200a326a33e5e19b16dfd5e013dd98bcf1916Jens Axboe .commit = fio_libaio_commit, 2302866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe .cancel = fio_libaio_cancel, 2312866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe .getevents = fio_libaio_getevents, 2322866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe .event = fio_libaio_event, 2332866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe .cleanup = fio_libaio_cleanup, 234b5af82930ccfd7dda6a1b11794efb452eb76d8dcJens Axboe .open_file = generic_open_file, 235b5af82930ccfd7dda6a1b11794efb452eb76d8dcJens Axboe .close_file = generic_close_file, 2362866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe}; 23734cfcdafa994a0a75120e498c51eda08bde5df72Jens Axboe 23834cfcdafa994a0a75120e498c51eda08bde5df72Jens Axboe#else /* FIO_HAVE_LIBAIO */ 23934cfcdafa994a0a75120e498c51eda08bde5df72Jens Axboe 24034cfcdafa994a0a75120e498c51eda08bde5df72Jens Axboe/* 24134cfcdafa994a0a75120e498c51eda08bde5df72Jens Axboe * When we have a proper configure system in place, we simply wont build 24234cfcdafa994a0a75120e498c51eda08bde5df72Jens Axboe * and install this io engine. For now install a crippled version that 24334cfcdafa994a0a75120e498c51eda08bde5df72Jens Axboe * just complains and fails to load. 24434cfcdafa994a0a75120e498c51eda08bde5df72Jens Axboe */ 24534cfcdafa994a0a75120e498c51eda08bde5df72Jens Axboestatic int fio_libaio_init(struct thread_data fio_unused *td) 24634cfcdafa994a0a75120e498c51eda08bde5df72Jens Axboe{ 24734cfcdafa994a0a75120e498c51eda08bde5df72Jens Axboe fprintf(stderr, "fio: libaio not available\n"); 24834cfcdafa994a0a75120e498c51eda08bde5df72Jens Axboe return 1; 24934cfcdafa994a0a75120e498c51eda08bde5df72Jens Axboe} 25034cfcdafa994a0a75120e498c51eda08bde5df72Jens Axboe 2515f350952eff89948bfbf1eb6ac4d3d08a9109581Jens Axboestatic struct ioengine_ops ioengine = { 25234cfcdafa994a0a75120e498c51eda08bde5df72Jens Axboe .name = "libaio", 25334cfcdafa994a0a75120e498c51eda08bde5df72Jens Axboe .version = FIO_IOOPS_VERSION, 25434cfcdafa994a0a75120e498c51eda08bde5df72Jens Axboe .init = fio_libaio_init, 25534cfcdafa994a0a75120e498c51eda08bde5df72Jens Axboe}; 25634cfcdafa994a0a75120e498c51eda08bde5df72Jens Axboe 25734cfcdafa994a0a75120e498c51eda08bde5df72Jens Axboe#endif 2585f350952eff89948bfbf1eb6ac4d3d08a9109581Jens Axboe 2595f350952eff89948bfbf1eb6ac4d3d08a9109581Jens Axboestatic void fio_init fio_libaio_register(void) 2605f350952eff89948bfbf1eb6ac4d3d08a9109581Jens Axboe{ 2615f350952eff89948bfbf1eb6ac4d3d08a9109581Jens Axboe register_ioengine(&ioengine); 2625f350952eff89948bfbf1eb6ac4d3d08a9109581Jens Axboe} 2635f350952eff89948bfbf1eb6ac4d3d08a9109581Jens Axboe 2645f350952eff89948bfbf1eb6ac4d3d08a9109581Jens Axboestatic void fio_exit fio_libaio_unregister(void) 2655f350952eff89948bfbf1eb6ac4d3d08a9109581Jens Axboe{ 2665f350952eff89948bfbf1eb6ac4d3d08a9109581Jens Axboe unregister_ioengine(&ioengine); 2675f350952eff89948bfbf1eb6ac4d3d08a9109581Jens Axboe} 268