libeio - example: cp

#include <ev.h> #include <eio.h> #include <stdlib.h> #include <stdio.h> #include <fcntl.h> static struct ev_loop* loop; static ev_idle repeat_watcher; static ev_async ready_watcher; static const char* src; static const char* dst; struct file_copy { int srcfd; int dstfd; int offset; char buffer[1024]; }; int srcfd; int dstfd; int offset; char buffer[1024]; static int copy(struct file_copy* data); void end_copy(struct file_copy* data) { free(data); ev_break(loop, EVUNLOOP_ALL); } static int write_done(eio_req* req) { struct file_copy* data = (struct file_copy*)req->data; if (req->result < 0) { perror("failed to copy"); end_copy(data); } else { printf("write %d bytes\n", req->result); data->offset += req->result; copy(data); } } static int read_done(eio_req* req) { struct file_copy* data = (struct file_copy*)req->data; if (req->result < 0) { perror("failed to copy"); end_copy(data); } else if (req->result == 0) { printf("file copy done\n"); eio_close(data->srcfd, 0, 0, 0); eio_close(data->dstfd, 0, 0, 0); end_copy(data); } else { printf("read %d bytes\n", req->result); eio_write(data->dstfd, data->buffer, req->result, data->offset, 0, write_done, data); } } static int copy(struct file_copy* data) { eio_read(data->srcfd, data->buffer, sizeof(data->buffer), data->offset, 0, read_done, data); } static int dst_open_done(eio_req* req) { printf("target file open done\n"); // file descriptor dstfd = req->result; // copy struct file_copy* data = malloc(sizeof(struct file_copy)); data->srcfd = srcfd; data->dstfd = dstfd; data->offset = 0; copy(data); } static int src_open_done(eio_req* req) { printf("source file open done\n"); // file descriptor srcfd = req->result; // open dest file eio_open(dst, O_CREAT | O_WRONLY, 0, 0, dst_open_done, 0); } void eio_copy() { printf("eio_copy\n"); // open source file eio_open(src, O_RDONLY, 0, 0, src_open_done, 0); } static void repeat(EV_P_ ev_idle* w, int revent) { printf("repeat\n"); if (eio_poll() != -1) { ev_idle_stop(EV_A_ w); } } static void ready(EV_P_ ev_async* w, int revents) { printf("ready\n"); if (eio_poll() == -1) { ev_idle_start(EV_A_ &repeat_watcher); } } static void want_poll(void) { printf("want_poll\n"); ev_async_send(loop, &ready_watcher); } //static void timeout(EV_P_ ev_timer* w, int revents) void init_eio() { printf("timer\n"); // init eio ev_idle_init(&repeat_watcher, repeat); ev_async_init(&ready_watcher, ready); ev_async_start(EV_A_ &ready_watcher); eio_init(want_poll, 0); // copy file eio_copy(); } int main(int argc, char* argv[]) { if (argc != 3) { fprintf(stderr, "usage: cp <source> <target>\n"); exit(0); } src = argv[1]; dst = argv[2]; // use the default event loop loop = ev_default_loop(0); // init eio init_eio(); // event loop ev_run(loop, 0); return 0; }