projects
/
fio.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
parse: enable options to be marked dont-free
[fio.git]
/
engines
/
rbd.c
diff --git
a/engines/rbd.c
b/engines/rbd.c
index 279b314a8c84c458544c0a915a1bb213bba75fdc..5b51a39c9e8f3595d733a88a1d77cc19ce89aa8f 100644
(file)
--- a/
engines/rbd.c
+++ b/
engines/rbd.c
@@
-290,7
+290,7
@@
static void _fio_rbd_finish_aiocb(rbd_completion_t comp, void *data)
*/
ret = rbd_aio_get_return_value(fri->completion);
if (ret < 0) {
*/
ret = rbd_aio_get_return_value(fri->completion);
if (ret < 0) {
- io_u->error = ret;
+ io_u->error =
-
ret;
io_u->resid = io_u->xfer_buflen;
} else
io_u->error = 0;
io_u->resid = io_u->xfer_buflen;
} else
io_u->error = 0;
@@
-517,6
+517,7
@@
static int fio_rbd_queue(struct thread_data *td, struct io_u *io_u)
} else {
dprint(FD_IO, "%s: Warning: unhandled ddir: %d\n", __func__,
io_u->ddir);
} else {
dprint(FD_IO, "%s: Warning: unhandled ddir: %d\n", __func__,
io_u->ddir);
+ r = -EINVAL;
goto failed_comp;
}
goto failed_comp;
}
@@
-524,7
+525,7
@@
static int fio_rbd_queue(struct thread_data *td, struct io_u *io_u)
failed_comp:
rbd_aio_release(fri->completion);
failed:
failed_comp:
rbd_aio_release(fri->completion);
failed:
- io_u->error = r;
+ io_u->error =
-
r;
td_verror(td, io_u->error, "xfer");
return FIO_Q_COMPLETED;
}
td_verror(td, io_u->error, "xfer");
return FIO_Q_COMPLETED;
}