This is an archive of the discontinued Mercurial Phabricator instance.

Differential D9123

changing-files: split the changing files computation from encoding
ClosedPublic

Authored by marmoute on Sep 30 2020, 9:10 AM.

Details

Reviewers
Alphare
pulkit
Group Reviewers
hg-reviewers
Commits
rHGcf474af69766: changing-files: split the changing files computation from encoding
rHGd79c2c71a0a9: changing-files: split the changing files computation from encoding
rHGb63e5c1e2c44: changing-files: split the changing files computation from encoding
Summary

The side data encoding is already in its own function, now we move the changing
files computation in it own function, it will receive more updates in the
coming changesets.

Diff Detail

Repository
rHG Mercurial
Branch
default
Lint
No Linters Available
Unit
No Unit Test Coverage

Revision Contents
Changeset List

PathPackages
Mmercurial/metadata.py (28 lines)

Diff 22943

mercurial/metadata.py

del self.copied_from_p2 del self.copied_from_p2
self._p2_copies[dest] = source self._p2_copies[dest] = source
def update_copies_from_p2(self, copies): def update_copies_from_p2(self, copies):
for dest, source in copies.items(): for dest, source in copies.items():
self.mark_copied_from_p2(source, dest) self.mark_copied_from_p2(source, dest)
def compute_all_files_changes(ctx):
"""compute the files changed by a revision"""
filescopies = computechangesetcopies(ctx)
filesadded = computechangesetfilesadded(ctx)
filesremoved = computechangesetfilesremoved(ctx)
filesmerged = computechangesetfilesmerged(ctx)
files = ChangingFiles()
files.update_touched(ctx.files())
files.update_added(filesadded)
files.update_removed(filesremoved)
files.update_merged(filesmerged)
files.update_copies_from_p1(filescopies[0])
files.update_copies_from_p2(filescopies[1])
return files
def computechangesetfilesadded(ctx): def computechangesetfilesadded(ctx):
"""return the list of files added in a changeset """return the list of files added in a changeset
""" """
added = [] added = []
for f in ctx.files(): for f in ctx.files():
if not any(f in p for p in ctx.parents()): if not any(f in p for p in ctx.parents()):
added.append(f) added.append(f)
return added return added
for copied, filename, copy_idx in copies: for copied, filename, copy_idx in copies:
copied(all_files[copy_idx], filename) copied(all_files[copy_idx], filename)
return md return md
def _getsidedata(srcrepo, rev): def _getsidedata(srcrepo, rev):
ctx = srcrepo[rev] ctx = srcrepo[rev]
filescopies = computechangesetcopies(ctx) files = compute_all_files_changes(ctx)
filesadded = computechangesetfilesadded(ctx)
filesremoved = computechangesetfilesremoved(ctx)
filesmerged = computechangesetfilesmerged(ctx)
files = ChangingFiles()
files.update_touched(ctx.files())
files.update_added(filesadded)
files.update_removed(filesremoved)
files.update_merged(filesmerged)
files.update_copies_from_p1(filescopies[0])
files.update_copies_from_p2(filescopies[1])
return encode_files_sidedata(files) return encode_files_sidedata(files)
def getsidedataadder(srcrepo, destrepo): def getsidedataadder(srcrepo, destrepo):
use_w = srcrepo.ui.configbool(b'experimental', b'worker.repository-upgrade') use_w = srcrepo.ui.configbool(b'experimental', b'worker.repository-upgrade')
if pycompat.iswindows or not use_w: if pycompat.iswindows or not use_w:
return _get_simple_sidedata_adder(srcrepo, destrepo) return _get_simple_sidedata_adder(srcrepo, destrepo)
else: else: