windowsaio: fix file offset bug
authorBruce Cran <BCran@fusionio.com>
Wed, 1 Feb 2012 20:46:55 +0000 (21:46 +0100)
committerJens Axboe <axboe@kernel.dk>
Wed, 1 Feb 2012 20:46:55 +0000 (21:46 +0100)
I was monitoring file IO while running fio today and noticed that the file
offset when using windowsaio was always 0.
Because the OVERLAPPED structure contains a union, by initializing Pointer
to NULL the code was also overwriting the Offset field.
I've attached a patch that fixes it.

Signed-off-by: Jens Axboe <axboe@kernel.dk>
engines/windowsaio.c

index 78f7382..e97d176 100644 (file)
@@ -223,7 +223,7 @@ static int fio_windowsaio_open_file(struct thread_data *td, struct fio_file *f)
 static int fio_windowsaio_close_file(struct thread_data fio_unused *td, struct fio_file *f)
 {
        int rc = 0;
-       
+
        dprint(FD_FILE, "fd close %s\n", f->file_name);
 
        if (f->hFile != INVALID_HANDLE_VALUE) {
@@ -307,7 +307,7 @@ static int fio_windowsaio_getevents(struct thread_data *td, unsigned int min,
 static int fio_windowsaio_queue(struct thread_data *td,
                              struct io_u *io_u)
 {
-    LPOVERLAPPED lpOvl = NULL;
+       LPOVERLAPPED lpOvl = NULL;
        struct windowsaio_data *wd;
        DWORD iobytes;
        BOOL success;
@@ -318,24 +318,23 @@ static int fio_windowsaio_queue(struct thread_data *td,
 
        wd = td->io_ops->data;
 
-    for (index = 0; index < td->o.iodepth; index++) {
-        if (wd->ovls[index].io_free) {
-            wd->ovls[index].io_free = FALSE;
-            ResetEvent(wd->ovls[index].o.hEvent);
-            break;
-        }
-    }
+       for (index = 0; index < td->o.iodepth; index++) {
+               if (wd->ovls[index].io_free) {
+                       wd->ovls[index].io_free = FALSE;
+                       ResetEvent(wd->ovls[index].o.hEvent);
+                       break;
+               }
+       }
 
-    assert(index < td->o.iodepth);
+       assert(index < td->o.iodepth);
 
-    lpOvl = &wd->ovls[index].o;
-    wd->ovls[index].io_u = io_u;
+       lpOvl = &wd->ovls[index].o;
+       wd->ovls[index].io_u = io_u;
        lpOvl->Internal = STATUS_PENDING;
        lpOvl->InternalHigh = 0;
        lpOvl->Offset = io_u->offset & 0xFFFFFFFF;
        lpOvl->OffsetHigh = io_u->offset >> 32;
-       lpOvl->Pointer = NULL;
-    io_u->engine_data = &wd->ovls[index];
+       io_u->engine_data = &wd->ovls[index];
 
        switch (io_u->ddir) {
     case DDIR_WRITE: