This is an archive of the discontinued Mercurial Phabricator instance.

Differential D5375

remotefilelog: use progress helper when analyzing repos
ClosedPublic

Authored by martinvonz on Dec 5 2018, 12:39 PM.

Details

Reviewers
None
Group Reviewers
hg-reviewers
Commits
rHG05afb32e9380: remotefilelog: use progress helper when analyzing repos
Summary

Diff Detail

Repository
rHG Mercurial
Lint
Lint Skipped
Unit
Unit Tests Skipped

Event Timeline

martinvonz created this revision.Dec 5 2018, 12:39 PM
Closed by commit rHG05afb32e9380: remotefilelog: use progress helper when analyzing repos (authored by martinvonz). · Explain WhyDec 6 2018, 6:41 AM
This revision was automatically updated to reflect the committed changes.

Revision Contents
Changeset List

PathPackages
Mhgext/remotefilelog/__init__.py (8 lines)

Diff 12714

hgext/remotefilelog/__init__.py

reposfile = open(repospath, 'r') reposfile = open(repospath, 'r')
repos = set([r[:-1] for r in reposfile.readlines()]) repos = set([r[:-1] for r in reposfile.readlines()])
reposfile.close() reposfile.close()
# build list of useful files # build list of useful files
validrepos = [] validrepos = []
keepkeys = set() keepkeys = set()
_analyzing = _("analyzing repositories")
sharedcache = None sharedcache = None
filesrepacked = False filesrepacked = False
count = 0 count = 0
progress = ui.makeprogress(_("analyzing repositories"), unit="repos",
total=len(repos))
for path in repos: for path in repos:
ui.progress(_analyzing, count, unit="repos", total=len(repos)) progress.update(count)
count += 1 count += 1
try: try:
path = ui.expandpath(os.path.normpath(path)) path = ui.expandpath(os.path.normpath(path))
except TypeError as e: except TypeError as e:
ui.warn(_("warning: malformed path: %r:%s\n") % (path, e)) ui.warn(_("warning: malformed path: %r:%s\n") % (path, e))
traceback.print_exc() traceback.print_exc()
continue continue
try: try:
if not sharedcache: if not sharedcache:
sharedcache = repo.sharedstore sharedcache = repo.sharedstore
# Compute a keepset which is not garbage collected # Compute a keepset which is not garbage collected
def keyfn(fname, fnode): def keyfn(fname, fnode):
return fileserverclient.getcachekey(reponame, fname, hex(fnode)) return fileserverclient.getcachekey(reponame, fname, hex(fnode))
keepkeys = repackmod.keepset(repo, keyfn=keyfn, lastkeepkeys=keepkeys) keepkeys = repackmod.keepset(repo, keyfn=keyfn, lastkeepkeys=keepkeys)
ui.progress(_analyzing, None) progress.complete()
# write list of valid repos back # write list of valid repos back
oldumask = os.umask(0o002) oldumask = os.umask(0o002)
try: try:
reposfile = open(repospath, 'w') reposfile = open(repospath, 'w')
reposfile.writelines([("%s\n" % r) for r in validrepos]) reposfile.writelines([("%s\n" % r) for r in validrepos])
reposfile.close() reposfile.close()
finally: finally: