Lines Matching refs:_loop

429         self._loop = loop
446         self._loop.call_soon(self._protocol.connection_made, self)
448         self._loop.call_soon(self._loop._add_reader,
452             self._loop.call_soon(futures._set_result_unless_cancelled,
462         selector = getattr(self._loop, '_selector', None)
487                 if self._loop.get_debug():
490                 self._loop._remove_reader(self._fileno)
491                 self._loop.call_soon(self._protocol.eof_received)
492                 self._loop.call_soon(self._call_connection_lost, None)
495         self._loop._remove_reader(self._fileno)
498         self._loop._add_reader(self._fileno, self._read_ready)
522             if self._loop.get_debug():
525             self._loop.call_exception_handler({
535         self._loop._remove_reader(self._fileno)
536         self._loop.call_soon(self._call_connection_lost, exc)
545             self._loop = None
573         self._loop.call_soon(self._protocol.connection_made, self)
580             self._loop.call_soon(self._loop._add_reader,
585             self._loop.call_soon(futures._set_result_unless_cancelled,
595         selector = getattr(self._loop, '_selector', None)
617         if self._loop.get_debug():
652             self._loop._add_writer(self._fileno, self._write_ready)
669             self._loop._remove_writer(self._fileno)
674                 self._loop._remove_writer(self._fileno)
677                     self._loop._remove_reader(self._fileno)
692             self._loop._remove_reader(self._fileno)
693             self._loop.call_soon(self._call_connection_lost, None)
721             if self._loop.get_debug():
724             self._loop.call_exception_handler({
735             self._loop._remove_writer(self._fileno)
737         self._loop._remove_reader(self._fileno)
738         self._loop.call_soon(self._call_connection_lost, exc)
747             self._loop = None
842         self._loop = None
857         if self._loop is not None and loop is None and self._callbacks:
863         if self._loop is not None:
864             self._loop.remove_signal_handler(signal.SIGCHLD)
866         self._loop = loop
881             self._loop.call_exception_handler({
922         if self._loop is None:
963             if self._loop.get_debug():
972             if self._loop.get_debug():
1023         if self._loop is None:
1070                         if self._loop.get_debug():
1077                     if self._loop.get_debug():
1103                     self._watcher.attach_loop(self._local._loop)