equal
deleted
inserted
replaced
1223 self._clear_cnx_storage(cnx) |
1223 self._clear_cnx_storage(cnx) |
1224 |
1224 |
1225 def _clear_thread_storage(self, cnx): |
1225 def _clear_thread_storage(self, cnx): |
1226 self._cnxs.pop(cnx.connectionid, None) |
1226 self._cnxs.pop(cnx.connectionid, None) |
1227 try: |
1227 try: |
1228 del self.__threaddata.cnx |
1228 if self.__threaddata.cnx is cnx: |
|
1229 del self.__threaddata.cnx |
1229 except AttributeError: |
1230 except AttributeError: |
1230 pass |
1231 pass |
1231 |
1232 |
1232 def _clear_cnx_storage(self, cnx): |
1233 def _clear_cnx_storage(self, cnx): |
1233 cnx.clear() |
1234 cnx.clear() |