Fix return value.
[kopensolaris-gnu/glibc.git] / rt / tst-aio.c
index e319dea..a6c0762 100644 (file)
 #include <sys/stat.h>
 
 
-/* prototype for our test function.  */
+/* Prototype for our test function.  */
+extern void do_prepare (int argc, char *argv[]);
 extern int do_test (int argc, char *argv[]);
 
+/* We have a preparation function.  */
+#define PREPARE do_prepare
 
 /* We might need a bit longer timeout.  */
 #define TIMEOUT 20 /* sec */
@@ -37,6 +40,28 @@ extern int do_test (int argc, char *argv[]);
 #include <test-skeleton.c>
 
 
+/* These are for the temporary file we generate.  */
+char *name;
+int fd;
+
+void
+do_prepare (int argc, char *argv[])
+{
+  char name_len;
+
+  name_len = strlen (test_dir);
+  name = malloc (name_len + sizeof ("/aioXXXXXX"));
+  mempcpy (mempcpy (name, test_dir, name_len),
+          "/aioXXXXXX", sizeof ("/aioXXXXXX"));
+  add_temp_file (name);
+
+  /* Open our test file.   */
+  fd = mkstemp (name);
+  if (fd == -1)
+    error (EXIT_FAILURE, errno, "cannot open test file `%s'", name);
+}
+
+
 int
 test_file (const void *buf, size_t size, int fd, const char *msg)
 {
@@ -69,39 +94,40 @@ test_file (const void *buf, size_t size, int fd, const char *msg)
       return 1;
     }
 
-  if (ftruncate (fd, 0) < 0)
-    {
-      error (0, errno, "%s: failed truncate", msg);
-      return 1;
-    }
+  printf ("%s test ok\n", msg);
 
   return 0;
 }
 
 
+void
+do_wait (struct aiocb **cbp, size_t nent)
+{
+  int go_on;
+  do
+    {
+      size_t cnt;
+
+      aio_suspend ((const struct aiocb *const *) cbp, nent, NULL);
+      go_on = 0;
+      for (cnt = 0; cnt < nent; ++cnt)
+       if (cbp[cnt] != NULL && aio_error (cbp[cnt]) == EINPROGRESS)
+         go_on = 1;
+       else
+         cbp[cnt] = NULL;
+    }
+  while (go_on);
+}
+
+
 int
 do_test (int argc, char *argv[])
 {
-  char *name;
-  char name_len;
   struct aiocb cbs[10];
   struct aiocb *cbp[10];
   char buf[1000];
   size_t cnt;
-  int fd;
   int result = 0;
-  int go_on;
-
-  name_len = strlen (test_dir);
-  name = malloc (name_len + sizeof ("/aioXXXXXX"));
-  mempcpy (mempcpy (name, test_dir, name_len),
-          "/aioXXXXXX", sizeof ("/aioXXXXXX"));
-  add_temp_file (name);
-
-  /* Open our test file.   */
-  fd = mkstemp (name);
-  if (fd == -1)
-    error (EXIT_FAILURE, errno, "cannot open test file `%s'", name);
 
   /* Preparation.  */
   for (cnt = 0; cnt < 10; ++cnt)
@@ -120,23 +146,50 @@ do_test (int argc, char *argv[])
   for (cnt = 10; cnt > 0; )
     aio_write (cbp[--cnt]);
   /* Wait 'til the results are there.  */
-  do
+  do_wait (cbp, 10);
+  /* Test this.  */
+  result |= test_file (buf, sizeof (buf), fd, "aio_write");
+
+  /* Read now as we've written it.  */
+  memset (buf, '\0', sizeof (buf));
+  /* Issue the commands.  */
+  for (cnt = 10; cnt > 0; )
     {
-      aio_suspend ((const struct aiocb *const *) cbp, 10, NULL);
-      go_on = 0;
-      for (cnt = 0; cnt < 10; ++cnt)
-       if (cbp[cnt] != NULL && aio_error (cbp[cnt]) == EINPROGRESS)
-         go_on = 1;
-       else
-         {
-           if (cbp[cnt] != NULL)
-             printf ("request %d finished\n", cnt);
-           cbp[cnt] = NULL;
-         }
+      --cnt;
+      cbp[cnt] = &cbs[cnt];
+      aio_read (cbp[cnt]);
     }
-  while (go_on);
+  /* Wait 'til the results are there.  */
+  do_wait (cbp, 10);
   /* Test this.  */
-  result |= test_file (buf, sizeof (buf), fd, "aio_write");
+  for (cnt = 0; cnt < 1000; ++cnt)
+    if (buf[cnt] != '0' + (cnt / 100))
+      {
+       result = 1;
+       error (0, 0, "comparison failed for aio_read test");
+       break;
+      }
+
+  if (cnt == 1000)
+    puts ("aio_read test ok");
+
+  /* Remove the test file contents.  */
+  if (ftruncate (fd, 0) < 0)
+    {
+      error (0, errno, "ftruncate failed\n");
+      result = 1;
+    }
+
+  /* Test lio_listio.  */
+  for (cnt = 0; cnt < 10; ++cnt)
+    {
+      cbs[cnt].aio_lio_opcode = LIO_WRITE;
+      cbp[cnt] = &cbs[cnt];
+    }
+  /* Issue the command.  */
+  lio_listio (LIO_WAIT, cbp, 10, NULL);
+  /* ...and immediately test it since we started it in wait mode.  */
+  result |= test_file (buf, sizeof (buf), fd, "lio_listio (write)");
 
   return result;
 }