X-Git-Url: http://git.ozlabs.org/?p=ccan;a=blobdiff_plain;f=ccan%2Fio%2Fio.c;h=b3c4c760eb445f4ed6c188de08dd7bbad4cd2b22;hp=84be1758330e61481638ce31d72826799089f81b;hb=e2ce04eac30ec613c858bd4cd2ca12e1c464edb8;hpb=bfb80c566ab695b70a404a419f4b1450a2fcf27a diff --git a/ccan/io/io.c b/ccan/io/io.c index 84be1758..b3c4c760 100644 --- a/ccan/io/io.c +++ b/ccan/io/io.c @@ -12,10 +12,47 @@ void *io_loop_return; +#ifdef DEBUG +bool io_plan_for_other; +struct io_conn *current; +bool (*io_debug)(struct io_conn *conn); +bool io_debug_wakeup; + +void io_plan_debug(struct io_plan *plan) +{ + if (io_plan_for_other) { + io_plan_for_other = false; + return; + } + + if (!io_debug || !current) + return; + + if (!io_debug(current) && !io_debug_wakeup) + return; + + io_debug_wakeup = false; + current->plan = *plan; + backend_plan_changed(current); + + /* Call back into the loop immediately. */ + io_loop_return = io_loop(); +} + +static void debug_io_wake(struct io_conn *conn) +{ + /* We want linear if we wake a debugged connection, too. */ + if (io_debug && io_debug(conn)) + io_debug_wakeup = true; +} +#else +static void debug_io_wake(struct io_conn *conn) +{ +} +#endif + struct io_listener *io_new_listener_(int fd, - struct io_plan *(*start)(struct io_conn *, - void *arg), - void (*finish)(struct io_conn *, void *), + void (*init)(int fd, void *arg), void *arg) { struct io_listener *l = malloc(sizeof(*l)); @@ -25,9 +62,8 @@ struct io_listener *io_new_listener_(int fd, l->fd.listener = true; l->fd.fd = fd; - l->next = start; - l->finish = finish; - l->conn_arg = arg; + l->init = init; + l->arg = arg; if (!add_listener(l)) { free(l); return NULL; @@ -43,7 +79,7 @@ void io_close_listener(struct io_listener *l) } struct io_conn *io_new_conn_(int fd, - struct io_plan *(*start)(struct io_conn *, void *), + struct io_plan plan, void (*finish)(struct io_conn *, void *), void *arg) { @@ -54,11 +90,9 @@ struct io_conn *io_new_conn_(int fd, conn->fd.listener = false; conn->fd.fd = fd; - conn->next = start; + conn->plan = plan; conn->finish = finish; - conn->finish_arg = conn->next_arg = arg; - conn->pollflag = 0; - conn->state = NEXT; + conn->finish_arg = arg; conn->duplex = NULL; conn->timeout = NULL; if (!add_conn(conn)) { @@ -69,9 +103,9 @@ struct io_conn *io_new_conn_(int fd, } struct io_conn *io_duplex_(struct io_conn *old, - struct io_plan *(*start)(struct io_conn *, void *), - void (*finish)(struct io_conn *, void *), - void *arg) + struct io_plan plan, + void (*finish)(struct io_conn *, void *), + void *arg) { struct io_conn *conn; @@ -83,12 +117,10 @@ struct io_conn *io_duplex_(struct io_conn *old, conn->fd.listener = false; conn->fd.fd = old->fd.fd; - conn->next = start; - conn->finish = finish; - conn->finish_arg = conn->next_arg = arg; - conn->pollflag = 0; - conn->state = NEXT; + conn->plan = plan; conn->duplex = old; + conn->finish = finish; + conn->finish_arg = arg; conn->timeout = NULL; if (!add_duplex(conn)) { free(conn); @@ -98,14 +130,11 @@ struct io_conn *io_duplex_(struct io_conn *old, return conn; } -static inline struct io_plan *to_ioplan(enum io_state state) -{ - return (struct io_plan *)(long)state; -} - bool io_timeout_(struct io_conn *conn, struct timespec ts, - struct io_plan *(*cb)(struct io_conn *, void *), void *arg) + struct io_plan (*cb)(struct io_conn *, void *), void *arg) { + assert(cb); + if (!conn->timeout) { conn->timeout = malloc(sizeof(*conn->timeout)); if (!conn->timeout) @@ -119,166 +148,195 @@ bool io_timeout_(struct io_conn *conn, struct timespec ts, return true; } -static enum io_result do_write(struct io_conn *conn) +/* Returns true if we're finished. */ +static bool do_write(int fd, struct io_plan *plan) { - ssize_t ret = write(conn->fd.fd, conn->u.write.buf, conn->u.write.len); - if (ret < 0) - return RESULT_CLOSE; - - conn->u.write.buf += ret; - conn->u.write.len -= ret; - if (conn->u.write.len == 0) - return RESULT_FINISHED; - else - return RESULT_AGAIN; + ssize_t ret = write(fd, plan->u.write.buf, plan->u.write.len); + if (ret < 0) { + /* Override next function to close us. */ + plan->next = io_close; + return true; + } + + plan->u.write.buf += ret; + plan->u.write.len -= ret; + return (plan->u.write.len == 0); } /* Queue some data to be written. */ -struct io_plan *io_write_(struct io_conn *conn, const void *data, size_t len, - struct io_plan *(*cb)(struct io_conn *, void *), - void *arg) +struct io_plan io_write_(const void *data, size_t len, + struct io_plan (*cb)(struct io_conn *, void *), + void *arg) { - conn->u.write.buf = data; - conn->u.write.len = len; - conn->io = do_write; - conn->next = cb; - conn->next_arg = arg; - conn->pollflag = POLLOUT; - return to_ioplan(IO); + struct io_plan plan; + + assert(cb); + plan.u.write.buf = data; + plan.u.write.len = len; + plan.io = do_write; + plan.next = cb; + plan.next_arg = arg; + plan.pollflag = POLLOUT; + + io_plan_debug(&plan); + return plan; } -static enum io_result do_read(struct io_conn *conn) +static bool do_read(int fd, struct io_plan *plan) { - ssize_t ret = read(conn->fd.fd, conn->u.read.buf, conn->u.read.len); - if (ret <= 0) - return RESULT_CLOSE; - conn->u.read.buf += ret; - conn->u.read.len -= ret; - if (conn->u.read.len == 0) - return RESULT_FINISHED; - else - return RESULT_AGAIN; + ssize_t ret = read(fd, plan->u.read.buf, plan->u.read.len); + if (ret <= 0) { + /* Override next function to close us. */ + plan->next = io_close; + return true; + } + + plan->u.read.buf += ret; + plan->u.read.len -= ret; + return (plan->u.read.len == 0); } /* Queue a request to read into a buffer. */ -struct io_plan *io_read_(struct io_conn *conn, void *data, size_t len, - struct io_plan *(*cb)(struct io_conn *, void *), - void *arg) +struct io_plan io_read_(void *data, size_t len, + struct io_plan (*cb)(struct io_conn *, void *), + void *arg) { - conn->u.read.buf = data; - conn->u.read.len = len; - conn->io = do_read; - conn->next = cb; - conn->next_arg = arg; - conn->pollflag = POLLIN; - return to_ioplan(IO); + struct io_plan plan; + + assert(cb); + plan.u.read.buf = data; + plan.u.read.len = len; + plan.io = do_read; + plan.next = cb; + plan.next_arg = arg; + plan.pollflag = POLLIN; + + io_plan_debug(&plan); + return plan; } -static enum io_result do_read_partial(struct io_conn *conn) +static bool do_read_partial(int fd, struct io_plan *plan) { - ssize_t ret = read(conn->fd.fd, conn->u.readpart.buf, - *conn->u.readpart.lenp); - if (ret <= 0) - return RESULT_CLOSE; - *conn->u.readpart.lenp = ret; - return RESULT_FINISHED; + ssize_t ret = read(fd, plan->u.readpart.buf, *plan->u.readpart.lenp); + if (ret <= 0) { + /* Override next function to close us. */ + plan->next = io_close; + return true; + } + + *plan->u.readpart.lenp = ret; + return true; } /* Queue a partial request to read into a buffer. */ -struct io_plan *io_read_partial_(struct io_conn *conn, void *data, size_t *len, - struct io_plan *(*cb)(struct io_conn *, void *), - void *arg) +struct io_plan io_read_partial_(void *data, size_t *len, + struct io_plan (*cb)(struct io_conn *, void *), + void *arg) { - conn->u.readpart.buf = data; - conn->u.readpart.lenp = len; - conn->io = do_read_partial; - conn->next = cb; - conn->next_arg = arg; - conn->pollflag = POLLIN; - return to_ioplan(IO); + struct io_plan plan; + + assert(cb); + plan.u.readpart.buf = data; + plan.u.readpart.lenp = len; + plan.io = do_read_partial; + plan.next = cb; + plan.next_arg = arg; + plan.pollflag = POLLIN; + + io_plan_debug(&plan); + return plan; } -static enum io_result do_write_partial(struct io_conn *conn) +static bool do_write_partial(int fd, struct io_plan *plan) { - ssize_t ret = write(conn->fd.fd, conn->u.writepart.buf, - *conn->u.writepart.lenp); - if (ret < 0) - return RESULT_CLOSE; - *conn->u.writepart.lenp = ret; - return RESULT_FINISHED; + ssize_t ret = write(fd, plan->u.writepart.buf, *plan->u.writepart.lenp); + if (ret < 0) { + /* Override next function to close us. */ + plan->next = io_close; + return true; + } + + *plan->u.writepart.lenp = ret; + return true; } /* Queue a partial write request. */ -struct io_plan *io_write_partial_(struct io_conn *conn, - const void *data, size_t *len, - struct io_plan *(*cb)(struct io_conn*, void *), - void *arg) +struct io_plan io_write_partial_(const void *data, size_t *len, + struct io_plan (*cb)(struct io_conn*, void *), + void *arg) { - conn->u.writepart.buf = data; - conn->u.writepart.lenp = len; - conn->io = do_write_partial; - conn->next = cb; - conn->next_arg = arg; - conn->pollflag = POLLOUT; - return to_ioplan(IO); + struct io_plan plan; + + assert(cb); + plan.u.writepart.buf = data; + plan.u.writepart.lenp = len; + plan.io = do_write_partial; + plan.next = cb; + plan.next_arg = arg; + plan.pollflag = POLLOUT; + + io_plan_debug(&plan); + return plan; } -struct io_plan *io_idle(struct io_conn *conn) +struct io_plan io_idle(void) { - conn->pollflag = 0; - return to_ioplan(IDLE); + struct io_plan plan; + + plan.pollflag = 0; + plan.io = NULL; + /* Never called (overridded by io_wake), but NULL means closing */ + plan.next = io_close; + + io_plan_debug(&plan); + return plan; } -void io_wake_(struct io_conn *conn, - struct io_plan *(*fn)(struct io_conn *, void *), void *arg) +void io_wake_(struct io_conn *conn, struct io_plan plan) { - /* It might have finished, but we haven't called its finish() yet. */ - if (conn->state == FINISHED) + /* It might be closing, but we haven't called its finish() yet. */ + if (!conn->plan.next) return; - assert(conn->state == IDLE); - conn->next = fn; - conn->next_arg = arg; - backend_set_state(conn, to_ioplan(NEXT)); -} + /* It was idle, right? */ + assert(!conn->plan.io); + conn->plan = plan; + backend_plan_changed(conn); -static struct io_plan *do_next(struct io_conn *conn) -{ - if (timeout_active(conn)) - backend_del_timeout(conn); - return conn->next(conn, conn->next_arg); + debug_io_wake(conn); } -struct io_plan *do_ready(struct io_conn *conn) +void io_ready(struct io_conn *conn) { - assert(conn->state == IO); - switch (conn->io(conn)) { - case RESULT_CLOSE: - return io_close(conn, NULL); - case RESULT_FINISHED: - return do_next(conn); - case RESULT_AGAIN: - return to_ioplan(conn->state); - default: - abort(); + if (conn->plan.io(conn->fd.fd, &conn->plan)) { + set_current(conn); + if (timeout_active(conn)) + backend_del_timeout(conn); + conn->plan = conn->plan.next(conn, conn->plan.next_arg); + backend_plan_changed(conn); + set_current(NULL); } } /* Useful next functions. */ /* Close the connection, we're done. */ -struct io_plan *io_close(struct io_conn *conn, void *arg) +struct io_plan io_close(struct io_conn *conn, void *arg) { - return to_ioplan(FINISHED); + struct io_plan plan; + + plan.pollflag = 0; + /* This means we're closing. */ + plan.next = NULL; + + io_plan_debug(&plan); + return plan; } /* Exit the loop, returning this (non-NULL) arg. */ -struct io_plan *io_break_(struct io_conn *conn, void *ret, - struct io_plan *(*fn)(struct io_conn *, void *), - void *arg) +struct io_plan io_break_(void *ret, struct io_plan plan) { + assert(ret); io_loop_return = ret; - conn->next = fn; - conn->next_arg = arg; - return to_ioplan(NEXT); + return plan; }