Signed-off-by: Jens Axboe <jens.axboe@oracle.com>
{
struct null_data *nd = td->io_ops->data;
{
struct null_data *nd = td->io_ops->data;
- nd->events += nd->queued;
- nd->queued = 0;
+ if (!nd->events) {
+ nd->events = nd->queued;
+ nd->queued = 0;
+ }
+
if (td->io_ops->flags & FIO_SYNCIO)
return FIO_Q_COMPLETED;
if (td->io_ops->flags & FIO_SYNCIO)
return FIO_Q_COMPLETED;
+ if (nd->events)
+ return FIO_Q_BUSY;
nd->io_us[nd->queued++] = io_u;
return FIO_Q_QUEUED;
nd->io_us[nd->queued++] = io_u;
return FIO_Q_QUEUED;