##// END OF EJS Templates
bundlespec: rationalize the way we specify stream bundle version...
marmoute -
r52451:c4aab366 default
parent child Browse files
Show More
@@ -1728,9 +1728,10 b' def writenewbundle('
1728 caps = {}
1728 caps = {}
1729 if opts.get(b'obsolescence', False):
1729 if opts.get(b'obsolescence', False):
1730 caps[b'obsmarkers'] = (b'V1',)
1730 caps[b'obsmarkers'] = (b'V1',)
1731 if opts.get(b'streamv2'):
1731 stream_version = opts.get(b'stream', b"")
1732 if stream_version == b"v2":
1732 caps[b'stream'] = [b'v2']
1733 caps[b'stream'] = [b'v2']
1733 elif opts.get(b'streamv3-exp'):
1734 elif stream_version == b"v3-exp":
1734 caps[b'stream'] = [b'v3-exp']
1735 caps[b'stream'] = [b'v3-exp']
1735 bundle = bundle20(ui, caps)
1736 bundle = bundle20(ui, caps)
1736 bundle.setcompression(compression, compopts)
1737 bundle.setcompression(compression, compopts)
@@ -1774,10 +1775,10 b' def _addpartsfromopts(ui, repo, bundler,'
1774 if repository.REPO_FEATURE_SIDE_DATA in repo.features:
1775 if repository.REPO_FEATURE_SIDE_DATA in repo.features:
1775 part.addparam(b'exp-sidedata', b'1')
1776 part.addparam(b'exp-sidedata', b'1')
1776
1777
1777 if opts.get(b'streamv2', False):
1778 if opts.get(b'stream', b"") == b"v2":
1778 addpartbundlestream2(bundler, repo, stream=True)
1779 addpartbundlestream2(bundler, repo, stream=True)
1779
1780
1780 if opts.get(b'streamv3-exp', False):
1781 if opts.get(b'stream', b"") == b"v3-exp":
1781 addpartbundlestream2(bundler, repo, stream=True)
1782 addpartbundlestream2(bundler, repo, stream=True)
1782
1783
1783 if opts.get(b'tagsfnodescache', True):
1784 if opts.get(b'tagsfnodescache', True):
@@ -136,7 +136,7 b' class bundlespec:'
136 b'cg.version': b'02',
136 b'cg.version': b'02',
137 b'obsolescence': False,
137 b'obsolescence': False,
138 b'phases': False,
138 b'phases': False,
139 b"streamv2": True,
139 b"stream": "v2",
140 b'tagsfnodescache': False,
140 b'tagsfnodescache': False,
141 b'revbranchcache': False,
141 b'revbranchcache': False,
142 },
142 },
@@ -145,7 +145,7 b' class bundlespec:'
145 b'cg.version': b'03',
145 b'cg.version': b'03',
146 b'obsolescence': False,
146 b'obsolescence': False,
147 b'phases': False,
147 b'phases': False,
148 b"streamv3-exp": True,
148 b"stream": "v3-exp",
149 b'tagsfnodescache': False,
149 b'tagsfnodescache': False,
150 b'revbranchcache': False,
150 b'revbranchcache': False,
151 },
151 },
@@ -388,10 +388,7 b' def isstreamclonespec(bundlespec):'
388 if (
388 if (
389 bundlespec.wirecompression == b'UN'
389 bundlespec.wirecompression == b'UN'
390 and bundlespec.wireversion == b'02'
390 and bundlespec.wireversion == b'02'
391 and (
391 and bundlespec.contentopts.get(b'stream', None) in (b"v2", b"v3-exp")
392 bundlespec.contentopts.get(b'streamv2')
393 or bundlespec.contentopts.get(b'streamv3-exp')
394 )
395 ):
392 ):
396 return True
393 return True
397
394
General Comments 0
You need to be logged in to leave comments. Login now