| 123 | } |
| 124 | |
| 125 | static struct io_plan *simple_read(struct io_conn *conn, |
| 126 | void *data, size_t len, |
| 127 | struct io_plan *(*next)(struct io_conn *, void *), |
| 128 | void *next_arg) |
| 129 | { |
| 130 | if (!read_all(conn->fd, data, len)) |
| 131 | err(1, "Reading data"); |
| 132 | return next(conn, next_arg); |
| 133 | } |
| 134 | |
| 135 | static void sync_crypto_write(int peer_fd, struct crypto_state *cs, const void *msg TAKES) |
| 136 | { |