equal
deleted
inserted
replaced
1343 tracker = self._cnxset_tracker |
1343 tracker = self._cnxset_tracker |
1344 with self._lock: |
1344 with self._lock: |
1345 self._closed = True |
1345 self._closed = True |
1346 tracker.close() |
1346 tracker.close() |
1347 self.rollback() |
1347 self.rollback() |
1348 self.info('waiting for open transaction of session: %s', self) |
1348 self.debug('waiting for open transaction of session: %s', self) |
1349 timeout = 10 |
1349 timeout = 10 |
1350 pendings = tracker.wait(timeout) |
1350 pendings = tracker.wait(timeout) |
1351 if pendings: |
1351 if pendings: |
1352 self.error('%i transaction still alive after 10 seconds, will close ' |
1352 self.error('%i transaction still alive after 10 seconds, will close ' |
1353 'session anyway', len(pendings)) |
1353 'session anyway', len(pendings)) |