equal
deleted
inserted
replaced
162 chunks = exchange.getbundlechunks(self._repo, source, heads=heads, |
162 chunks = exchange.getbundlechunks(self._repo, source, heads=heads, |
163 common=common, bundlecaps=bundlecaps, |
163 common=common, bundlecaps=bundlecaps, |
164 **kwargs) |
164 **kwargs) |
165 cb = util.chunkbuffer(chunks) |
165 cb = util.chunkbuffer(chunks) |
166 |
166 |
167 if bundlecaps is not None and 'HG20' in bundlecaps: |
167 if exchange.bundle2requested(bundlecaps): |
168 # When requesting a bundle2, getbundle returns a stream to make the |
168 # When requesting a bundle2, getbundle returns a stream to make the |
169 # wire level function happier. We need to build a proper object |
169 # wire level function happier. We need to build a proper object |
170 # from it in local peer. |
170 # from it in local peer. |
171 return bundle2.getunbundler(self.ui, cb) |
171 return bundle2.getunbundler(self.ui, cb) |
172 else: |
172 else: |