| dlax | |
| durin42 |
| hg-reviewers |
I like avoiding patterns that lead to the pyramid of doom.
| Automatic diff as part of commit; lint not applicable. |
| Automatic diff as part of commit; unit tests not applicable. |
| # dict with the mapping 'filename' -> position in the bundle | # dict with the mapping 'filename' -> position in the bundle | ||||
| self.bundlefilespos = {} | self.bundlefilespos = {} | ||||
| self.firstnewrev = self.changelog.repotiprev + 1 | self.firstnewrev = self.changelog.repotiprev + 1 | ||||
| phases.retractboundary(self, None, phases.draft, | phases.retractboundary(self, None, phases.draft, | ||||
| [ctx.node() for ctx in self[self.firstnewrev:]]) | [ctx.node() for ctx in self[self.firstnewrev:]]) | ||||
| def _handlebundle2part(self, bundle, part): | def _handlebundle2part(self, bundle, part): | ||||
| if part.type == 'changegroup': | if part.type != 'changegroup': | ||||
| return | |||||
| cgstream = part | cgstream = part | ||||
| version = part.params.get('version', '01') | version = part.params.get('version', '01') | ||||
| legalcgvers = changegroup.supportedincomingversions(self) | legalcgvers = changegroup.supportedincomingversions(self) | ||||
| if version not in legalcgvers: | if version not in legalcgvers: | ||||
| msg = _('Unsupported changegroup version: %s') | msg = _('Unsupported changegroup version: %s') | ||||
| raise error.Abort(msg % version) | raise error.Abort(msg % version) | ||||
| if bundle.compressed(): | if bundle.compressed(): | ||||
| cgstream = self._writetempbundle(part.read, | cgstream = self._writetempbundle(part.read, '.cg%sun' % version) | ||||
| ".cg%sun" % version) | |||||
| self._cgunpacker = changegroup.getunbundler(version, cgstream, | self._cgunpacker = changegroup.getunbundler(version, cgstream, 'UN') | ||||
| 'UN') | |||||
| def _writetempbundle(self, readfn, suffix, header=''): | def _writetempbundle(self, readfn, suffix, header=''): | ||||
| """Write a temporary file to disk | """Write a temporary file to disk | ||||
| """ | """ | ||||
| fdtemp, temp = self.vfs.mkstemp(prefix="hg-bundle-", | fdtemp, temp = self.vfs.mkstemp(prefix="hg-bundle-", | ||||
| suffix=suffix) | suffix=suffix) | ||||
| self.tempfile = temp | self.tempfile = temp | ||||