facebook/sapling
1
1
Fork 0
mirror of https://github.com/facebook/sapling.git synced 2025-01-07 22:21:40 +03:00
Code Issues Projects Releases Wiki Activity

checkheads: extract obsolete post processing in its own function

Browse Source 
The checkheads function is long and complex, extract that logic in a subfunction
is win in itself. As the comment in the code says, this postprocessing is
currently very basic and either misbehave or fails to detect valid push in many
cases. My deeper motive for this extraction is to be make it easier to provide
extensive testing of this case and strategy to cover them. Final test and logic
will makes it to core once done.
This commit is contained in:
Pierre-Yves David 2017-03-21 23:30:13 +01:00
parent ffc66837df
commit 3e8a941a87
1 changed files with 43 additions and 29 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

72
mercurial/discovery.py
View File

@ -343,38 +343,13 @@ def checkheads(pushop):
oldhs.update(unsyncedheads)
candidate_newhs.update(unsyncedheads)
dhs = None # delta heads, the new heads on branch
discardedheads = set()
if not repo.obsstore:
discardedheads = set()
newhs = candidate_newhs
else:
# remove future heads which are actually obsoleted by another
# pushed element:
#
# XXX as above, There are several cases this code does not handle
# XXX properly
#
# (1) if <nh> is public, it won't be affected by obsolete marker
# and a new is created
#
# (2) if the new heads have ancestors which are not obsolete and
# not ancestors of any other heads we will have a new head too.
#
# These two cases will be easy to handle for known changeset but
# much more tricky for unsynced changes.
#
# In addition, this code is confused by prune as it only looks for
# successors of the heads (none if pruned) leading to issue4354
newhs = set()
for nh in candidate_newhs:
if nh in repo and repo[nh].phase() <= phases.public:
newhs.add(nh)
else:
for suc in obsolete.allsuccessors(repo.obsstore, [nh]):
if suc != nh and suc in allfuturecommon:
discardedheads.add(nh)
break
else:
newhs.add(nh)
newhs, discardedheads = _postprocessobsolete(pushop,
allfuturecommon,
candidate_newhs)
unsynced = sorted(h for h in unsyncedheads if h not in discardedheads)
if unsynced:
if None in unsynced:
@ -434,3 +409,42 @@ def checkheads(pushop):
repo.ui.note((" %s\n") % short(h))
if errormsg:
raise error.Abort(errormsg, hint=hint)
def _postprocessobsolete(pushop, futurecommon, candidate_newhs):
"""post process the list of new heads with obsolescence information
Exists as a subfunction to contain the complexity and allow extensions to
experiment with smarter logic.
Returns (newheads, discarded_heads) tuple
"""
# remove future heads which are actually obsoleted by another
# pushed element:
#
# XXX as above, There are several cases this code does not handle
# XXX properly
#
# (1) if <nh> is public, it won't be affected by obsolete marker
# and a new is created
#
# (2) if the new heads have ancestors which are not obsolete and
# not ancestors of any other heads we will have a new head too.
#
# These two cases will be easy to handle for known changeset but
# much more tricky for unsynced changes.
#
# In addition, this code is confused by prune as it only looks for
# successors of the heads (none if pruned) leading to issue4354
repo = pushop.repo
newhs = set()
discarded = set()
for nh in candidate_newhs:
if nh in repo and repo[nh].phase() <= phases.public:
newhs.add(nh)
else:
for suc in obsolete.allsuccessors(repo.obsstore, [nh]):
if suc != nh and suc in futurecommon:
discarded.add(nh)
break
else:
newhs.add(nh)
return newhs, discarded