if (connect(sock[i], (void *)addr, sizeof(*addr)) != 0)
err(1, "connecting socket");
/* Make nonblocking. */
- fcntl(sock[i], F_SETFD, fcntl(sock[i], F_GETFD)|O_NONBLOCK);
+ io_fd_block(sock[i], false);
done[i] = 0;
}
err(1, "Accepting fd");
/* For efficiency, we share buffer */
client->request_buffer = buffer;
- io_new_conn(ret, io_read_header(client), NULL, NULL);
+ io_new_conn(ret, io_read_header(client));
}
}
- io_new_conn(timeout[0], io_read(&buf, 1, do_timeout, &buf), NULL, NULL);
+ io_new_conn(timeout[0], io_read(&buf, 1, do_timeout, &buf));
close(wake[0]);
for (i = 0; i < NUM_CHILDREN; i++)