187 else: |
187 else: |
188 tr._validator = validator |
188 tr._validator = validator |
189 handlecheckheads.params = frozenset() |
189 handlecheckheads.params = frozenset() |
190 |
190 |
191 def _pushb2phases(orig, pushop, bundler): |
191 def _pushb2phases(orig, pushop, bundler): |
192 checktypes = ('check:heads', 'check:updated-heads') |
192 if common.hastopicext(pushop.repo): |
193 hascheck = any(p.type in checktypes for p in bundler._parts) |
193 checktypes = ('check:heads', 'check:updated-heads') |
194 if not hascheck and pushop.outdatedphases: |
194 hascheck = any(p.type in checktypes for p in bundler._parts) |
195 exchange._pushb2ctxcheckheads(pushop, bundler) |
195 if not hascheck and pushop.outdatedphases: |
|
196 exchange._pushb2ctxcheckheads(pushop, bundler) |
196 return orig(pushop, bundler) |
197 return orig(pushop, bundler) |
197 |
198 |
198 def wireprotocaps(orig, repo, proto): |
199 def wireprotocaps(orig, repo, proto): |
199 caps = orig(repo, proto) |
200 caps = orig(repo, proto) |
200 if repo.peer().capable('topics'): |
201 if repo.peer().capable('topics'): |