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 |
|
|
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 |
|
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'stream |
|
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'stream |
|
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"stream |
|
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"stream |
|
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