Lines Matching refs:_loop
800 if self._loop is not None and not self._loop.is_closed():
801 polling = _test_selector_event(self._loop._selector,
808 polling = _test_selector_event(self._loop._selector,
840 self._loop._remove_reader(self._sock_fd)
841 if self._loop.get_debug():
849 if self._loop.get_debug():
856 self._loop._remove_reader(self._sock_fd)
859 self._loop._remove_writer(self._sock_fd)
860 self._loop.call_soon(self._call_connection_lost, None)
870 if self._loop.get_debug():
873 self._loop.call_exception_handler({
886 self._loop._remove_writer(self._sock_fd)
889 self._loop._remove_reader(self._sock_fd)
891 self._loop.call_soon(self._call_connection_lost, exc)
901 self._loop = None
913 self._loop._add_reader(fd, callback, *args)
934 self._loop.call_soon(self._protocol.connection_made, self)
936 self._loop.call_soon(self._add_reader,
940 self._loop.call_soon(futures._set_result_unless_cancelled,
1017 if self._loop.get_debug():
1033 self._loop._remove_reader(self._sock_fd)
1070 self._loop._add_writer(self._sock_fd, self._write_ready)
1088 self._loop._remove_writer(self._sock_fd)
1098 self._loop._remove_writer(self._sock_fd)
1125 self._empty_waiter = self._loop.create_future()
1143 self._loop.call_soon(self._protocol.connection_made, self)
1145 self._loop.call_soon(self._add_reader,
1149 self._loop.call_soon(futures._set_result_unless_cancelled,
1199 self._loop._add_writer(self._sock_fd, self._sendto_ready)
1240 self._loop._remove_writer(self._sock_fd)