(self, loop, sock, protocol, extra=None, server=None, context=None)
| 774 | _sock = None |
| 775 | |
| 776 | def __init__(self, loop, sock, protocol, extra=None, server=None, context=None): |
| 777 | super().__init__(extra, loop) |
| 778 | self._extra['socket'] = trsock.TransportSocket(sock) |
| 779 | try: |
| 780 | self._extra['sockname'] = sock.getsockname() |
| 781 | except OSError: |
| 782 | self._extra['sockname'] = None |
| 783 | if 'peername' not in self._extra: |
| 784 | try: |
| 785 | self._extra['peername'] = sock.getpeername() |
| 786 | except socket.error: |
| 787 | self._extra['peername'] = None |
| 788 | self._sock = sock |
| 789 | self._sock_fd = sock.fileno() |
| 790 | self._context = context |
| 791 | self._protocol_connected = False |
| 792 | self.set_protocol(protocol) |
| 793 | |
| 794 | self._server = server |
| 795 | self._buffer = collections.deque() |
| 796 | self._buffer_size = 0 |
| 797 | self._conn_lost = 0 # Set when call to connection_lost scheduled. |
| 798 | self._closing = False # Set when close() called. |
| 799 | self._paused = False # Set when pause_reading() called |
| 800 | |
| 801 | if self._server is not None: |
| 802 | self._server._attach(self) |
| 803 | loop._transports[self._sock_fd] = self |
| 804 | |
| 805 | def __repr__(self): |
| 806 | info = [self.__class__.__name__] |
no test coverage detected