X-Git-Url: http://git.ozlabs.org/?a=blobdiff_plain;f=ccan%2Fio%2Ftest%2Frun-15-timeout.c;fp=ccan%2Fio%2Ftest%2Frun-15-timeout.c;h=f8ddc6a57ed6e21ae492a497476a1cd65c2a6bfa;hb=57d9d1be33905691ec756b14b066181ca6850ced;hp=0ff3fc8a54a85c207c3552a1fc73528b60069cc6;hpb=737705f0c2ec60ea5b51ca55299488d86db37b5d;p=ccan diff --git a/ccan/io/test/run-15-timeout.c b/ccan/io/test/run-15-timeout.c index 0ff3fc8a..f8ddc6a5 100644 --- a/ccan/io/test/run-15-timeout.c +++ b/ccan/io/test/run-15-timeout.c @@ -30,25 +30,23 @@ static struct io_plan timeout(struct io_conn *conn, struct data *d) return io_close(conn, d); } -static struct io_plan start_ok(struct io_conn *conn, struct data *d) -{ - ok1(d->state == 0); - d->state++; - io_timeout(conn, time_from_usec(d->timeout_usec), timeout, d); - return io_read(d->buf, sizeof(d->buf), no_timeout, d); -} - static void finish_ok(struct io_conn *conn, struct data *d) { ok1(d->state == 2); d->state++; - io_break(d, NULL, NULL); + io_break(d, io_idle()); } static void init_conn(int fd, struct data *d) { - if (!io_new_conn(fd, start_ok, finish_ok, d)) - abort(); + struct io_conn *conn; + + ok1(d->state == 0); + d->state++; + + conn = io_new_conn(fd, io_read(d->buf, sizeof(d->buf), no_timeout, d), + finish_ok, d); + io_timeout(conn, time_from_usec(d->timeout_usec), timeout, d); } static int make_listen_fd(const char *port, struct addrinfo **info)