Lines Matching refs:_loop
34 if transport._loop.get_debug():
67 self._loop.call_soon(self._protocol.connection_made, self)
70 self._loop.call_soon(futures._set_result_unless_cancelled,
109 self._loop.call_soon(self._call_connection_lost, None)
122 if self._loop.get_debug():
125 self._loop.call_exception_handler({
152 self._loop.call_soon(self._call_connection_lost, exc)
192 self._loop.call_soon(self._loop_reading)
214 if self._loop.get_debug():
223 self._loop.call_soon(self._loop_reading, None)
230 self._loop.call_soon(self._data_received, self._data[:length], length)
232 if self._loop.get_debug():
236 if self._loop.get_debug():
305 self._read_fut = self._loop._proactor.recv_into(self._sock, self._data)
309 elif self._loop.get_debug():
391 self._loop.call_soon(self._call_connection_lost, None)
401 self._write_fut = self._loop._proactor.send(self._sock, data)
428 self._empty_waiter = self._loop.create_future()
440 self._read_fut = self._loop._proactor.recv(self._sock, 16)
473 self._loop.call_soon(self._loop_reading)
527 self._loop.call_soon(self._call_connection_lost, None)
533 self._write_fut = self._loop._proactor.send(self._sock,
536 self._write_fut = self._loop._proactor.sendto(self._sock,
573 self._read_fut = self._loop._proactor.recv(self._sock,
576 self._read_fut = self._loop._proactor.recvfrom(self._sock,