Show More
@@ -165,9 +165,6 b" configitem('infinitepush', 'storeallpart" | |||||
165 | configitem('infinitepush', 'reponame', |
|
165 | configitem('infinitepush', 'reponame', | |
166 | default='', |
|
166 | default='', | |
167 | ) |
|
167 | ) | |
168 | configitem('infinitepush', 'bundle-stream', |
|
|||
169 | default=False, |
|
|||
170 | ) |
|
|||
171 | configitem('scratchbranch', 'storepath', |
|
168 | configitem('scratchbranch', 'storepath', | |
172 | default='', |
|
169 | default='', | |
173 | ) |
|
170 | ) | |
@@ -360,7 +357,6 b' def clientextsetup(ui):' | |||||
360 | extensions.wrapcommand(commands.table, 'update', _update) |
|
357 | extensions.wrapcommand(commands.table, 'update', _update) | |
361 |
|
358 | |||
362 | extensions.wrapfunction(discovery, 'checkheads', _checkheads) |
|
359 | extensions.wrapfunction(discovery, 'checkheads', _checkheads) | |
363 | extensions.wrapfunction(bundle2, '_addpartsfromopts', _addpartsfromopts) |
|
|||
364 |
|
360 | |||
365 | wireproto.wirepeer.listkeyspatterns = listkeyspatterns |
|
361 | wireproto.wirepeer.listkeyspatterns = listkeyspatterns | |
366 |
|
362 | |||
@@ -427,18 +423,6 b' def _checkheads(orig, pushop):' | |||||
427 | return |
|
423 | return | |
428 | return orig(pushop) |
|
424 | return orig(pushop) | |
429 |
|
425 | |||
430 | def _addpartsfromopts(orig, ui, repo, bundler, *args, **kwargs): |
|
|||
431 | """ adds a stream level part to bundle2 storing whether this is an |
|
|||
432 | infinitepush bundle or not |
|
|||
433 | This functionality is hidden behind a config option: |
|
|||
434 |
|
||||
435 | [infinitepush] |
|
|||
436 | bundle-stream = True |
|
|||
437 | """ |
|
|||
438 | if ui.configbool('infinitepush', 'bundle-stream', False): |
|
|||
439 | bundler.addparam('infinitepush', True) |
|
|||
440 | return orig(ui, repo, bundler, *args, **kwargs) |
|
|||
441 |
|
||||
442 | def wireprotolistkeyspatterns(repo, proto, namespace, patterns): |
|
426 | def wireprotolistkeyspatterns(repo, proto, namespace, patterns): | |
443 | patterns = wireproto.decodelist(patterns) |
|
427 | patterns = wireproto.decodelist(patterns) | |
444 | d = repo.listkeys(encoding.tolocal(namespace), patterns).iteritems() |
|
428 | d = repo.listkeys(encoding.tolocal(namespace), patterns).iteritems() | |
@@ -1255,14 +1239,6 b' def storebundle(op, params, bundlefile):' | |||||
1255 | if bundle: |
|
1239 | if bundle: | |
1256 | bundle.close() |
|
1240 | bundle.close() | |
1257 |
|
1241 | |||
1258 | @bundle2.b2streamparamhandler('infinitepush') |
|
|||
1259 | def processinfinitepush(unbundler, param, value): |
|
|||
1260 | """ process the bundle2 stream level parameter containing whether this push |
|
|||
1261 | is an infinitepush or not. """ |
|
|||
1262 | if value and unbundler.ui.configbool('infinitepush', |
|
|||
1263 | 'bundle-stream', False): |
|
|||
1264 | pass |
|
|||
1265 |
|
||||
1266 | @bundle2.parthandler(scratchbranchparttype, |
|
1242 | @bundle2.parthandler(scratchbranchparttype, | |
1267 | ('bookmark', 'bookprevnode' 'create', 'force', |
|
1243 | ('bookmark', 'bookprevnode' 'create', 'force', | |
1268 | 'pushbackbookmarks', 'cgversion')) |
|
1244 | 'pushbackbookmarks', 'cgversion')) |
General Comments 0
You need to be logged in to leave comments.
Login now