X-Git-Url: http://git.ozlabs.org/?p=ccan;a=blobdiff_plain;f=ccan%2Fio%2Fio.c;h=a58b3f01a71f7526dba3f4e69fb987d8ebaea703;hp=54ba7da529ec433661163f2d01fb4ab335562fa8;hb=5a510ed5696255910fd42adb47d7c1ffa728a116;hpb=dbbefec6973725d9a16c82747e0c7ce8e5e6c4f2 diff --git a/ccan/io/io.c b/ccan/io/io.c index 54ba7da5..a58b3f01 100644 --- a/ccan/io/io.c +++ b/ccan/io/io.c @@ -46,12 +46,6 @@ struct io_plan io_debug(struct io_plan plan) current->plan = plan; backend_plan_changed(current); - /* If it closed, close duplex. */ - if (!current->plan.next && current->duplex) { - current->duplex->plan = io_close_(); - backend_plan_changed(current->duplex); - } - /* Call back into the loop immediately. */ io_loop_return = do_io_loop(&ready); @@ -460,14 +454,6 @@ void io_ready(struct io_conn *conn) backend_plan_changed(conn); } set_current(NULL); - - /* If it closed, close duplex if not already */ - if (!conn->plan.next && conn->duplex && conn->duplex->plan.next) { - set_current(conn->duplex); - conn->duplex->plan = io_close(); - backend_plan_changed(conn->duplex); - set_current(NULL); - } } /* Close the connection, we're done. */