if (!ready->plan.next) {
/* Call finish function immediately. */
if (ready->finish) {
- errno = ready->plan.u.close.saved_errno;
+ errno = ready->plan.u1.s;
ready->finish(ready, ready->finish_arg);
ready->finish = NULL;
}
/* Returns true if we're finished. */
static int do_write(int fd, struct io_plan *plan)
{
- ssize_t ret = write(fd, plan->u.write.buf, plan->u.write.len);
+ ssize_t ret = write(fd, plan->u1.cp, plan->u2.s);
if (ret < 0)
return io_debug_io(-1);
- plan->u.write.buf += ret;
- plan->u.write.len -= ret;
- return io_debug_io(plan->u.write.len == 0);
+ plan->u1.cp += ret;
+ plan->u2.s -= ret;
+ return io_debug_io(plan->u2.s == 0);
}
/* Queue some data to be written. */
struct io_plan plan;
assert(cb);
- plan.u.write.buf = data;
- plan.u.write.len = len;
+ plan.u1.const_vp = data;
+ plan.u2.s = len;
plan.io = do_write;
plan.next = cb;
plan.next_arg = arg;
static int do_read(int fd, struct io_plan *plan)
{
- ssize_t ret = read(fd, plan->u.read.buf, plan->u.read.len);
+ ssize_t ret = read(fd, plan->u1.cp, plan->u2.s);
if (ret <= 0)
return io_debug_io(-1);
- plan->u.read.buf += ret;
- plan->u.read.len -= ret;
- return io_debug_io(plan->u.read.len == 0);
+ plan->u1.cp += ret;
+ plan->u2.s -= ret;
+ return io_debug_io(plan->u2.s == 0);
}
/* Queue a request to read into a buffer. */
struct io_plan plan;
assert(cb);
- plan.u.read.buf = data;
- plan.u.read.len = len;
+ plan.u1.cp = data;
+ plan.u2.s = len;
plan.io = do_read;
plan.next = cb;
plan.next_arg = arg;
static int do_read_partial(int fd, struct io_plan *plan)
{
- ssize_t ret = read(fd, plan->u.readpart.buf, *plan->u.readpart.lenp);
+ ssize_t ret = read(fd, plan->u1.cp, *(size_t *)plan->u2.vp);
if (ret <= 0)
return io_debug_io(-1);
- *plan->u.readpart.lenp = ret;
+ *(size_t *)plan->u2.vp = ret;
return io_debug_io(1);
}
struct io_plan plan;
assert(cb);
- plan.u.readpart.buf = data;
- plan.u.readpart.lenp = len;
+ plan.u1.cp = data;
+ plan.u2.vp = len;
plan.io = do_read_partial;
plan.next = cb;
plan.next_arg = arg;
static int do_write_partial(int fd, struct io_plan *plan)
{
- ssize_t ret = write(fd, plan->u.writepart.buf, *plan->u.writepart.lenp);
+ ssize_t ret = write(fd, plan->u1.cp, *(size_t *)plan->u2.vp);
if (ret < 0)
return io_debug_io(-1);
- *plan->u.writepart.lenp = ret;
+ *(size_t *)plan->u2.vp = ret;
return io_debug_io(1);
}
struct io_plan plan;
assert(cb);
- plan.u.writepart.buf = data;
- plan.u.writepart.lenp = len;
+ plan.u1.const_vp = data;
+ plan.u2.vp = len;
plan.io = do_write_partial;
plan.next = cb;
plan.next_arg = arg;
if (err == 0) {
/* Restore blocking if it was initially. */
- fcntl(fd, F_SETFD, plan->u.len_len.len1);
+ fcntl(fd, F_SETFD, plan->u1.s);
return 1;
}
return 0;
plan.next_arg = arg;
/* Save old flags, set nonblock if not already. */
- plan.u.len_len.len1 = fcntl(fd, F_GETFD);
- fcntl(fd, F_SETFD, plan.u.len_len.len1 | O_NONBLOCK);
+ plan.u1.s = fcntl(fd, F_GETFD);
+ fcntl(fd, F_SETFD, plan.u1.s | O_NONBLOCK);
/* Immediate connect can happen. */
if (connect(fd, addr->ai_addr, addr->ai_addrlen) == 0) {
plan.pollflag = 0;
/* This means we're closing. */
plan.next = NULL;
- plan.u.close.saved_errno = errno;
+ plan.u1.s = errno;
return plan;
}
static int do_read_packet(int fd, struct io_plan *plan)
{
- struct packet *pkt = plan->u.ptr_len.p;
+ struct packet *pkt = plan->u1.vp;
char *dest;
ssize_t ret;
size_t off, totlen;
/* Reading len? */
- if (plan->u.ptr_len.len < sizeof(size_t)) {
+ if (plan->u2.s < sizeof(size_t)) {
ok1(pkt->state == 1);
pkt->state++;
dest = (char *)&pkt->len;
- off = plan->u.ptr_len.len;
+ off = plan->u2.s;
totlen = sizeof(pkt->len);
} else {
ok1(pkt->state == 2);
goto fail;
else {
dest = pkt->contents;
- off = plan->u.ptr_len.len - sizeof(pkt->len);
+ off = plan->u2.s - sizeof(pkt->len);
totlen = pkt->len;
}
}
if (ret <= 0)
goto fail;
- plan->u.ptr_len.len += ret;
+ plan->u2.s += ret;
/* Finished? */
- return io_debug_io(plan->u.ptr_len.len >= sizeof(pkt->len)
- && plan->u.ptr_len.len == pkt->len + sizeof(pkt->len));
+ return io_debug_io(plan->u2.s >= sizeof(pkt->len)
+ && plan->u2.s == pkt->len + sizeof(pkt->len));
fail:
free(pkt->contents);
assert(cb);
pkt->contents = NULL;
- plan.u.ptr_len.p = pkt;
- plan.u.ptr_len.len = 0;
+ plan.u1.vp = pkt;
+ plan.u2.s = 0;
plan.io = do_read_packet;
plan.next = cb;
plan.next_arg = arg;