plan.next_arg = arg;
plan.pollflag = POLLIN;
- io_plan_debug(&plan);
return plan;
}
ok1(pkt->state == 0);
pkt->state++;
- io_set_finish(io_new_conn(fd, io_read_packet(pkt, io_close, pkt)),
+ io_set_finish(io_new_conn(fd, io_read_packet(pkt, io_close_cb, pkt)),
finish_ok, pkt);
}