#define SUSPEND_ENTRIES 8
static int fio_posixaio_getevents(struct thread_data *td, unsigned int min,
#define SUSPEND_ENTRIES 8
static int fio_posixaio_getevents(struct thread_data *td, unsigned int min,
- flist_for_each(entry, &td->io_u_busylist) {
- struct io_u *io_u = flist_entry(entry, struct io_u, list);
+ memset(suspend_list, 0, sizeof(suspend_list));
+ suspend_entries = 0;
+ io_u_qiter(&td->io_u_all, io_u, i) {
/*
* At least OSX has a very low limit on the number of pending
* IOs, so if it returns EAGAIN, we are out of resources
* to queue more. Just return FIO_Q_BUSY to naturally
* drop off at this depth.
*/
/*
* At least OSX has a very low limit on the number of pending
* IOs, so if it returns EAGAIN, we are out of resources
* to queue more. Just return FIO_Q_BUSY to naturally
* drop off at this depth.
*/
pd->aio_events = malloc(td->o.iodepth * sizeof(struct io_u *));
memset(pd->aio_events, 0, td->o.iodepth * sizeof(struct io_u *));
pd->aio_events = malloc(td->o.iodepth * sizeof(struct io_u *));
memset(pd->aio_events, 0, td->o.iodepth * sizeof(struct io_u *));