Lines Matching refs:_loop
465 self._loop = loop
483 self._loop.call_soon(self._protocol.connection_made, self)
485 self._loop.call_soon(self._add_reader,
489 self._loop.call_soon(futures._set_result_unless_cancelled,
495 self._loop._add_reader(fd, callback)
507 selector = getattr(self._loop, '_selector', None)
532 if self._loop.get_debug():
535 self._loop._remove_reader(self._fileno)
536 self._loop.call_soon(self._protocol.eof_received)
537 self._loop.call_soon(self._call_connection_lost, None)
543 self._loop._remove_reader(self._fileno)
544 if self._loop.get_debug():
551 self._loop._add_reader(self._fileno, self._read_ready)
552 if self._loop.get_debug():
576 if self._loop.get_debug():
579 self._loop.call_exception_handler({
589 self._loop._remove_reader(self._fileno)
590 self._loop.call_soon(self._call_connection_lost, exc)
599 self._loop = None
627 self._loop.call_soon(self._protocol.connection_made, self)
634 self._loop.call_soon(self._loop._add_reader,
639 self._loop.call_soon(futures._set_result_unless_cancelled,
649 selector = getattr(self._loop, '_selector', None)
671 if self._loop.get_debug():
708 self._loop._add_writer(self._fileno, self._write_ready)
727 self._loop._remove_writer(self._fileno)
732 self._loop._remove_writer(self._fileno)
735 self._loop._remove_reader(self._fileno)
750 self._loop._remove_reader(self._fileno)
751 self._loop.call_soon(self._call_connection_lost, None)
778 if self._loop.get_debug():
781 self._loop.call_exception_handler({
792 self._loop._remove_writer(self._fileno)
794 self._loop._remove_reader(self._fileno)
795 self._loop.call_soon(self._call_connection_lost, exc)
804 self._loop = None
923 self._loop = None
933 return self._loop is not None and self._loop.is_running()
939 if self._loop is not None and loop is None and self._callbacks:
945 self._loop._remove_reader(pidfd)
948 self._loop = loop
956 self._loop._add_reader(pidfd, self._do_wait, pid)
961 self._loop._remove_reader(pidfd)
983 self._loop._remove_reader(pidfd)
991 self._loop = None
998 return self._loop is not None and self._loop.is_running()
1009 if self._loop is not None and loop is None and self._callbacks:
1015 if self._loop is not None:
1016 self._loop.remove_signal_handler(signal.SIGCHLD)
1018 self._loop = loop
1032 # self._loop should always be available here
1035 self._loop.call_exception_handler({
1099 if self._loop.get_debug():
1108 if self._loop.get_debug():
1201 if self._loop.get_debug():
1208 if self._loop.get_debug():
1447 self._watcher.attach_loop(self._local._loop)