X-Git-Url: http://git.ozlabs.org/?a=blobdiff_plain;f=ccan%2Fio%2Ftest%2Frun-03-readpartial.c;fp=ccan%2Fio%2Ftest%2Frun-03-readpartial.c;h=a24be7e025847b3e36bf4cf865cc11113e3a47f8;hb=57d9d1be33905691ec756b14b066181ca6850ced;hp=a7d0ae3161aa674cc7b22a23ec16c1148cb1cca8;hpb=737705f0c2ec60ea5b51ca55299488d86db37b5d;p=ccan diff --git a/ccan/io/test/run-03-readpartial.c b/ccan/io/test/run-03-readpartial.c index a7d0ae31..a24be7e0 100644 --- a/ccan/io/test/run-03-readpartial.c +++ b/ccan/io/test/run-03-readpartial.c @@ -12,24 +12,21 @@ struct data { char buf[4]; }; -static struct io_plan start_ok(struct io_conn *conn, struct data *d) -{ - ok1(d->state == 0); - d->state++; - d->bytes = sizeof(d->buf); - return io_read_partial(d->buf, &d->bytes, io_close, d); -} - static void finish_ok(struct io_conn *conn, struct data *d) { ok1(d->state == 1); 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)) + ok1(d->state == 0); + d->state++; + d->bytes = sizeof(d->buf); + + if (!io_new_conn(fd, io_read_partial(d->buf, &d->bytes, io_close, d), + finish_ok, d)) abort(); }