| hg-reviewers |
This is a handle on a callable that is called when the journal
is closed. The value is specified at init time. It doesn't
need to be exposed on the public interface. So mark it as private.
| Automatic diff as part of commit; lint not applicable. |
| Automatic diff as part of commit; unit tests not applicable. |
| # 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) | ||||
| self.names = [name] | self.names = [name] | ||||
| # A dict dedicated to precisely tracking the changes introduced in the | # A dict dedicated to precisely tracking the changes introduced in the | ||||
| if not c: | if not c: | ||||
| raise | raise | ||||
| # Abort may be raise by read only opener | # Abort may be raise by read only opener | ||||
| self.report("couldn't remove %s: %s\n" | self.report("couldn't remove %s: %s\n" | ||||
| % (vfs.join(b), inst)) | % (vfs.join(b), inst)) | ||||
| self._backupentries = [] | self._backupentries = [] | ||||
| self._journal = None | self._journal = None | ||||
| self.releasefn(self, True) # notify success of closing transaction | self._releasefn(self, True) # notify success of closing transaction | ||||
| self.releasefn = None # Help prevent cycles. | self._releasefn = None # Help prevent cycles. | ||||
| # run post close action | # run post close action | ||||
| categories = sorted(self._postclosecallback) | categories = sorted(self._postclosecallback) | ||||
| for cat in categories: | for cat in categories: | ||||
| self._postclosecallback[cat](self) | self._postclosecallback[cat](self) | ||||
| # Prevent double usage and help clear cycles. | # Prevent double usage and help clear cycles. | ||||
| self._postclosecallback = None | self._postclosecallback = None | ||||
| _playback(self._journal, self.report, self.opener, self._vfsmap, | _playback(self._journal, self.report, self.opener, self._vfsmap, | ||||
| self.entries, self._backupentries, False, | self.entries, self._backupentries, False, | ||||
| checkambigfiles=self.checkambigfiles) | checkambigfiles=self.checkambigfiles) | ||||
| self.report(_("rollback completed\n")) | self.report(_("rollback completed\n")) | ||||
| except BaseException: | except BaseException: | ||||
| self.report(_("rollback failed - please run hg recover\n")) | self.report(_("rollback failed - please run hg recover\n")) | ||||
| finally: | finally: | ||||
| self._journal = None | self._journal = None | ||||
| self.releasefn(self, False) # notify failure of transaction | self._releasefn(self, False) # notify failure of transaction | ||||
| self.releasefn = None # Help prevent cycles. | self._releasefn = None # Help prevent cycles. | ||||
| def rollback(opener, vfsmap, file, report, checkambigfiles=None): | def rollback(opener, vfsmap, file, report, checkambigfiles=None): | ||||
| """Rolls back the transaction contained in the given file | """Rolls back the transaction contained in the given file | ||||
| Reads the entries in the specified file, and the corresponding | Reads the entries in the specified file, and the corresponding | ||||
| '*.backupfiles' file, to recover from an incomplete transaction. | '*.backupfiles' file, to recover from an incomplete transaction. | ||||
| * `file`: a file containing a list of entries, specifying where | * `file`: a file containing a list of entries, specifying where | ||||