*** empty log message ***rel-3_02

1 files changed, 223 insertions, 0 deletions

diff --git a/demo.c b/demo.c
new file mode 100644
index 0000000..a21d5cb
--- /dev/null
+++ b/demo.c
@@ -0,0 +1,223 @@
+#include <stdio.h>
+#include <stdlib.h>
+#include <unistd.h>
+#include <poll.h>
+#include <string.h>
+#include <assert.h>
+#include <fcntl.h>
+#include <sys/types.h>
+#include <sys/stat.h>
+
+#include "eio.h"
+
+int respipe [2];
+
+void
+want_poll (void)
+{
+  char dummy;
+  printf ("want_poll ()\n");
+  write (respipe [1], &dummy, 1);
+}
+
+void
+done_poll (void)
+{
+  char dummy;
+  printf ("done_poll ()\n");
+  read (respipe [0], &dummy, 1);
+}
+
+void
+event_loop (void)
+{
+  // an event loop. yeah.
+  struct pollfd pfd;
+  pfd.fd     = respipe [0];
+  pfd.events = POLLIN;
+
+  printf ("\nentering event loop\n");
+  while (eio_nreqs ())
+    {
+      poll (&pfd, 1, -1);
+      printf ("eio_poll () = %d\n", eio_poll ());
+    }
+  printf ("leaving event loop\n");
+}
+
+int
+res_cb (eio_req *req)
+{
+  printf ("res_cb(%d|%s) = %d\n", req->type, req->data ? req->data : "?", EIO_RESULT (req));
+
+  if (req->result < 0)
+    abort ();
+
+  return 0;
+}
+
+int
+readdir_cb (eio_req *req)
+{
+  char *buf = (char *)EIO_BUF (req);
+
+  printf ("readdir_cb = %d\n", EIO_RESULT (req));
+
+  if (EIO_RESULT (req) < 0)
+    return 0;
+
+  while (EIO_RESULT (req)--)
+    {
+      printf ("readdir = <%s>\n", buf);
+      buf += strlen (buf) + 1;
+    }
+
+  return 0;
+}
+
+int
+stat_cb (eio_req *req)
+{
+  struct stat *buf = EIO_STAT_BUF (req);
+
+  if (req->type == EIO_FSTAT)
+    printf ("fstat_cb = %d\n", EIO_RESULT (req));
+  else
+    printf ("stat_cb(%s) = %d\n", EIO_PATH (req), EIO_RESULT (req));
+
+  if (!EIO_RESULT (req))
+    printf ("stat size %d perm 0%o\n", buf->st_size, buf->st_mode & 0777);
+
+  return 0;
+}
+
+int
+read_cb (eio_req *req)
+{
+  unsigned char *buf = (unsigned char *)EIO_BUF (req);
+
+  printf ("read_cb = %d (%02x%02x%02x%02x %02x%02x%02x%02x)\n",
+          EIO_RESULT (req),
+          buf [0], buf [1], buf [2], buf [3],
+          buf [4], buf [5], buf [6], buf [7]);
+
+  return 0;
+}
+
+int last_fd;
+
+int
+open_cb (eio_req *req)
+{
+  printf ("open_cb = %d\n", EIO_RESULT (req));
+
+  last_fd = EIO_RESULT (req);
+
+  return 0;
+}
+
+int
+main (void)
+{
+  printf ("pipe ()\n");
+  if (pipe (respipe)) abort ();
+
+  printf ("eio_init ()\n");
+  if (eio_init (want_poll, done_poll)) abort ();
+
+  do
+    {
+      /* avoid relative paths yourself(!) */
+      eio_mkdir ("eio-test-dir", 0777, res_cb)
+        ->data = "mkdir";
+      eio_nop (res_cb)
+        ->data = "nop";
+      event_loop ();
+
+      eio_stat ("eio-test-dir", stat_cb);
+      eio_lstat ("eio-test-dir", stat_cb);
+      eio_open ("eio-test-dir/eio-test-file", O_RDWR | O_CREAT, 0777, open_cb);
+      eio_symlink ("test", "eio-test-dir/eio-symlink", res_cb)
+        ->data = "symlink";
+      eio_mknod ("eio-test-dir/eio-fifo", S_IFIFO, 0, res_cb)
+        ->data = "mknod";
+      event_loop ();
+
+      eio_utime ("eio-test-dir", 12345.678, 23456.789, res_cb)
+        ->data = "utime";
+      eio_futime (last_fd, 92345.678, 93456.789, res_cb)
+        ->data = "futime";
+      eio_chown ("eio-test-dir", getuid (), getgid (), res_cb)
+        ->data = "chown";
+      eio_fchown (last_fd, getuid (), getgid (), res_cb)
+        ->data = "fchown";
+      eio_fchmod (last_fd, 0123, res_cb)
+        ->data = "fchmod";
+      eio_readdir ("eio-test-dir", readdir_cb);
+      eio_readdir ("/nonexistant", readdir_cb);
+      eio_fstat (last_fd, stat_cb);
+      eio_write (last_fd, "test\nfail\n", 10, 4, res_cb)
+        ->data = "write";
+      event_loop ();
+
+      eio_read (last_fd, 0, 8, 0, read_cb);
+      eio_readlink ("eio-test-dir/eio-symlink", res_cb)
+        ->data = "readlink";
+      event_loop ();
+
+      eio_dup2 (1, 2, res_cb) // dup stdout to stderr
+        ->data = "dup2";
+      eio_chmod ("eio-test-dir", 0765, res_cb)
+        ->data = "chmod";
+      eio_ftruncate (last_fd, 9, res_cb)
+        ->data = "ftruncate";
+      eio_fdatasync (last_fd, res_cb)
+        ->data = "fdatasync";
+      eio_fsync (last_fd, res_cb)
+        ->data = "fsync";
+      eio_sync (res_cb)
+        ->data = "sync";
+      eio_busy (0.5, res_cb)
+        ->data = "busy";
+      event_loop ();
+
+      eio_sendfile (1, last_fd, 4, 5, res_cb) // write "test\n" to stdout
+        ->data = "sendfile";
+      eio_fstat (last_fd, stat_cb);
+      event_loop ();
+
+      eio_truncate ("eio-test-dir/eio-test-file", 6, res_cb)
+        ->data = "truncate";
+      eio_readahead (last_fd, 0, 64, res_cb)
+        ->data = "readahead";
+      event_loop ();
+
+      eio_close (last_fd, res_cb)
+        ->data = "close";
+      eio_link ("eio-test-dir/eio-test-file", "eio-test-dir/eio-test-file-2", res_cb)
+        ->data = "link";
+      event_loop ();
+
+      eio_rename ("eio-test-dir/eio-test-file", "eio-test-dir/eio-test-file-renamed", res_cb)
+        ->data = "rename";
+      event_loop ();
+
+      eio_unlink ("eio-test-dir/eio-fifo", res_cb)
+        ->data = "unlink";
+      eio_unlink ("eio-test-dir/eio-symlink", res_cb)
+        ->data = "unlink";
+      eio_unlink ("eio-test-dir/eio-test-file-2", res_cb)
+        ->data = "unlink";
+      eio_unlink ("eio-test-dir/eio-test-file-renamed", res_cb)
+        ->data = "unlink";
+      event_loop ();
+
+      eio_rmdir ("eio-test-dir", res_cb)
+        ->data = "rmdir";
+      event_loop ();
+    }
+  while (0);
+
+  return 0;
+}
+