equal
deleted
inserted
replaced
465 for operation in processed: |
465 for operation in processed: |
466 operation.handle_event('revert%s_event' % trstate) |
466 operation.handle_event('revert%s_event' % trstate) |
467 self.rollback(reset_pool) |
467 self.rollback(reset_pool) |
468 raise |
468 raise |
469 self.pool.commit() |
469 self.pool.commit() |
|
470 self.commit_state = trstate = 'postcommit' |
|
471 while self.pending_operations: |
|
472 operation = self.pending_operations.pop(0) |
|
473 operation.processed = trstate |
|
474 try: |
|
475 operation.handle_event('%s_event' % trstate) |
|
476 except: |
|
477 self.exception('error while %sing', trstate) |
|
478 self.debug('%s session %s done', trstate, self.id) |
470 finally: |
479 finally: |
471 self._touch() |
480 self._touch() |
472 self.commit_state = None |
481 self.commit_state = None |
473 self.pending_operations[:] = [] |
482 self.pending_operations[:] = [] |
474 self.transaction_data.clear() |
483 self.transaction_data.clear() |