| 111 | } |
| 112 | |
| 113 | static struct io_plan *simple_read(struct io_conn *conn, |
| 114 | void *data, size_t len, |
| 115 | struct io_plan *(*next)(struct io_conn *, void *), |
| 116 | void *next_arg) |
| 117 | { |
| 118 | if (!read_all(conn->fd, data, len)) |
| 119 | err(1, "Reading data"); |
| 120 | return next(conn, next_arg); |
| 121 | } |
| 122 | |
| 123 | static void sync_crypto_write(int peer_fd, struct crypto_state *cs, const void *msg TAKES) |
| 124 | { |