(self)
| 864 | connection.close() |
| 865 | |
| 866 | def _retrying_replace(self): |
| 867 | replaced = False |
| 868 | try: |
| 869 | replaced = self._add_conn_if_under_max() |
| 870 | except Exception: |
| 871 | log.exception("Failed replacing connection to %s", self.host) |
| 872 | if not replaced: |
| 873 | log.debug("Failed replacing connection to %s. Retrying.", self.host) |
| 874 | self._session.submit(self._retrying_replace) |
| 875 | |
| 876 | def shutdown(self): |
| 877 | with self._lock: |
nothing calls this directly
no test coverage detected