| … | |
… | |
| 361 | /*****************************************************************************/ |
361 | /*****************************************************************************/ |
| 362 | |
362 | |
| 363 | static void |
363 | static void |
| 364 | iouring_modify (EV_P_ int fd, int oev, int nev) |
364 | iouring_modify (EV_P_ int fd, int oev, int nev) |
| 365 | { |
365 | { |
| 366 | fprintf (stderr,"modify %d (%d, %d) %d\n", fd, oev,nev, anfds[fd].eflags);//D |
|
|
| 367 | if (ecb_expect_false (anfds [fd].eflags)) |
366 | if (ecb_expect_false (anfds [fd].eflags)) |
| 368 | { |
367 | { |
| 369 | /* we handed this fd over to epoll, so undo this first */ |
368 | /* we handed this fd over to epoll, so undo this first */ |
| 370 | /* we do it manually because the optimisations on epoll_modify won't do us any good */ |
369 | /* we do it manually because the optimisations on epoll_modify won't do us any good */ |
| 371 | epoll_ctl (iouring_fd, EPOLL_CTL_DEL, fd, 0); |
370 | epoll_ctl (iouring_fd, EPOLL_CTL_DEL, fd, 0); |
| … | |
… | |
| 471 | } |
470 | } |
| 472 | |
471 | |
| 473 | return; |
472 | return; |
| 474 | } |
473 | } |
| 475 | |
474 | |
| 476 | fprintf (stderr, "fd %d event, rearm\n", fd);//D |
|
|
| 477 | |
|
|
| 478 | /* feed events, we do not expect or handle POLLNVAL */ |
475 | /* feed events, we do not expect or handle POLLNVAL */ |
| 479 | fd_event ( |
476 | fd_event ( |
| 480 | EV_A_ |
477 | EV_A_ |
| 481 | fd, |
478 | fd, |
| 482 | (res & (POLLOUT | POLLERR | POLLHUP) ? EV_WRITE : 0) |
479 | (res & (POLLOUT | POLLERR | POLLHUP) ? EV_WRITE : 0) |
