(self, user, passwd, host, port, dirs, timeout)
| 1581 | self.max_conns = m |
| 1582 | |
| 1583 | def connect_ftp(self, user, passwd, host, port, dirs, timeout): |
| 1584 | key = user, host, port, '/'.join(dirs), timeout |
| 1585 | conn = self.cache.get(key) |
| 1586 | if conn is None or not conn.keepalive: |
| 1587 | if conn is not None: |
| 1588 | conn.close() |
| 1589 | conn = self.cache[key] = ftpwrapper(user, passwd, host, port, |
| 1590 | dirs, timeout) |
| 1591 | self.timeout[key] = time.time() + self.delay |
| 1592 | self.check_cache() |
| 1593 | return conn |
| 1594 | |
| 1595 | def check_cache(self): |
| 1596 | # first check for old ones |
nothing calls this directly
no test coverage detected