X-Git-Url: http://git.ozlabs.org/?a=blobdiff_plain;f=ccan%2Fio%2Fbackend.h;h=2ee5a830e1233bd614d916d73d7087a9f9ec7cea;hb=9f06b8f85927202c05751e43f285cbef8054052b;hp=3a1f12e7ee859742b0341912de41044c5416b61b;hpb=f3c92802bfdb388f8c191cd1c682f90bc485b357;p=ccan diff --git a/ccan/io/backend.h b/ccan/io/backend.h index 3a1f12e7..2ee5a830 100644 --- a/ccan/io/backend.h +++ b/ccan/io/backend.h @@ -2,7 +2,6 @@ #ifndef CCAN_IO_BACKEND_H #define CCAN_IO_BACKEND_H #include -#include #include "io_plan.h" #include @@ -26,14 +25,13 @@ struct io_listener { enum io_plan_status { /* As before calling next function. */ IO_UNSET, - /* Normal. */ - IO_POLLING, + /* Normal, but haven't started yet. */ + IO_POLLING_NOTSTARTED, + IO_POLLING_STARTED, /* Waiting for io_wake */ IO_WAITING, /* Always do this. */ - IO_ALWAYS, - /* Closing (both plans will be the same). */ - IO_CLOSING + IO_ALWAYS }; /** @@ -59,12 +57,9 @@ struct io_plan { /* One connection per client. */ struct io_conn { struct fd fd; - bool debug; - /* For duplex to save. */ - bool debug_saved; - /* always and closing lists. */ - struct list_node always, closing; + /* always list. */ + struct list_node always; void (*finish)(struct io_conn *, void *arg); void *finish_arg; @@ -78,14 +73,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);