50 |
|
static fde_t kqfd; |
51 |
|
static struct kevent kq_fdlist[KE_LENGTH]; /* kevent buffer */ |
52 |
|
static int kqoff; /* offset into the buffer */ |
53 |
– |
void init_netio(void); |
53 |
|
|
54 |
|
/* |
55 |
|
* init_netio |
182 |
|
{ |
183 |
|
F->read_handler = NULL; |
184 |
|
hdl(F, F->read_data); |
185 |
< |
if (!F->flags.open) |
186 |
< |
continue; |
185 |
> |
if (!F->flags.open) |
186 |
> |
continue; |
187 |
|
} |
188 |
|
|
189 |
|
if (ke[i].filter == EVFILT_WRITE) |
191 |
|
{ |
192 |
|
F->write_handler = NULL; |
193 |
|
hdl(F, F->write_data); |
194 |
< |
if (!F->flags.open) |
195 |
< |
continue; |
194 |
> |
if (!F->flags.open) |
195 |
> |
continue; |
196 |
|
} |
197 |
|
|
198 |
|
comm_setselect(F, 0, NULL, NULL, 0); |