Show More
@@ -319,7 +319,9 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 | return | |||
|
324 | ||||
323 |
|
|
325 | cgstream = part | |
324 |
|
|
326 | version = part.params.get('version', '01') | |
325 |
|
|
327 | legalcgvers = changegroup.supportedincomingversions(self) | |
@@ -327,11 +329,9 class bundlerepository(localrepo.localre | |||||
327 |
|
|
329 | msg = _('Unsupported changegroup version: %s') | |
328 |
|
|
330 | raise error.Abort(msg % version) | |
329 |
|
|
331 | if bundle.compressed(): | |
330 |
|
|
332 | cgstream = self._writetempbundle(part.read, '.cg%sun' % version) | |
331 | ".cg%sun" % version) |
|
|||
332 |
|
333 | |||
333 |
|
|
334 | self._cgunpacker = changegroup.getunbundler(version, cgstream, 'UN') | |
334 | '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