(
self, sock, protocol_factory, ssl,
server_hostname, server_side=False,
ssl_handshake_timeout=None,
ssl_shutdown_timeout=None, context=None)
| 1213 | return transport, protocol |
| 1214 | |
| 1215 | async def _create_connection_transport( |
| 1216 | self, sock, protocol_factory, ssl, |
| 1217 | server_hostname, server_side=False, |
| 1218 | ssl_handshake_timeout=None, |
| 1219 | ssl_shutdown_timeout=None, context=None): |
| 1220 | |
| 1221 | sock.setblocking(False) |
| 1222 | context = context if context is not None else contextvars.copy_context() |
| 1223 | |
| 1224 | protocol = protocol_factory() |
| 1225 | waiter = self.create_future() |
| 1226 | if ssl: |
| 1227 | sslcontext = None if isinstance(ssl, bool) else ssl |
| 1228 | transport = self._make_ssl_transport( |
| 1229 | sock, protocol, sslcontext, waiter, |
| 1230 | server_side=server_side, server_hostname=server_hostname, |
| 1231 | ssl_handshake_timeout=ssl_handshake_timeout, |
| 1232 | ssl_shutdown_timeout=ssl_shutdown_timeout, |
| 1233 | context=context) |
| 1234 | else: |
| 1235 | transport = self._make_socket_transport(sock, protocol, waiter, context=context) |
| 1236 | |
| 1237 | try: |
| 1238 | await waiter |
| 1239 | except: |
| 1240 | transport.close() |
| 1241 | raise |
| 1242 | |
| 1243 | return transport, protocol |
| 1244 | |
| 1245 | async def sendfile(self, transport, file, offset=0, count=None, |
| 1246 | *, fallback=True): |
no test coverage detected