comparison hgext3rd/topic/discovery.py @ 2673:1014341c637b

topic: also detect head checking using the concurrent part
author Pierre-Yves David <pierre-yves.david@octobus.net>
date Wed, 28 Jun 2017 17:23:43 +0200
parents 13313d0cab71
children 9585fac76d2d
comparison
equal deleted inserted replaced
2672:a08bd434a19b 2673:1014341c637b
127 return oldvalidator(tr) 127 return oldvalidator(tr)
128 tr.validator = validator 128 tr.validator = validator
129 handlecheckheads.params = frozenset() 129 handlecheckheads.params = frozenset()
130 130
131 def _pushb2phases(orig, pushop, bundler): 131 def _pushb2phases(orig, pushop, bundler):
132 hascheck = any(p.type == 'check:heads' for p in bundler._parts) 132 checktypes = ('check:heads', 'check:updated-heads')
133 if pushop.outdatedphases and not hascheck: 133 hascheck = any(p.type in checktypes for p in bundler._parts)
134 if not hascheck and pushop.outdatedphases:
134 exchange._pushb2ctxcheckheads(pushop, bundler) 135 exchange._pushb2ctxcheckheads(pushop, bundler)
135 return orig(pushop, bundler) 136 return orig(pushop, bundler)
136 137
137 def wireprotocaps(orig, repo, proto): 138 def wireprotocaps(orig, repo, proto):
138 caps = orig(repo, proto) 139 caps = orig(repo, proto)