qa/workunits/direct_io/test_sync_io.c: add proper error handling

Signed-off-by: Danny Al-Gaaf <danny.al-gaaf@bisect.de>

diff --git a/qa/workunits/direct_io/test_sync_io.c b/qa/workunits/direct_io/test_sync_io.c
index 59d32cf972a9c3dfc279056be4cad68186c2a016..f393fa6e8ffd79072468e4a7878bad1655bd3a29 100644 (file)
--- a/qa/workunits/direct_io/test_sync_io.c
+++ b/qa/workunits/direct_io/test_sync_io.c
@@ -31,6 +31,11 @@ void write_pattern()
        }
        for (i=0; i<1048576 * sizeof(i); i += sizeof(i)) {
                r = write(fd, &i, sizeof(i));
+               if (r == -1) {
+                       r = errno;
+                       printf("write_pattern: error: write() failed with: %d (%s)\n", r, strerror(r));
+                       break;
+               }
        }
 
        close(fd);
@@ -69,6 +74,8 @@ int read_file(int buf_align, uint64_t offset, int len, int direct) {
        void *rawbuf;
        int r;
         int flags;
+       int err = 0;
+
        if(direct)
           flags = O_RDONLY|O_DIRECT;
        else
@@ -76,7 +83,7 @@ int read_file(int buf_align, uint64_t offset, int len, int direct) {
 
        int fd = open("foo", flags);
        if (fd < 0) {
-          int err = errno;
+          err = errno;
           printf("read_file: error: open() failed with: %d (%s)\n", err, strerror(err));
           exit(err);
        }
@@ -86,14 +93,22 @@ int read_file(int buf_align, uint64_t offset, int len, int direct) {
 
        if ((r = posix_memalign(&rawbuf, 4096, len + buf_align)) != 0) {
           printf("read_file: error: posix_memalign failed with %d", r);
+          close(fd);
           exit (r);
        }
 
        void *buf = (char *)rawbuf + buf_align;
        memset(buf, 0, len);
        r = pread(fd, buf, len, offset);
-       close(fd);
+       if (r == -1) {
+          err = errno;
+          printf("read_file: error: pread() failed with: %d (%s)\n", err, strerror(err));
+          goto out;
+       }
        r = verify_pattern(buf, len, offset);
+
+out:
+       close(fd);
        free(rawbuf);
        return r;
 }
@@ -164,8 +179,14 @@ int write_file(int buf_align, uint64_t offset, int len, int direct)
 
        memset(buf2, 0, len);
        r = pread(fd, buf2, len, offset);
+       if (r == -1) {
+          err = errno;
+          printf("write_file: error: pread() failed with: %d (%s)\n", err, strerror(err));
+          goto out_free_buf;
+       }
        r = verify_pattern(buf2, len, offset);
 
+out_free_buf:
        free(buf2);
 out_free:
        free(rawbuf);