Show More
@@ -319,19 +319,19 b' class bundlerepository(localrepo.localre' | |||||
319 | [ctx.node() for ctx in self[self.firstnewrev:]]) |
|
319 | [ctx.node() for ctx in self[self.firstnewrev:]]) | |
320 |
|
320 | |||
321 | def _handlebundle2part(self, bundle, part): |
|
321 | def _handlebundle2part(self, bundle, part): | |
322 |
if part.type |
|
322 | if part.type != 'changegroup': | |
323 |
|
|
323 | return | |
324 | version = part.params.get('version', '01') |
|
|||
325 | legalcgvers = changegroup.supportedincomingversions(self) |
|
|||
326 | if version not in legalcgvers: |
|
|||
327 | msg = _('Unsupported changegroup version: %s') |
|
|||
328 | raise error.Abort(msg % version) |
|
|||
329 | if bundle.compressed(): |
|
|||
330 | cgstream = self._writetempbundle(part.read, |
|
|||
331 | ".cg%sun" % version) |
|
|||
332 |
|
324 | |||
333 | self._cgunpacker = changegroup.getunbundler(version, cgstream, |
|
325 | cgstream = part | |
334 | 'UN') |
|
326 | version = part.params.get('version', '01') | |
|
327 | legalcgvers = changegroup.supportedincomingversions(self) | |||
|
328 | if version not in legalcgvers: | |||
|
329 | msg = _('Unsupported changegroup version: %s') | |||
|
330 | raise error.Abort(msg % version) | |||
|
331 | if bundle.compressed(): | |||
|
332 | cgstream = self._writetempbundle(part.read, '.cg%sun' % version) | |||
|
333 | ||||
|
334 | self._cgunpacker = changegroup.getunbundler(version, cgstream, 'UN') | |||
335 |
|
335 | |||
336 | def _writetempbundle(self, readfn, suffix, header=''): |
|
336 | def _writetempbundle(self, readfn, suffix, header=''): | |
337 | """Write a temporary file to disk |
|
337 | """Write a temporary file to disk |
General Comments 0
You need to be logged in to leave comments.
Login now