X-Git-Url: https://git.ozlabs.org/?a=blobdiff_plain;f=ccan%2Fio%2Ftest%2Frun-12-bidir.c;fp=ccan%2Fio%2Ftest%2Frun-12-bidir.c;h=3534bc3138f92df5aa6bb57e51849aac26ac6f3b;hb=737705f0c2ec60ea5b51ca55299488d86db37b5d;hp=5b39f38dbc1be78fc7ff26a35fe946203b67f712;hpb=733b09fa8b6083949ff62795e54851aa282d510c;p=ccan diff --git a/ccan/io/test/run-12-bidir.c b/ccan/io/test/run-12-bidir.c index 5b39f38d..3534bc31 100644 --- a/ccan/io/test/run-12-bidir.c +++ b/ccan/io/test/run-12-bidir.c @@ -36,6 +36,12 @@ static struct io_plan start_ok(struct io_conn *conn, struct data *d) return io_read(d->buf, sizeof(d->buf), io_close, d); } +static void init_conn(int fd, struct data *d) +{ + if (!io_new_conn(fd, start_ok, finish_ok, d)) + abort(); +} + static int make_listen_fd(const char *port, struct addrinfo **info) { int fd, on = 1; @@ -79,7 +85,7 @@ int main(void) d->state = 0; fd = make_listen_fd("65012", &addrinfo); ok1(fd >= 0); - d->l = io_new_listener(fd, start_ok, finish_ok, d); + d->l = io_new_listener(fd, init_conn, d); ok1(d->l); fflush(stdout); if (!fork()) {