X-Git-Url: https://git.ozlabs.org/?a=blobdiff_plain;f=ccan%2Fio%2Ftest%2Frun-05-write.c;fp=ccan%2Fio%2Ftest%2Frun-05-write.c;h=2e744cffd8fa5446c3ce18ded98f8ac6c65b1c02;hb=cdffdf5d61f8330cfc3467e73a84876eb3928e9b;hp=2c3e1839991b3ef927ac24cd7b3ac5ad658a80fc;hpb=12e924346b342c61219a3fdc57eb6b00a27f1cd1;p=ccan diff --git a/ccan/io/test/run-05-write.c b/ccan/io/test/run-05-write.c index 2c3e1839..2e744cff 100644 --- a/ccan/io/test/run-05-write.c +++ b/ccan/io/test/run-05-write.c @@ -20,16 +20,15 @@ static void finish_ok(struct io_conn *conn, struct data *d) { ok1(d->state == 1); d->state++; - io_break(d, io_never()); + io_break(d); } -static void init_conn(int fd, struct data *d) +static struct io_plan *init_conn(struct io_conn *conn, struct data *d) { ok1(d->state == 0); d->state++; - io_set_finish(io_new_conn(fd, io_write(d->buf, d->bytes, - io_close_cb, d)), - finish_ok, d); + io_set_finish(conn, finish_ok, d); + return io_write(conn, d->buf, d->bytes, io_close_cb, d); } static int make_listen_fd(const char *port, struct addrinfo **info) @@ -100,7 +99,7 @@ int main(void) memset(d->buf, 'a', d->bytes); fd = make_listen_fd(PORT, &addrinfo); ok1(fd >= 0); - l = io_new_listener(fd, init_conn, d); + l = io_new_listener(NULL, fd, init_conn, d); ok1(l); fflush(stdout); if (!fork()) {