(self, proactor)
| 629 | class BaseProactorEventLoop(base_events.BaseEventLoop): |
| 630 | |
| 631 | def __init__(self, proactor): |
| 632 | super().__init__() |
| 633 | logger.debug('Using proactor: %s', proactor.__class__.__name__) |
| 634 | self._proactor = proactor |
| 635 | self._selector = proactor # convenient alias |
| 636 | self._self_reading_future = None |
| 637 | self._accept_futures = {} # socket file descriptor => Future |
| 638 | proactor.set_loop(self) |
| 639 | self._make_self_pipe() |
| 640 | if threading.current_thread() is threading.main_thread(): |
| 641 | # wakeup fd can only be installed to a file descriptor from the main thread |
| 642 | signal.set_wakeup_fd(self._csock.fileno()) |
| 643 | |
| 644 | def _make_socket_transport(self, sock, protocol, waiter=None, |
| 645 | extra=None, server=None, context=None): |
no test coverage detected