| hg-reviewers |
It will be reused for the formatting of the requirements of the stream v2 part
requirement and later for the stream v2 requirements.
| Automatic diff as part of commit; lint not applicable. |
| Automatic diff as part of commit; unit tests not applicable. |
| Path | Packages | |||
|---|---|---|---|---|
| M | mercurial/exchange.py (11 lines) |
| Status | Author | Revision | |
|---|---|---|---|
| Closed | lothiraldan | ||
| Closed | lothiraldan | ||
| Closed | lothiraldan | ||
| Closed | lothiraldan | ||
| Closed | lothiraldan | ||
| Closed | lothiraldan | ||
| Closed | lothiraldan | ||
| Closed | lothiraldan | ||
| Closed | lothiraldan | ||
| Closed | lothiraldan |
| return changegroup.cg1unpacker(fh, alg) | return changegroup.cg1unpacker(fh, alg) | ||||
| elif version.startswith('2'): | elif version.startswith('2'): | ||||
| return bundle2.getunbundler(ui, fh, magicstring=magic + version) | return bundle2.getunbundler(ui, fh, magicstring=magic + version) | ||||
| elif version == 'S1': | elif version == 'S1': | ||||
| return streamclone.streamcloneapplier(fh) | return streamclone.streamcloneapplier(fh) | ||||
| else: | else: | ||||
| raise error.Abort(_('%s: unknown bundle version %s') % (fname, version)) | raise error.Abort(_('%s: unknown bundle version %s') % (fname, version)) | ||||
| def _formatrequirementsspec(requirements): | |||||
| return urlreq.quote(','.join(sorted(requirements))) | |||||
| def _formatrequirementsparams(requirements): | |||||
| requirements = _formatrequirementsspec(requirements) | |||||
| params = "%s%s" % (urlreq.quote("requirements="), requirements) | |||||
| return params | |||||
| def getbundlespec(ui, fh): | def getbundlespec(ui, fh): | ||||
| """Infer the bundlespec from a bundle file handle. | """Infer the bundlespec from a bundle file handle. | ||||
| The input file handle is seeked and the original seek position is not | The input file handle is seeked and the original seek position is not | ||||
| restored. | restored. | ||||
| """ | """ | ||||
| def speccompression(alg): | def speccompression(alg): | ||||
| try: | try: | ||||
| if not version: | if not version: | ||||
| raise error.Abort(_('could not identify changegroup version in ' | raise error.Abort(_('could not identify changegroup version in ' | ||||
| 'bundle')) | 'bundle')) | ||||
| return '%s-%s' % (comp, version) | return '%s-%s' % (comp, version) | ||||
| elif isinstance(b, streamclone.streamcloneapplier): | elif isinstance(b, streamclone.streamcloneapplier): | ||||
| requirements = streamclone.readbundle1header(fh)[2] | requirements = streamclone.readbundle1header(fh)[2] | ||||
| params = 'requirements=%s' % ','.join(sorted(requirements)) | return 'none-packed1;%s' % _formatrequirementsparams(requirements) | ||||
| return 'none-packed1;%s' % urlreq.quote(params) | |||||
| else: | else: | ||||
| raise error.Abort(_('unknown bundle type: %s') % b) | raise error.Abort(_('unknown bundle type: %s') % b) | ||||
| def _computeoutgoing(repo, heads, common): | def _computeoutgoing(repo, heads, common): | ||||
| """Computes which revs are outgoing given a set of common | """Computes which revs are outgoing given a set of common | ||||
| and a set of heads. | and a set of heads. | ||||
| This is a separate function so extensions can have access to | This is a separate function so extensions can have access to | ||||