projects
/
fio.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
engines: fixup fio_q_status style violations
[fio.git]
/
engines
/
sync.c
diff --git
a/engines/sync.c
b/engines/sync.c
index 26b98b60e2c7896e846c6b0daa2a1ad138b8b6fb..3f36da824ec30e1e95111561f480abadfa5780e8 100644
(file)
--- a/
engines/sync.c
+++ b/
engines/sync.c
@@
-10,7
+10,6
@@
#include <unistd.h>
#include <sys/uio.h>
#include <errno.h>
#include <unistd.h>
#include <sys/uio.h>
#include <errno.h>
-#include <assert.h>
#include "../fio.h"
#include "../optgroup.h"
#include "../fio.h"
#include "../optgroup.h"
@@
-111,7
+110,8
@@
static int fio_io_end(struct thread_data *td, struct io_u *io_u, int ret)
}
#ifdef CONFIG_PWRITEV
}
#ifdef CONFIG_PWRITEV
-static int fio_pvsyncio_queue(struct thread_data *td, struct io_u *io_u)
+static enum fio_q_status fio_pvsyncio_queue(struct thread_data *td,
+ struct io_u *io_u)
{
struct syncio_data *sd = td->io_ops_data;
struct iovec *iov = &sd->iovecs[0];
{
struct syncio_data *sd = td->io_ops_data;
struct iovec *iov = &sd->iovecs[0];
@@
-138,7
+138,8
@@
static int fio_pvsyncio_queue(struct thread_data *td, struct io_u *io_u)
#endif
#ifdef FIO_HAVE_PWRITEV2
#endif
#ifdef FIO_HAVE_PWRITEV2
-static int fio_pvsyncio2_queue(struct thread_data *td, struct io_u *io_u)
+static enum fio_q_status fio_pvsyncio2_queue(struct thread_data *td,
+ struct io_u *io_u)
{
struct syncio_data *sd = td->io_ops_data;
struct psyncv2_options *o = td->eo;
{
struct syncio_data *sd = td->io_ops_data;
struct psyncv2_options *o = td->eo;
@@
-169,8
+170,8
@@
static int fio_pvsyncio2_queue(struct thread_data *td, struct io_u *io_u)
}
#endif
}
#endif
-
-
static int fio_psyncio_queue(struct thread_data *td,
struct io_u *io_u)
+static enum fio_q_status fio_psyncio_queue(struct thread_data *td,
+
struct io_u *io_u)
{
struct fio_file *f = io_u->file;
int ret;
{
struct fio_file *f = io_u->file;
int ret;
@@
-190,7
+191,8
@@
static int fio_psyncio_queue(struct thread_data *td, struct io_u *io_u)
return fio_io_end(td, io_u, ret);
}
return fio_io_end(td, io_u, ret);
}
-static int fio_syncio_queue(struct thread_data *td, struct io_u *io_u)
+static enum fio_q_status fio_syncio_queue(struct thread_data *td,
+ struct io_u *io_u)
{
struct fio_file *f = io_u->file;
int ret;
{
struct fio_file *f = io_u->file;
int ret;
@@
-261,7
+263,8
@@
static void fio_vsyncio_set_iov(struct syncio_data *sd, struct io_u *io_u,
sd->queued++;
}
sd->queued++;
}
-static int fio_vsyncio_queue(struct thread_data *td, struct io_u *io_u)
+static enum fio_q_status fio_vsyncio_queue(struct thread_data *td,
+ struct io_u *io_u)
{
struct syncio_data *sd = td->io_ops_data;
{
struct syncio_data *sd = td->io_ops_data;