| hg-reviewers |
This is similar to releasefn. It holds state that doesn't need to be
exposed as part of the public interface.
| Automatic diff as part of commit; lint not applicable. |
| Automatic diff as part of commit; unit tests not applicable. |
| self._journal = journalname | self._journal = journalname | ||||
| self._undoname = undoname | self._undoname = undoname | ||||
| self._queue = [] | self._queue = [] | ||||
| # A callback to validate transaction content before closing it. | # A callback to validate transaction content before closing it. | ||||
| # should raise exception is anything is wrong. | # should raise exception is anything is wrong. | ||||
| # target user is repository hooks. | # target user is repository hooks. | ||||
| if validator is None: | if validator is None: | ||||
| validator = lambda tr: None | validator = lambda tr: None | ||||
| self.validator = validator | self._validator = validator | ||||
| # A callback to do something just after releasing transaction. | # A callback to do something just after releasing transaction. | ||||
| if releasefn is None: | if releasefn is None: | ||||
| releasefn = lambda tr, success: None | releasefn = lambda tr, success: None | ||||
| self._releasefn = releasefn | self._releasefn = releasefn | ||||
| self.checkambigfiles = set() | self.checkambigfiles = set() | ||||
| if checkambigfiles: | if checkambigfiles: | ||||
| self.checkambigfiles.update(checkambigfiles) | self.checkambigfiles.update(checkambigfiles) | ||||
| with a newer callback. | with a newer callback. | ||||
| """ | """ | ||||
| self._abortcallback[category] = callback | self._abortcallback[category] = callback | ||||
| @active | @active | ||||
| def close(self): | def close(self): | ||||
| '''commit the transaction''' | '''commit the transaction''' | ||||
| if self._count == 1: | if self._count == 1: | ||||
| self.validator(self) # will raise exception if needed | self._validator(self) # will raise exception if needed | ||||
| self.validator = None # Help prevent cycles. | self._validator = None # Help prevent cycles. | ||||
| self._generatefiles(group=gengroupprefinalize) | self._generatefiles(group=gengroupprefinalize) | ||||
| categories = sorted(self._finalizecallback) | categories = sorted(self._finalizecallback) | ||||
| for cat in categories: | for cat in categories: | ||||
| self._finalizecallback[cat](self) | self._finalizecallback[cat](self) | ||||
| # Prevent double usage and help clear cycles. | # Prevent double usage and help clear cycles. | ||||
| self._finalizecallback = None | self._finalizecallback = None | ||||
| self._generatefiles(group=gengrouppostfinalize) | self._generatefiles(group=gengrouppostfinalize) | ||||