| hg-reviewers |
This is used to report the transaction name in repr. It is
very obviously an implementation detail and doesn't need to be
exposed as part of 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. |
| 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 | ||||
| # transaction. | # transaction. | ||||
| self.changes = {} | self.changes = {} | ||||
| # a dict of arguments to be passed to hooks | # a dict of arguments to be passed to hooks | ||||
| self.hookargs = {} | self.hookargs = {} | ||||
| self._file = opener.open(self._journal, "w") | self._file = opener.open(self._journal, "w") | ||||
| # holds callback to call when writing the transaction | # holds callback to call when writing the transaction | ||||
| self._finalizecallback = {} | self._finalizecallback = {} | ||||
| # hold callback for post transaction close | # hold callback for post transaction close | ||||
| self._postclosecallback = {} | self._postclosecallback = {} | ||||
| # holds callbacks to call during abort | # holds callbacks to call during abort | ||||
| self._abortcallback = {} | self._abortcallback = {} | ||||
| def __repr__(self): | def __repr__(self): | ||||
| name = r'/'.join(self.names) | name = r'/'.join(self._names) | ||||
| return (r'<transaction name=%s, count=%d, usages=%d>' % | return (r'<transaction name=%s, count=%d, usages=%d>' % | ||||
| (name, self._count, self._usages)) | (name, self._count, self._usages)) | ||||
| def __del__(self): | def __del__(self): | ||||
| if self._journal: | if self._journal: | ||||
| self._abort() | self._abort() | ||||
| @active | @active | ||||
| self.entries[index] = (file, offset, data) | self.entries[index] = (file, offset, data) | ||||
| self._file.write("%s\0%d\n" % (file, offset)) | self._file.write("%s\0%d\n" % (file, offset)) | ||||
| self._file.flush() | self._file.flush() | ||||
| @active | @active | ||||
| def nest(self, name=r'<unnamed>'): | def nest(self, name=r'<unnamed>'): | ||||
| self._count += 1 | self._count += 1 | ||||
| self._usages += 1 | self._usages += 1 | ||||
| self.names.append(name) | self._names.append(name) | ||||
| return self | return self | ||||
| def release(self): | def release(self): | ||||
| if self._count > 0: | if self._count > 0: | ||||
| self._usages -= 1 | self._usages -= 1 | ||||
| if self.names: | if self._names: | ||||
| self.names.pop() | self._names.pop() | ||||
| # if the transaction scopes are left without being closed, fail | # if the transaction scopes are left without being closed, fail | ||||
| if self._count > 0 and self._usages == 0: | if self._count > 0 and self._usages == 0: | ||||
| self._abort() | self._abort() | ||||
| def running(self): | def running(self): | ||||
| return self._count > 0 | return self._count > 0 | ||||
| def addpending(self, category, callback): | def addpending(self, category, callback): | ||||