… | |
… | |
268 | |
268 | |
269 | /* increment generation counter to avoid handling old events */ |
269 | /* increment generation counter to avoid handling old events */ |
270 | ++anfd->egen; |
270 | ++anfd->egen; |
271 | } |
271 | } |
272 | |
272 | |
273 | iocb->io.aio_buf = |
273 | iocb->io.aio_buf = (nev & EV_READ ? POLLIN : 0) |
274 | (nev & EV_READ ? POLLIN : 0) |
|
|
275 | | (nev & EV_WRITE ? POLLOUT : 0); |
274 | | (nev & EV_WRITE ? POLLOUT : 0); |
276 | |
275 | |
277 | if (nev) |
276 | if (nev) |
278 | { |
277 | { |
279 | iocb->io.aio_data = (uint32_t)fd | ((__u64)(uint32_t)anfd->egen << 32); |
278 | iocb->io.aio_data = (uint32_t)fd | ((__u64)(uint32_t)anfd->egen << 32); |
280 | |
279 | |