X-Git-Url: http://git.ozlabs.org/?p=ccan;a=blobdiff_plain;f=ccan%2Fio%2Fio.c;h=a4489ee8855c5a67fce5d746672342b345c72dc5;hp=5ea90ea7b03437cd7a7a5e69210a6fc85a8a1363;hb=9e02685a6216720d37848a332187e3745b7f981e;hpb=737705f0c2ec60ea5b51ca55299488d86db37b5d diff --git a/ccan/io/io.c b/ccan/io/io.c index 5ea90ea7..a4489ee8 100644 --- a/ccan/io/io.c +++ b/ccan/io/io.c @@ -12,6 +12,59 @@ void *io_loop_return; +#ifdef DEBUG +/* Set to skip the next plan. */ +bool io_plan_nodebug; +/* The current connection to apply plan to. */ +struct io_conn *current; +/* User-defined function to select which connection(s) to debug. */ +bool (*io_debug_conn)(struct io_conn *conn); +/* Set when we wake up an connection we are debugging. */ +bool io_debug_wakeup; + +struct io_plan io_debug(struct io_plan plan) +{ + if (io_plan_nodebug) { + io_plan_nodebug = false; + return plan; + } + + if (!io_debug_conn || !current) + return plan; + + if (!io_debug_conn(current) && !io_debug_wakeup) + return plan; + + io_debug_wakeup = false; + current->plan = plan; + backend_plan_changed(current); + + /* Call back into the loop immediately. */ + io_loop_return = io_loop(); + return plan; +} + +static void debug_io_wake(struct io_conn *conn) +{ + /* We want linear if we wake a debugged connection, too. */ + if (io_debug_conn && io_debug_conn(conn)) + io_debug_wakeup = true; +} + +/* Counterpart to io_plan_no_debug(), called in macros in io.h */ +static void io_plan_debug_again(void) +{ + io_plan_nodebug = false; +} +#else +static void debug_io_wake(struct io_conn *conn) +{ +} +static void io_plan_debug_again(void) +{ +} +#endif + struct io_listener *io_new_listener_(int fd, void (*init)(int fd, void *arg), void *arg) @@ -39,23 +92,20 @@ void io_close_listener(struct io_listener *l) free(l); } -struct io_conn *io_new_conn_(int fd, - struct io_plan (*start)(struct io_conn *, void *), - void (*finish)(struct io_conn *, void *), - void *arg) +struct io_conn *io_new_conn_(int fd, struct io_plan plan) { struct io_conn *conn = malloc(sizeof(*conn)); + io_plan_debug_again(); + if (!conn) return NULL; conn->fd.listener = false; conn->fd.fd = fd; - conn->plan.next = start; - conn->finish = finish; - conn->finish_arg = conn->plan.next_arg = arg; - conn->plan.pollflag = 0; - conn->plan.state = IO_NEXT; + conn->plan = plan; + conn->finish = NULL; + conn->finish_arg = NULL; conn->duplex = NULL; conn->timeout = NULL; if (!add_conn(conn)) { @@ -65,13 +115,20 @@ struct io_conn *io_new_conn_(int fd, return conn; } -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) +void io_set_finish_(struct io_conn *conn, + void (*finish)(struct io_conn *, void *), + void *arg) +{ + conn->finish = finish; + conn->finish_arg = arg; +} + +struct io_conn *io_duplex_(struct io_conn *old, struct io_plan plan) { struct io_conn *conn; + io_plan_debug_again(); + assert(!old->duplex); conn = malloc(sizeof(*conn)); @@ -80,12 +137,10 @@ struct io_conn *io_duplex_(struct io_conn *old, conn->fd.listener = false; conn->fd.fd = old->fd.fd; - conn->plan.next = start; - conn->finish = finish; - conn->finish_arg = conn->plan.next_arg = arg; - conn->plan.pollflag = 0; - conn->plan.state = IO_NEXT; + conn->plan = plan; conn->duplex = old; + conn->finish = NULL; + conn->finish_arg = NULL; conn->timeout = NULL; if (!add_duplex(conn)) { free(conn); @@ -98,6 +153,8 @@ struct io_conn *io_duplex_(struct io_conn *old, bool io_timeout_(struct io_conn *conn, struct timespec ts, struct io_plan (*cb)(struct io_conn *, void *), void *arg) { + assert(cb); + if (!conn->timeout) { conn->timeout = malloc(sizeof(*conn->timeout)); if (!conn->timeout) @@ -111,18 +168,16 @@ 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 int do_write(int fd, struct io_plan *plan) { - ssize_t ret = write(conn->fd.fd, conn->plan.u.write.buf, conn->plan.u.write.len); + ssize_t ret = write(fd, plan->u.write.buf, plan->u.write.len); if (ret < 0) - return RESULT_CLOSE; - - conn->plan.u.write.buf += ret; - conn->plan.u.write.len -= ret; - if (conn->plan.u.write.len == 0) - return RESULT_FINISHED; - else - return RESULT_AGAIN; + return -1; + + plan->u.write.buf += ret; + plan->u.write.len -= ret; + return (plan->u.write.len == 0); } /* Queue some data to be written. */ @@ -132,28 +187,26 @@ struct io_plan io_write_(const void *data, size_t len, { 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; - plan.state = IO_IO; + return plan; } -static enum io_result do_read(struct io_conn *conn) +static int do_read(int fd, struct io_plan *plan) { - ssize_t ret = read(conn->fd.fd, conn->plan.u.read.buf, - conn->plan.u.read.len); + ssize_t ret = read(fd, plan->u.read.buf, plan->u.read.len); if (ret <= 0) - return RESULT_CLOSE; - conn->plan.u.read.buf += ret; - conn->plan.u.read.len -= ret; - if (conn->plan.u.read.len == 0) - return RESULT_FINISHED; - else - return RESULT_AGAIN; + return -1; + + plan->u.read.buf += ret; + plan->u.read.len -= ret; + return (plan->u.read.len == 0); } /* Queue a request to read into a buffer. */ @@ -163,24 +216,25 @@ struct io_plan io_read_(void *data, size_t len, { 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; - plan.state = IO_IO; + return plan; } -static enum io_result do_read_partial(struct io_conn *conn) +static int do_read_partial(int fd, struct io_plan *plan) { - ssize_t ret = read(conn->fd.fd, conn->plan.u.readpart.buf, - *conn->plan.u.readpart.lenp); + ssize_t ret = read(fd, plan->u.readpart.buf, *plan->u.readpart.lenp); if (ret <= 0) - return RESULT_CLOSE; - *conn->plan.u.readpart.lenp = ret; - return RESULT_FINISHED; + return -1; + + *plan->u.readpart.lenp = ret; + return 1; } /* Queue a partial request to read into a buffer. */ @@ -190,25 +244,25 @@ struct io_plan io_read_partial_(void *data, size_t *len, { 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; - plan.state = IO_IO; return plan; } -static enum io_result do_write_partial(struct io_conn *conn) +static int do_write_partial(int fd, struct io_plan *plan) { - ssize_t ret = write(conn->fd.fd, conn->plan.u.writepart.buf, - *conn->plan.u.writepart.lenp); + ssize_t ret = write(fd, plan->u.writepart.buf, *plan->u.writepart.lenp); if (ret < 0) - return RESULT_CLOSE; - *conn->plan.u.writepart.lenp = ret; - return RESULT_FINISHED; + return -1; + + *plan->u.writepart.lenp = ret; + return 1; } /* Queue a partial write request. */ @@ -218,89 +272,91 @@ struct io_plan io_write_partial_(const void *data, size_t *len, { 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; - plan.state = IO_IO; return plan; } -struct io_plan io_idle(void) +struct io_plan io_idle_(void) { struct io_plan plan; plan.pollflag = 0; - plan.state = IO_IDLE; + plan.io = NULL; + /* Never called (overridden by io_wake), but NULL means closing */ + plan.next = (void *)io_idle_; 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->plan.state == IO_FINISHED) + io_plan_debug_again(); + + /* It might be closing, but we haven't called its finish() yet. */ + if (!conn->plan.next) return; - assert(conn->plan.state == IO_IDLE); - conn->plan.next = fn; - conn->plan.next_arg = arg; - conn->plan.pollflag = 0; - conn->plan.state = IO_NEXT; - backend_wakeup(conn); -} + /* 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->plan.next(conn, conn->plan.next_arg); + debug_io_wake(conn); } -struct io_plan do_ready(struct io_conn *conn) +void io_ready(struct io_conn *conn) { - assert(conn->plan.state == IO_IO); - switch (conn->plan.io(conn)) { - case RESULT_CLOSE: - return io_close(conn, NULL); - case RESULT_FINISHED: - return do_next(conn); - case RESULT_AGAIN: - return conn->plan; - default: - abort(); + switch (conn->plan.io(conn->fd.fd, &conn->plan)) { + case -1: /* Failure means a new plan: close up. */ + set_current(conn); + conn->plan = io_close(); + backend_plan_changed(conn); + set_current(NULL); + break; + case 0: /* Keep going with plan. */ + break; + case 1: /* Done: get next 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_(void) { struct io_plan plan; - plan.state = IO_FINISHED; plan.pollflag = 0; + /* This means we're closing. */ + plan.next = NULL; + plan.u.close.saved_errno = errno; return plan; } +struct io_plan io_close_cb(struct io_conn *conn, void *arg) +{ + return io_close(); +} + /* Exit the loop, returning this (non-NULL) arg. */ -struct io_plan io_break_(void *ret, - struct io_plan (*fn)(struct io_conn *, void *), - void *arg) +struct io_plan io_break_(void *ret, struct io_plan plan) { - struct io_plan plan; + io_plan_debug_again(); + assert(ret); io_loop_return = ret; - plan.state = IO_NEXT; - plan.pollflag = 0; - plan.next = fn; - plan.next_arg = arg; - return plan; }