ioq->get = 0;
ioq->buf = new_buf;
ioq->size = new_size;
- return new_size - ioq->put;
+ return new_size - ioq->put - 1;
}
extern struct io_engine io_engine_kevent;
static void
ioset_buffered_read(struct io_fd *fd) {
- int put_avail, nbr, fdnum;
+ int put_avail, nbr;
if (!(put_avail = ioq_put_avail(&fd->recv)))
put_avail = ioq_grow(&fd->recv);
fd->recv.put += nbr;
if (fd->recv.put == fd->recv.size)
fd->recv.put = 0;
- fdnum = fd->fd;
while (fd->line_len > 0) {
struct io_fd *old_active;
int died = 0;