X-Git-Url: http://git.ozlabs.org/?p=ccan;a=blobdiff_plain;f=ccan%2Fio%2Fbackend.h;h=c8ceb4e864397c5e54c54fe20c3ceddaae2c9e20;hp=39605ec48662114944f184f4739848e1d2953c0d;hb=e846b1a93ecf096164ff2c4faaf4a89c24a0e76b;hpb=8d94c52a7d6a51fd3a95734b2b4c7daa8c687d91 diff --git a/ccan/io/backend.h b/ccan/io/backend.h index 39605ec4..c8ceb4e8 100644 --- a/ccan/io/backend.h +++ b/ccan/io/backend.h @@ -2,8 +2,8 @@ #ifndef CCAN_IO_BACKEND_H #define CCAN_IO_BACKEND_H #include -#include #include "io_plan.h" +#include struct fd { int fd; @@ -30,9 +30,7 @@ enum io_plan_status { /* Waiting for io_wake */ IO_WAITING, /* Always do this. */ - IO_ALWAYS, - /* Closing (both plans will be the same). */ - IO_CLOSING + IO_ALWAYS }; /** @@ -58,12 +56,9 @@ struct io_plan { /* One connection per client. */ struct io_conn { struct fd fd; - bool debug; - /* For duplex to save. */ - bool debug_saved; - /* always or closing list. */ - struct io_conn *list; + /* always list. */ + struct list_node always; void (*finish)(struct io_conn *, void *arg); void *finish_arg; @@ -77,14 +72,13 @@ bool add_listener(struct io_listener *l); bool add_conn(struct io_conn *c); bool add_duplex(struct io_conn *c); void del_listener(struct io_listener *l); -void backend_new_closing(struct io_conn *conn); +void cleanup_conn_without_close(struct io_conn *c); void backend_new_always(struct io_conn *conn); void backend_new_plan(struct io_conn *conn); void remove_from_always(struct io_conn *conn); void backend_plan_done(struct io_conn *conn); void backend_wake(const void *wait); -void backend_del_conn(struct io_conn *conn); void io_ready(struct io_conn *conn, int pollflags); void io_do_always(struct io_conn *conn);