

def _tunnel(self):
    self._set_hostport(self._tunnel_host, self._tunnel_port)
    connect_str = ('CONNECT %s:%d HTTP/1.0\r\n' % (self.host, self.port))
    connect_bytes = version.encode('ascii')
    self.send(connect_bytes)
    for (header, value) in self._tunnel_headers.items():
        header_str = ('%s: %s\r\n' % (header, value))
        header_bytes = header_str.encode('latin-1')
        self.send(header_bytes)
    self.send(bytes(b'\r\n'))
    response = self.response_class(self.sock, method=self._method)
    (version, code, message) = response._read_status()
    if (code != 200):
        self.close()
        raise socket.error(('Tunnel connection failed: %d %s' % (code, message.strip())))
    while True:
        line = response.fp.readline((_MAXLINE + 1))
        if (len(line) > _MAXLINE):
            raise LineTooLong('header line')
        if (not line):
            break
        if (line in (b'\r\n', b'\n', b'')):
            break

dataset/ETHPy150Open OpenCobolIDE/OpenCobolIDE/open_cobol_ide/extlibs/future/backports/http/client.py HTTPConnection._tunnel/VarMisuse@41/73 `connect_str`->`version`