Lines Matching refs:_loop
582 if self._loop is not None and not self._loop.is_closed():
583 polling = _test_selector_event(self._loop._selector,
590 polling = _test_selector_event(self._loop._selector,
618 self._loop._remove_reader(self._sock_fd)
621 self._loop._remove_writer(self._sock_fd)
622 self._loop.call_soon(self._call_connection_lost, None)
637 if self._loop.get_debug():
640 self._loop.call_exception_handler({
653 self._loop._remove_writer(self._sock_fd)
656 self._loop._remove_reader(self._sock_fd)
658 self._loop.call_soon(self._call_connection_lost, exc)
668 self._loop = None
691 self._loop.call_soon(self._protocol.connection_made, self)
693 self._loop.call_soon(self._loop._add_reader,
697 self._loop.call_soon(futures._set_result_unless_cancelled,
706 self._loop._remove_reader(self._sock_fd)
707 if self._loop.get_debug():
716 self._loop._add_reader(self._sock_fd, self._read_ready)
717 if self._loop.get_debug():
733 if self._loop.get_debug():
740 self._loop._remove_reader(self._sock_fd)
773 self._loop._add_writer(self._sock_fd, self._write_ready)
789 self._loop._remove_writer(self._sock_fd)
797 self._loop._remove_writer(self._sock_fd)
847 if self._loop.get_debug():
849 start_time = self._loop.time()
868 self._loop._add_reader(self._sock_fd,
872 self._loop._add_writer(self._sock_fd,
876 if self._loop.get_debug():
879 self._loop._remove_reader(self._sock_fd)
880 self._loop._remove_writer(self._sock_fd)
888 self._loop._remove_reader(self._sock_fd)
889 self._loop._remove_writer(self._sock_fd)
900 if self._loop.get_debug():
917 self._loop._add_reader(self._sock_fd, self._read_ready)
919 self._loop.call_soon(self._protocol.connection_made, self)
921 self._loop.call_soon(self._wakeup_waiter)
923 if self._loop.get_debug():
924 dt = self._loop.time() - start_time
939 self._loop._remove_reader(self._sock_fd)
940 if self._loop.get_debug():
949 self._loop._add_reader(self._sock_fd, self._read_ready)
950 if self._loop.get_debug():
961 self._loop._add_writer(self._sock_fd, self._write_ready)
969 self._loop._remove_reader(self._sock_fd)
970 self._loop._add_writer(self._sock_fd, self._write_ready)
978 if self._loop.get_debug():
995 self._loop._add_reader(self._sock_fd, self._read_ready)
1004 self._loop._remove_writer(self._sock_fd)
1007 self._loop._remove_writer(self._sock_fd)
1018 self._loop._remove_writer(self._sock_fd)
1036 self._loop._add_writer(self._sock_fd, self._write_ready)
1054 self._loop.call_soon(self._protocol.connection_made, self)
1056 self._loop.call_soon(self._loop._add_reader,
1060 self._loop.call_soon(futures._set_result_unless_cancelled,
1106 self._loop._add_writer(self._sock_fd, self._sendto_ready)
1140 self._loop._remove_writer(self._sock_fd)
