io_break(pkt, io_idle());
}
-static bool do_read_packet(int fd, struct io_plan *plan)
+static int do_read_packet(int fd, struct io_plan *plan)
{
struct packet *pkt = plan->u.ptr_len.p;
char *dest;
ok1(pkt->state == 2);
pkt->state++;
if (pkt->len == 0)
- return true;
+ return 1;
if (!pkt->contents && !(pkt->contents = malloc(pkt->len)))
goto fail;
else {
fail:
free(pkt->contents);
- /* Override next function to close us. */
- plan->next = io_close;
- return true;
+ return -1;
}
static struct io_plan io_read_packet(struct packet *pkt,
plan.next_arg = arg;
plan.pollflag = POLLIN;
- io_plan_debug(&plan);
return plan;
}
ok1(pkt->state == 0);
pkt->state++;
- if (!io_new_conn(fd, io_read_packet(pkt, io_close, pkt), finish_ok, pkt))
- abort();
+ io_set_finish(io_new_conn(fd, io_read_packet(pkt, io_close_cb, pkt)),
+ finish_ok, pkt);
}
static int make_listen_fd(const char *port, struct addrinfo **info)