(self, block)
| 444 | self.__poller.unregister(fileno) |
| 445 | |
| 446 | def doPoll(self, block): |
| 447 | readyList = self.__poller.poll(-1 if block else 0) |
| 448 | for (fd, eventMask) in readyList: |
| 449 | readReady = ((eventMask & select.EPOLLIN) != 0) |
| 450 | writeReady = ((eventMask & select.EPOLLOUT) != 0) |
| 451 | errorReady = ((eventMask & |
| 452 | (select.EPOLLERR | select.EPOLLHUP)) != 0) |
| 453 | self.handleEventForFD(fd = fd, |
| 454 | readReady = readReady, |
| 455 | writeReady = writeReady, |
| 456 | errorReady = errorReady) |
| 457 | |
| 458 | class KQueueAsyncIOService(AsyncIOService): |
| 459 |
nothing calls this directly
no test coverage detected