diff options
Diffstat (limited to 'demo.c')
| -rw-r--r-- | demo.c | 223 |
1 files changed, 223 insertions, 0 deletions
@@ -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; +} + |