io: fix corner case in EPIPE handling.

[ccan] / ccan / io / io.c

diff --git a/ccan/io/io.c b/ccan/io/io.c
index 7eea9c35442cbbcb4386b430929195d1454b49a0..99f0f7c90fd8580f4dac211134b5ec87da544bf4 100644 (file)
--- a/ccan/io/io.c
+++ b/ccan/io/io.c
@@ -399,8 +399,7 @@ void io_ready(struct io_conn *conn, int pollflags)
                /* If we're writing to a closed pipe, we need to wait for
                 * read to fail if we're duplex: we want to drain it! */
                do_plan(conn, &conn->plan[IO_OUT],
-                       (conn->plan[IO_IN].status == IO_POLLING
-                        || conn->plan[IO_IN].status == IO_ALWAYS));
+                       conn->plan[IO_IN].status == IO_POLLING);
 }
 
 void io_do_always(struct io_conn *conn)