(transport, sock)
| 26 | |
| 27 | |
| 28 | def _set_socket_extra(transport, sock): |
| 29 | transport._extra['socket'] = trsock.TransportSocket(sock) |
| 30 | |
| 31 | try: |
| 32 | transport._extra['sockname'] = sock.getsockname() |
| 33 | except socket.error: |
| 34 | if transport._loop.get_debug(): |
| 35 | logger.warning( |
| 36 | "getsockname() failed on %r", sock, exc_info=True) |
| 37 | |
| 38 | if 'peername' not in transport._extra: |
| 39 | try: |
| 40 | transport._extra['peername'] = sock.getpeername() |
| 41 | except socket.error: |
| 42 | # UDP sockets may not have a peer name |
| 43 | transport._extra['peername'] = None |
| 44 | |
| 45 | |
| 46 | class _ProactorBasePipeTransport(transports._FlowControlMixin, |
no test coverage detected
searching dependent graphs…