| hg-reviewers |
This is another callable that is passed in at init time. It
doesn't need to be part of the public interface.
| Lint Skipped |
| Unit Tests Skipped |
| Path | Packages | |||
|---|---|---|---|---|
| M | mercurial/transaction.py (8 lines) |
| Commit | Parents | Author | Summary | Date |
|---|---|---|---|---|
| Gregory Szorc | Sep 17 2018, 7:04 PM |
| self._usages = 1 | self._usages = 1 | ||||
| self.report = report | self.report = report | ||||
| # a vfs to the store content | # a vfs to the store content | ||||
| self.opener = opener | self.opener = opener | ||||
| # a map to access file in various {location -> vfs} | # a map to access file in various {location -> vfs} | ||||
| vfsmap = vfsmap.copy() | vfsmap = vfsmap.copy() | ||||
| vfsmap[''] = opener # set default value | vfsmap[''] = opener # set default value | ||||
| self._vfsmap = vfsmap | self._vfsmap = vfsmap | ||||
| self.after = after | self._after = after | ||||
| self.entries = [] | self.entries = [] | ||||
| self.map = {} | self.map = {} | ||||
| 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. | ||||
| except (IOError, OSError, error.Abort) as inst: | except (IOError, OSError, error.Abort) as inst: | ||||
| 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.entries = [] | self.entries = [] | ||||
| self._writeundo() | self._writeundo() | ||||
| if self.after: | if self._after: | ||||
| self.after() | self._after() | ||||
| self.after = None # Help prevent cycles. | self._after = None # Help prevent cycles. | ||||
| if self.opener.isfile(self._backupjournal): | if self.opener.isfile(self._backupjournal): | ||||
| self.opener.unlink(self._backupjournal) | self.opener.unlink(self._backupjournal) | ||||
| if self.opener.isfile(self._journal): | if self.opener.isfile(self._journal): | ||||
| self.opener.unlink(self._journal) | self.opener.unlink(self._journal) | ||||
| for l, _f, b, c in self._backupentries: | for l, _f, b, c in self._backupentries: | ||||
| if l not in self._vfsmap and c: | if l not in self._vfsmap and c: | ||||
| self.report("couldn't remove %s: unknown cache location" | self.report("couldn't remove %s: unknown cache location" | ||||
| "%s\n" % (b, l)) | "%s\n" % (b, l)) | ||||