X-Git-Url: https://git.kernel.dk/?p=fio.git;a=blobdiff_plain;f=engines%2Fguasi.c;h=e0bcaf4c72bf89058d7e78533de9beafd847bb9f;hp=1d3c77f6bce16752eb688928c523d64fcf23b1bb;hb=28cfeb6851703cf12b54b3a06bf3ff611198933e;hpb=317b95d07d4921d2594a1be6e014c9c2d062fe75 diff --git a/engines/guasi.c b/engines/guasi.c index 1d3c77f6..e0bcaf4c 100644 --- a/engines/guasi.c +++ b/engines/guasi.c @@ -37,9 +37,6 @@ #define GDBG_PRINT(a) (void) 0 #endif -#define STFU_GCC(a) a = a - - struct guasi_data { guasi_t hctx; int max_reqs; @@ -89,8 +86,8 @@ static struct io_u *fio_guasi_event(struct thread_data *td, int event) return io_u; } -static int fio_guasi_getevents(struct thread_data *td, int min, int max, - struct timespec *t) +static int fio_guasi_getevents(struct thread_data *td, unsigned int min, + unsigned int max, struct timespec *t) { struct guasi_data *ld = td->io_ops->data; int n, r; @@ -127,6 +124,8 @@ static int fio_guasi_queue(struct thread_data *td, struct io_u *io_u) { struct guasi_data *ld = td->io_ops->data; + fio_ro_check(td, io_u); + GDBG_PRINT(("fio_guasi_queue(%p)\n", io_u)); if (ld->queued_nr == (int) td->o.iodepth) return FIO_Q_BUSY; @@ -190,11 +189,9 @@ static int fio_guasi_commit(struct thread_data *td) return 0; } -static int fio_guasi_cancel(struct thread_data *td, struct io_u *io_u) +static int fio_guasi_cancel(struct thread_data fio_unused *td, + struct io_u *io_u) { - struct guasi_data *ld = td->io_ops->data; - - STFU_GCC(ld); GDBG_PRINT(("fio_guasi_cancel(%p) req=%p\n", io_u, io_u->greq)); if (io_u->greq != NULL) guasi_req_cancel(io_u->greq); @@ -230,7 +227,7 @@ static int fio_guasi_init(struct thread_data *td) maxthr = td->o.iodepth > GFIO_MIN_THREADS ? td->o.iodepth: GFIO_MIN_THREADS; if (maxthr > GFIO_MAX_THREADS) maxthr = GFIO_MAX_THREADS; - if ((ld->hctx = guasi_create(GFIO_MIN_THREADS, maxthr, 1, 0)) == NULL) { + if ((ld->hctx = guasi_create(GFIO_MIN_THREADS, maxthr, 1)) == NULL) { td_verror(td, errno, "guasi_create"); free(ld); return 1;