(self)
| 874 | self._session.submit(self._retrying_replace) |
| 875 | |
| 876 | def shutdown(self): |
| 877 | with self._lock: |
| 878 | if self.is_shutdown: |
| 879 | return |
| 880 | else: |
| 881 | self.is_shutdown = True |
| 882 | |
| 883 | self._signal_all_available_conn() |
| 884 | for conn in self._connections: |
| 885 | conn.close() |
| 886 | self.open_count -= 1 |
| 887 | |
| 888 | for conn in self._trash: |
| 889 | conn.close() |
| 890 | |
| 891 | def ensure_core_connections(self): |
| 892 | if self.is_shutdown: |
no test coverage detected