12866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe/* 2da751ca9665bcdeca56d2eec5b629a0953c07662Jens Axboe * posixaio engine 3da751ca9665bcdeca56d2eec5b629a0953c07662Jens Axboe * 4da751ca9665bcdeca56d2eec5b629a0953c07662Jens Axboe * IO engine that uses the posix defined 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> 11bc733f3b3ae7d397a591e3616503cfb36d56166bJens Axboe#include <fcntl.h> 125f350952eff89948bfbf1eb6ac4d3d08a9109581Jens Axboe 135f350952eff89948bfbf1eb6ac4d3d08a9109581Jens Axboe#include "../fio.h" 142866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 152866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboestruct posixaio_data { 162866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe struct io_u **aio_events; 17207cb0f05e689a50ffb960830f52169a1342aba7Jens Axboe unsigned int queued; 182866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe}; 192866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 202866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboestatic int fill_timespec(struct timespec *ts) 212866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe{ 225351f564918be658b8dd98a373cd91247c1e484bJens Axboe#ifdef CONFIG_CLOCK_GETTIME 235351f564918be658b8dd98a373cd91247c1e484bJens Axboe#ifdef CONFIG_CLOCK_MONOTONIC 245351f564918be658b8dd98a373cd91247c1e484bJens Axboe clockid_t clk = CLOCK_MONOTONIC; 255351f564918be658b8dd98a373cd91247c1e484bJens Axboe#else 265351f564918be658b8dd98a373cd91247c1e484bJens Axboe clockid_t clk = CLOCK_REALTIME; 275351f564918be658b8dd98a373cd91247c1e484bJens Axboe#endif 285351f564918be658b8dd98a373cd91247c1e484bJens Axboe if (!clock_gettime(clk, ts)) 292866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe return 0; 302866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 312866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe perror("clock_gettime"); 322866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe return 1; 335351f564918be658b8dd98a373cd91247c1e484bJens Axboe#else 345351f564918be658b8dd98a373cd91247c1e484bJens Axboe struct timeval tv; 355351f564918be658b8dd98a373cd91247c1e484bJens Axboe 365351f564918be658b8dd98a373cd91247c1e484bJens Axboe gettimeofday(&tv, NULL); 375351f564918be658b8dd98a373cd91247c1e484bJens Axboe ts->tv_sec = tv.tv_sec; 385351f564918be658b8dd98a373cd91247c1e484bJens Axboe ts->tv_nsec = tv.tv_usec * 1000; 395351f564918be658b8dd98a373cd91247c1e484bJens Axboe return 0; 405351f564918be658b8dd98a373cd91247c1e484bJens Axboe#endif 412866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe} 422866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 432866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboestatic unsigned long long ts_utime_since_now(struct timespec *t) 442866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe{ 452866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe long long sec, nsec; 462866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe struct timespec now; 472866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 482866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe if (fill_timespec(&now)) 492866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe return 0; 502866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 512866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe sec = now.tv_sec - t->tv_sec; 522866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe nsec = now.tv_nsec - t->tv_nsec; 532866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe if (sec > 0 && nsec < 0) { 542866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe sec--; 552866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe nsec += 1000000000; 562866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe } 572866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 582866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe sec *= 1000000; 592866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe nsec /= 1000; 602866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe return sec + nsec; 612866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe} 622866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 637a16dd027f83d7ff8ff0e72bb6bb12fae046fcbfJens Axboestatic int fio_posixaio_cancel(struct thread_data fio_unused *td, 647a16dd027f83d7ff8ff0e72bb6bb12fae046fcbfJens Axboe struct io_u *io_u) 652866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe{ 6653cdc6864f7471b28cc9b40a5314ab43e5b1cb5eJens Axboe struct fio_file *f = io_u->file; 6753cdc6864f7471b28cc9b40a5314ab43e5b1cb5eJens Axboe int r = aio_cancel(f->fd, &io_u->aiocb); 682866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 692faf9ec84cc329304bd0dcbf928184e11e550108YAMAMOTO Takashi if (r == AIO_ALLDONE || r == AIO_CANCELED) 702866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe return 0; 712866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 722866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe return 1; 732866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe} 742866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 757a16dd027f83d7ff8ff0e72bb6bb12fae046fcbfJens Axboestatic int fio_posixaio_prep(struct thread_data fio_unused *td, 767a16dd027f83d7ff8ff0e72bb6bb12fae046fcbfJens Axboe struct io_u *io_u) 772866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe{ 78e97c14423a5688d7adfb342c16363c263cb741f9Jens Axboe os_aiocb_t *aiocb = &io_u->aiocb; 7953cdc6864f7471b28cc9b40a5314ab43e5b1cb5eJens Axboe struct fio_file *f = io_u->file; 802866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 8153cdc6864f7471b28cc9b40a5314ab43e5b1cb5eJens Axboe aiocb->aio_fildes = f->fd; 82cec6b55da1c282b5b91ad346c7804171fccf151eJens Axboe aiocb->aio_buf = io_u->xfer_buf; 83cec6b55da1c282b5b91ad346c7804171fccf151eJens Axboe aiocb->aio_nbytes = io_u->xfer_buflen; 842866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe aiocb->aio_offset = io_u->offset; 859918be5a9bfe2819cccdb9f975f2b9d4d36f3f70Jens Axboe aiocb->aio_sigevent.sigev_notify = SIGEV_NONE; 862866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 872866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe io_u->seen = 0; 882866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe return 0; 892866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe} 902866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 913c77037e67c4a4af29e12f760db2541bad6c5898Jens Axboe#define SUSPEND_ENTRIES 8 923c77037e67c4a4af29e12f760db2541bad6c5898Jens Axboe 93e7d2e61694c62b90a2fb84c012b4edcc1973d72cJens Axboestatic int fio_posixaio_getevents(struct thread_data *td, unsigned int min, 94e7d2e61694c62b90a2fb84c012b4edcc1973d72cJens Axboe unsigned int max, struct timespec *t) 952866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe{ 962866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe struct posixaio_data *pd = td->io_ops->data; 97e97c14423a5688d7adfb342c16363c263cb741f9Jens Axboe os_aiocb_t *suspend_list[SUSPEND_ENTRIES]; 982866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe struct timespec start; 99a3cc770d09992e7823879fc167057a52ecbfddefJens Axboe int have_timeout = 0; 100f832642400a7d0f19f21b744d1b1c7dad452408aJens Axboe int suspend_entries; 1012ae0b204743d6b4048c6fffd46c6280a70f2ecd1Jens Axboe struct io_u *io_u; 102a3cc770d09992e7823879fc167057a52ecbfddefJens Axboe unsigned int r; 1032ae0b204743d6b4048c6fffd46c6280a70f2ecd1Jens Axboe int i; 1042866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 1052866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe if (t && !fill_timespec(&start)) 1062866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe have_timeout = 1; 1075351f564918be658b8dd98a373cd91247c1e484bJens Axboe else 1085351f564918be658b8dd98a373cd91247c1e484bJens Axboe memset(&start, 0, sizeof(start)); 1092866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 1102866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe r = 0; 1112866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboerestart: 112f832642400a7d0f19f21b744d1b1c7dad452408aJens Axboe memset(suspend_list, 0, sizeof(*suspend_list)); 113f832642400a7d0f19f21b744d1b1c7dad452408aJens Axboe suspend_entries = 0; 1142ae0b204743d6b4048c6fffd46c6280a70f2ecd1Jens Axboe io_u_qiter(&td->io_u_all, io_u, i) { 1152866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe int err; 1162866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 1172ae0b204743d6b4048c6fffd46c6280a70f2ecd1Jens Axboe if (io_u->seen || !(io_u->flags & IO_U_F_FLIGHT)) 1182866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe continue; 1192866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 1202866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe err = aio_error(&io_u->aiocb); 1213c77037e67c4a4af29e12f760db2541bad6c5898Jens Axboe if (err == EINPROGRESS) { 1223c77037e67c4a4af29e12f760db2541bad6c5898Jens Axboe if (suspend_entries < SUSPEND_ENTRIES) { 1233c77037e67c4a4af29e12f760db2541bad6c5898Jens Axboe suspend_list[suspend_entries] = &io_u->aiocb; 1243c77037e67c4a4af29e12f760db2541bad6c5898Jens Axboe suspend_entries++; 1253c77037e67c4a4af29e12f760db2541bad6c5898Jens Axboe } 1263f344316b3200143f413c9a4a8fd6476ca5899cfJens Axboe continue; 1273c77037e67c4a4af29e12f760db2541bad6c5898Jens Axboe } 1283f344316b3200143f413c9a4a8fd6476ca5899cfJens Axboe 1293f344316b3200143f413c9a4a8fd6476ca5899cfJens Axboe io_u->seen = 1; 130207cb0f05e689a50ffb960830f52169a1342aba7Jens Axboe pd->queued--; 1313f344316b3200143f413c9a4a8fd6476ca5899cfJens Axboe pd->aio_events[r++] = io_u; 1323f344316b3200143f413c9a4a8fd6476ca5899cfJens Axboe 1333f344316b3200143f413c9a4a8fd6476ca5899cfJens Axboe if (err == ECANCELED) 1343f344316b3200143f413c9a4a8fd6476ca5899cfJens Axboe io_u->resid = io_u->xfer_buflen; 1353f344316b3200143f413c9a4a8fd6476ca5899cfJens Axboe else if (!err) { 1363f344316b3200143f413c9a4a8fd6476ca5899cfJens Axboe ssize_t retval = aio_return(&io_u->aiocb); 1373f344316b3200143f413c9a4a8fd6476ca5899cfJens Axboe 1383f344316b3200143f413c9a4a8fd6476ca5899cfJens Axboe io_u->resid = io_u->xfer_buflen - retval; 1393f344316b3200143f413c9a4a8fd6476ca5899cfJens Axboe } else 1403f344316b3200143f413c9a4a8fd6476ca5899cfJens Axboe io_u->error = err; 1412866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe } 1422866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 1432866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe if (r >= min) 1442866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe return r; 1452866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 1462866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe if (have_timeout) { 1472866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe unsigned long long usec; 1482866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 1492866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe usec = (t->tv_sec * 1000000) + (t->tv_nsec / 1000); 1502866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe if (ts_utime_since_now(&start) > usec) 1512866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe return r; 1522866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe } 1532866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 1542866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe /* 1553c77037e67c4a4af29e12f760db2541bad6c5898Jens Axboe * must have some in-flight, wait for at least one 1562866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe */ 157e97c14423a5688d7adfb342c16363c263cb741f9Jens Axboe aio_suspend((const os_aiocb_t * const *)suspend_list, 1583c77037e67c4a4af29e12f760db2541bad6c5898Jens Axboe suspend_entries, t); 1592866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe goto restart; 1602866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe} 1612866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 1622866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboestatic struct io_u *fio_posixaio_event(struct thread_data *td, int event) 1632866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe{ 1642866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe struct posixaio_data *pd = td->io_ops->data; 1652866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 1662866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe return pd->aio_events[event]; 1672866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe} 1682866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 16903e20d687566753b90383571e5e152c5142bdffdBruce Cranstatic int fio_posixaio_queue(struct thread_data *td, 1702866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe struct io_u *io_u) 1712866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe{ 172207cb0f05e689a50ffb960830f52169a1342aba7Jens Axboe struct posixaio_data *pd = td->io_ops->data; 173e97c14423a5688d7adfb342c16363c263cb741f9Jens Axboe os_aiocb_t *aiocb = &io_u->aiocb; 1742866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe int ret; 1752866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 1767101d9c24abec4be58a086d85d6d92ec6e6492e9Jens Axboe fio_ro_check(td, io_u); 1777101d9c24abec4be58a086d85d6d92ec6e6492e9Jens Axboe 1782866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe if (io_u->ddir == DDIR_READ) 1792866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe ret = aio_read(aiocb); 18087dc1ab1b4df7b977f60e3d43533a896e2ee665bJens Axboe else if (io_u->ddir == DDIR_WRITE) 1812866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe ret = aio_write(aiocb); 182a5f3027cb0495dfe217b2626d248fcc054e7e878Jens Axboe else if (io_u->ddir == DDIR_TRIM) { 183a5f3027cb0495dfe217b2626d248fcc054e7e878Jens Axboe if (pd->queued) 184a5f3027cb0495dfe217b2626d248fcc054e7e878Jens Axboe return FIO_Q_BUSY; 185a5f3027cb0495dfe217b2626d248fcc054e7e878Jens Axboe 186a5f3027cb0495dfe217b2626d248fcc054e7e878Jens Axboe do_io_u_trim(td, io_u); 187a5f3027cb0495dfe217b2626d248fcc054e7e878Jens Axboe return FIO_Q_COMPLETED; 188a5f3027cb0495dfe217b2626d248fcc054e7e878Jens Axboe } else { 18967bf982340d95ca98098ea050b54b4c7adb116c0Jens Axboe#ifdef CONFIG_POSIXAIO_FSYNC 19087dc1ab1b4df7b977f60e3d43533a896e2ee665bJens Axboe ret = aio_fsync(O_SYNC, aiocb); 191207cb0f05e689a50ffb960830f52169a1342aba7Jens Axboe#else 192207cb0f05e689a50ffb960830f52169a1342aba7Jens Axboe if (pd->queued) 193207cb0f05e689a50ffb960830f52169a1342aba7Jens Axboe return FIO_Q_BUSY; 194207cb0f05e689a50ffb960830f52169a1342aba7Jens Axboe 195f011531e61ae750cdf82074e0dea1379b07fa239Jens Axboe do_io_u_sync(td, io_u); 196207cb0f05e689a50ffb960830f52169a1342aba7Jens Axboe return FIO_Q_COMPLETED; 197207cb0f05e689a50ffb960830f52169a1342aba7Jens Axboe#endif 198207cb0f05e689a50ffb960830f52169a1342aba7Jens Axboe } 1994c057b34dfc2554ce506f806e126db22e38488d6Jens Axboe 20095bcd815e5ce55d6cdd8eb83bda5ee411f37bdc9Jens Axboe if (ret) { 2014c057b34dfc2554ce506f806e126db22e38488d6Jens Axboe int aio_err = aio_error(aiocb); 2024c057b34dfc2554ce506f806e126db22e38488d6Jens Axboe 203afa16407813ee36e75aaa665613c469500ed07c6Jens Axboe /* 204afa16407813ee36e75aaa665613c469500ed07c6Jens Axboe * At least OSX has a very low limit on the number of pending 205def1d8e3019d8757b8214691013880ebb414d396Jens Axboe * IOs, so if it returns EAGAIN, we are out of resources 206def1d8e3019d8757b8214691013880ebb414d396Jens Axboe * to queue more. Just return FIO_Q_BUSY to naturally 207def1d8e3019d8757b8214691013880ebb414d396Jens Axboe * drop off at this depth. 208afa16407813ee36e75aaa665613c469500ed07c6Jens Axboe */ 2094c057b34dfc2554ce506f806e126db22e38488d6Jens Axboe if (aio_err == EAGAIN) 210afa16407813ee36e75aaa665613c469500ed07c6Jens Axboe return FIO_Q_BUSY; 211afa16407813ee36e75aaa665613c469500ed07c6Jens Axboe 2124c057b34dfc2554ce506f806e126db22e38488d6Jens Axboe io_u->error = aio_err; 213e1161c325f7866bae879e686d1c673ca32ab09aeJens Axboe td_verror(td, io_u->error, "xfer"); 21436167d82e5f49dee91c6d2cd426068edee90e36fJens Axboe return FIO_Q_COMPLETED; 21595bcd815e5ce55d6cdd8eb83bda5ee411f37bdc9Jens Axboe } 21636167d82e5f49dee91c6d2cd426068edee90e36fJens Axboe 217207cb0f05e689a50ffb960830f52169a1342aba7Jens Axboe pd->queued++; 21836167d82e5f49dee91c6d2cd426068edee90e36fJens Axboe return FIO_Q_QUEUED; 2192866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe} 2202866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 2212866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboestatic void fio_posixaio_cleanup(struct thread_data *td) 2222866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe{ 2232866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe struct posixaio_data *pd = td->io_ops->data; 2242866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 2252866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe if (pd) { 2262866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe free(pd->aio_events); 2272866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe free(pd); 2282866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe } 2292866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe} 2302866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 2312866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboestatic int fio_posixaio_init(struct thread_data *td) 2322866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe{ 2332866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe struct posixaio_data *pd = malloc(sizeof(*pd)); 2342866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 235cb781c758e5df7ff4c6f655c1e4f9df3043a4be9Jens Axboe memset(pd, 0, sizeof(*pd)); 2362dc1bbeb58edc85f2829eed6729862c438ea2353Jens Axboe pd->aio_events = malloc(td->o.iodepth * sizeof(struct io_u *)); 2372dc1bbeb58edc85f2829eed6729862c438ea2353Jens Axboe memset(pd->aio_events, 0, td->o.iodepth * sizeof(struct io_u *)); 2382866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 2392866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe td->io_ops->data = pd; 2402866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe return 0; 2412866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe} 2422866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe 2435f350952eff89948bfbf1eb6ac4d3d08a9109581Jens Axboestatic struct ioengine_ops ioengine = { 2442866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe .name = "posixaio", 2452866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe .version = FIO_IOOPS_VERSION, 2462866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe .init = fio_posixaio_init, 2472866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe .prep = fio_posixaio_prep, 2482866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe .queue = fio_posixaio_queue, 2492866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe .cancel = fio_posixaio_cancel, 2502866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe .getevents = fio_posixaio_getevents, 2512866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe .event = fio_posixaio_event, 2522866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe .cleanup = fio_posixaio_cleanup, 253b5af82930ccfd7dda6a1b11794efb452eb76d8dcJens Axboe .open_file = generic_open_file, 254b5af82930ccfd7dda6a1b11794efb452eb76d8dcJens Axboe .close_file = generic_close_file, 255df9c26b10275a631e83e7cc92d5f7384998b2c49Jens Axboe .get_file_size = generic_get_file_size, 2562866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe}; 25734cfcdafa994a0a75120e498c51eda08bde5df72Jens Axboe 2585f350952eff89948bfbf1eb6ac4d3d08a9109581Jens Axboestatic void fio_init fio_posixaio_register(void) 2595f350952eff89948bfbf1eb6ac4d3d08a9109581Jens Axboe{ 2605f350952eff89948bfbf1eb6ac4d3d08a9109581Jens Axboe register_ioengine(&ioengine); 2615f350952eff89948bfbf1eb6ac4d3d08a9109581Jens Axboe} 2625f350952eff89948bfbf1eb6ac4d3d08a9109581Jens Axboe 2635f350952eff89948bfbf1eb6ac4d3d08a9109581Jens Axboestatic void fio_exit fio_posixaio_unregister(void) 2645f350952eff89948bfbf1eb6ac4d3d08a9109581Jens Axboe{ 2655f350952eff89948bfbf1eb6ac4d3d08a9109581Jens Axboe unregister_ioengine(&ioengine); 2665f350952eff89948bfbf1eb6ac4d3d08a9109581Jens Axboe} 267