##// END OF EJS Templates
infinitepush: remove wrapping around bundle2._addpartsfromopts()...
Pulkit Goyal -
r37209:e702ca15 default
parent child Browse files
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