These have the same definitions as their original definitions. We reiterate * these here because we want them to use test_sync_write and test_sync_read. */
| 230 | * these here because we want them to use test_sync_write and test_sync_read. |
| 231 | */ |
| 232 | static void test_peer_write(struct per_peer_state *pps, const void *msg TAKES) |
| 233 | { |
| 234 | /* Abort the run when called by `negotiation_aborted`. */ |
| 235 | if (is_peer_error(tmpctx, msg)) |
| 236 | longjmp(fuzz_env, 1); |
| 237 | |
| 238 | status_peer_io(LOG_IO_OUT, NULL, msg); |
| 239 | test_sync_write(pps->peer_fd, msg); |
| 240 | } |
| 241 | |
| 242 | static u8 *test_peer_read(const tal_t *ctx, struct per_peer_state *pps) |
| 243 | { |
nothing calls this directly
no test coverage detected