X-Git-Url: http://git.ozlabs.org/?a=blobdiff_plain;f=ccan%2Fio%2Ftest%2Frun-10-many.c;fp=ccan%2Fio%2Ftest%2Frun-10-many.c;h=313691187f6c63d059f03f0144e5a1fa6f2c48be;hb=bfb80c566ab695b70a404a419f4b1450a2fcf27a;hp=b20b2285b9e9621673ba7f3318834d9ea191a8c9;hpb=174fe59fdce127808420986f56987205ecab2858;p=ccan diff --git a/ccan/io/test/run-10-many.c b/ccan/io/test/run-10-many.c index b20b2285..31369118 100644 --- a/ccan/io/test/run-10-many.c +++ b/ccan/io/test/run-10-many.c @@ -18,7 +18,7 @@ struct buffer { static struct io_plan *poke_writer(struct io_conn *conn, struct buffer *buf); static struct io_plan *poke_reader(struct io_conn *conn, struct buffer *buf); -static struct io_plan *do_read(struct io_conn *conn, struct buffer *buf) +static struct io_plan *plan_read(struct io_conn *conn, struct buffer *buf) { assert(conn == buf->reader); @@ -26,7 +26,7 @@ static struct io_plan *do_read(struct io_conn *conn, struct buffer *buf) poke_writer, buf); } -static struct io_plan *do_write(struct io_conn *conn, struct buffer *buf) +static struct io_plan *plan_write(struct io_conn *conn, struct buffer *buf) { assert(conn == buf->writer); @@ -42,7 +42,7 @@ static struct io_plan *poke_writer(struct io_conn *conn, struct buffer *buf) return io_close(conn, NULL); /* You write. */ - io_wake(buf->writer, do_write, buf); + io_wake(buf->writer, plan_write, buf); /* I'll wait until you wake me. */ return io_idle(conn); @@ -52,7 +52,7 @@ static struct io_plan *poke_reader(struct io_conn *conn, struct buffer *buf) { assert(conn == buf->writer); /* You read. */ - io_wake(buf->reader, do_read, buf); + io_wake(buf->reader, plan_read, buf); if (++buf->iters == NUM_ITERS) return io_close(conn, NULL); @@ -91,7 +91,7 @@ int main(void) buf[i].reader = io_new_conn(last_read, reader, NULL, &buf[i]); if (!buf[i].reader) break; - buf[i].writer = io_new_conn(fds[1], do_write, NULL, &buf[i]); + buf[i].writer = io_new_conn(fds[1], plan_write, NULL, &buf[i]); if (!buf[i].writer) break; last_read = fds[0]; @@ -104,7 +104,7 @@ int main(void) sprintf(buf[i].buf, "%i-%i", i, i); buf[i].reader = io_new_conn(last_read, reader, NULL, &buf[i]); ok1(buf[i].reader); - buf[i].writer = io_new_conn(last_write, do_write, NULL, &buf[i]); + buf[i].writer = io_new_conn(last_write, plan_write, NULL, &buf[i]); ok1(buf[i].writer); /* They should eventually exit */