Lines Matching refs:transport
209 raise TypeError("transport should be _FlowControlMixin instance")
229 def connection_made(self, transport):
470 """Create socket transport."""
480 """Create SSL transport."""
485 """Create datagram transport."""
490 """Create read pipe transport."""
495 """Create write pipe transport."""
501 """Create subprocess transport."""
997 Create a streaming transport connection to a given internet host and
1004 (transport, protocol) pair.
1112 transport, protocol = await self._create_connection_transport(
1117 # Get the socket from the transport because SSL transport closes
1119 sock = transport.get_extra_info('socket')
1121 sock, host, port, transport, protocol)
1122 return transport, protocol
1136 transport = self._make_ssl_transport(
1142 transport = self._make_socket_transport(sock, protocol, waiter)
1147 transport.close()
1150 return transport, protocol
1152 async def sendfile(self, transport, file, offset=0, count=None,
1154 """Send a file to transport.
1176 if transport.is_closing():
1178 mode = getattr(transport, '_sendfile_compatible',
1182 f"sendfile is not supported for transport {transport!r}")
1185 return await self._sendfile_native(transport, file,
1194 f"supported for transport {transport!r}")
1196 return await self._sendfile_fallback(transport, file,
1228 async def start_tls(self, transport, protocol, sslcontext, *,
1233 """Upgrade transport to TLS.
1235 Return a new transport that *protocol* should start using
1246 if not getattr(transport, '_start_tls_compatible', False):
1248 f'transport {transport!r} is not supported by start_tls()')
1260 transport.pause_reading()
1262 transport.set_protocol(ssl_protocol)
1263 conmade_cb = self.call_soon(ssl_protocol.connection_made, transport)
1264 resume_cb = self.call_soon(transport.resume_reading)
1269 transport.close()
1390 transport = self._make_datagram_transport(
1396 local_addr, remote_addr, transport, protocol)
1400 remote_addr, transport, protocol)
1405 transport.close()
1408 return transport, protocol
1575 transport, protocol = await self._create_connection_transport(
1580 # Get the socket from the transport because SSL transport closes
1582 sock = transport.get_extra_info('socket')
1583 logger.debug("%r handled: (%r, %r)", sock, transport, protocol)
1584 return transport, protocol
1589 transport = self._make_read_pipe_transport(pipe, protocol, waiter)
1594 transport.close()
1599 pipe.fileno(), transport, protocol)
1600 return transport, protocol
1605 transport = self._make_write_pipe_transport(pipe, protocol, waiter)
1610 transport.close()
1615 pipe.fileno(), transport, protocol)
1616 return transport, protocol
1661 transport = await self._make_subprocess_transport(
1664 logger.info('%s: %r', debug_log, transport)
1665 return transport, protocol
1694 transport = await self._make_subprocess_transport(
1698 logger.info('%s: %r', debug_log, transport)
1699 return transport, protocol
1784 - 'transport' (optional): Transport instance;