X-Git-Url: http://git.ozlabs.org/?p=ccan;a=blobdiff_plain;f=ccan%2Fio%2Fbenchmarks%2Frun-length-prefix.c;fp=ccan%2Fio%2Fbenchmarks%2Frun-length-prefix.c;h=8a276839395223dfb403db4e5102b9d4c6eae890;hp=7d0336348e0028a922afe777b427f4ffa42628ed;hb=7a8a585c32d1010426f587a6933f05de7a06dfd0;hpb=1fe2db9cbe84812e1465db36f538a222e9984c93 diff --git a/ccan/io/benchmarks/run-length-prefix.c b/ccan/io/benchmarks/run-length-prefix.c index 7d033634..8a276839 100644 --- a/ccan/io/benchmarks/run-length-prefix.c +++ b/ccan/io/benchmarks/run-length-prefix.c @@ -25,28 +25,28 @@ struct client { char *request_buffer; }; -static struct io_op *write_reply(struct io_conn *conn, struct client *client); -static struct io_op *read_body(struct io_conn *conn, struct client *client) +static struct io_plan *write_reply(struct io_conn *conn, struct client *client); +static struct io_plan *read_body(struct io_conn *conn, struct client *client) { assert(client->len <= REQUEST_MAX); return io_read(client->request_buffer, client->len, io_next(conn, write_reply, client)); } -static struct io_op *read_header(struct io_conn *conn, struct client *client) +static struct io_plan *read_header(struct io_conn *conn, struct client *client) { return io_read(&client->len, sizeof(client->len), io_next(conn, read_body, client)); } /* once we're done, loop again. */ -static struct io_op *write_complete(struct io_conn *conn, struct client *client) +static struct io_plan *write_complete(struct io_conn *conn, struct client *client) { completed++; return read_header(conn, client); } -static struct io_op *write_reply(struct io_conn *conn, struct client *client) +static struct io_plan *write_reply(struct io_conn *conn, struct client *client) { return io_write(&client->len, sizeof(client->len), io_next(conn, write_complete, client)); @@ -112,12 +112,12 @@ static void sigalarm(int sig) write(timeout[1], "1", 1); } -static struct io_op *do_timeout(struct io_conn *conn, char *buf) +static struct io_plan *do_timeout(struct io_conn *conn, char *buf) { return io_break(conn, NULL); } -static struct io_op *do_timeout_read(struct io_conn *conn, char *buf) +static struct io_plan *do_timeout_read(struct io_conn *conn, char *buf) { return io_read(buf, 1, io_next(conn, do_timeout, buf)); }