equal
deleted
inserted
replaced
1652 # do not close connections set on session close, since they are shared now |
1652 # do not close connections set on session close, since they are shared now |
1653 tracker = self._cnxset_tracker |
1653 tracker = self._cnxset_tracker |
1654 with self._lock: |
1654 with self._lock: |
1655 self._closed = True |
1655 self._closed = True |
1656 tracker.close() |
1656 tracker.close() |
1657 self._rollback() |
1657 if self._cnx._session_handled: |
|
1658 self._rollback() |
1658 self.debug('waiting for open connection of session: %s', self) |
1659 self.debug('waiting for open connection of session: %s', self) |
1659 timeout = 10 |
1660 timeout = 10 |
1660 pendings = tracker.wait(timeout) |
1661 pendings = tracker.wait(timeout) |
1661 if pendings: |
1662 if pendings: |
1662 self.error('%i connection still alive after 10 seconds, will close ' |
1663 self.error('%i connection still alive after 10 seconds, will close ' |