conn->duplex->duplex = NULL;
} else
del_fd(&conn->fd);
- if (conn->state == FINISHED)
+ if (conn->state == IO_FINISHED)
num_finished--;
- else if (conn->state == NEXT)
+ else if (conn->state == IO_NEXT)
num_next--;
}
if (pfd->events)
num_waiting++;
- if (state == NEXT)
+ if (state == IO_NEXT)
num_next++;
- else if (state == FINISHED)
+ else if (state == IO_FINISHED)
num_finished++;
conn->state = state;
continue;
c = (void *)fds[i];
for (duplex = c->duplex; c; c = duplex, duplex = NULL) {
- if (c->state == FINISHED) {
+ if (c->state == IO_FINISHED) {
del_conn(c);
free(c);
i--;
- } else if (!finished_only && c->state == NEXT) {
+ } else if (!finished_only && c->state == IO_NEXT) {
backend_set_state(c, c->next(c, c->next_arg));
num_next--;
}