mercurial-scm/hg-stable: mercurial/sparse.py comparison

comparison mercurial/sparse.py @ 43077:687b865b95ad

formatting: byteify all mercurial/ and hgext/ string literals Done with python3.7 contrib/byteify-strings.py -i $(hg files 'set:mercurial/**.py - mercurial/thirdparty/** + hgext/**.py - hgext/fsmonitor/pywatchman/** - mercurial/__init__.py') black -l 80 -t py33 -S $(hg files 'set:**.py - mercurial/thirdparty/** - "contrib/python-zstandard/**" - hgext/fsmonitor/pywatchman/**') # skip-blame mass-reformatting only Differential Revision: https://phab.mercurial-scm.org/D6972

author	Augie Fackler <augie@google.com>
date	Sun, 06 Oct 2019 09:48:39 -0400
parents	2372284d9457
children	d783f945a701

comparison

equal deleted inserted replaced

-:2372284d9457
+:687b865b95ad
 excludes = set()
 profiles = set()
 current = None
 havesection = False
-for line in raw.split('\n'):
+for line in raw.split(b'\n'):
 line = line.strip()
-if not line or line.startswith('#'):
+if not line or line.startswith(b'#'):
 # empty or comment line, skip
 continue
-elif line.startswith('%include '):
+elif line.startswith(b'%include '):
 line = line[9:].strip()
 if line:
 profiles.add(line)
-elif line == '[include]':
+elif line == b'[include]':
 if havesection and current != includes:
 # TODO pass filename into this API so we can report it.
 raise error.Abort(
 _(
-'%(action)s config cannot have includes '
+b'%(action)s config cannot have includes '
-'after excludes'
+b'after excludes'
 )
-% {'action': action}
+% {b'action': action}
 )
 havesection = True
 current = includes
 continue
-elif line == '[exclude]':
+elif line == b'[exclude]':
 havesection = True
 current = excludes
 elif line:
 if current is None:
 raise error.Abort(
-_('%(action)s config entry outside of ' 'section: %(line)s')
+_(
-% {'action': action, 'line': line},
+b'%(action)s config entry outside of '
+b'section: %(line)s'
+)
+% {b'action': action, b'line': line},
 hint=_(
-'add an [include] or [exclude] line '
+b'add an [include] or [exclude] line '
-'to declare the entry type'
+b'to declare the entry type'
 ),
 )
-if line.strip().startswith('/'):
+if line.strip().startswith(b'/'):
 ui.warn(
 _(
-'warning: %(action)s profile cannot use'
+b'warning: %(action)s profile cannot use'
-' paths starting with /, ignoring %(line)s\n'
+b' paths starting with /, ignoring %(line)s\n'
 )
-% {'action': action, 'line': line}
+% {b'action': action, b'line': line}
 )
 continue
 current.add(line)
 return includes, excludes, profiles
 """
 # Feature isn't enabled. No-op.
 if not enabled:
 return set(), set(), set()
-raw = repo.vfs.tryread('sparse')
+raw = repo.vfs.tryread(b'sparse')
 if not raw:
 return set(), set(), set()
 if rev is None:
 raise error.Abort(
-_('cannot parse sparse patterns from working ' 'directory')
+_(b'cannot parse sparse patterns from working ' b'directory')
 )
-includes, excludes, profiles = parseconfig(repo.ui, raw, 'sparse')
+includes, excludes, profiles = parseconfig(repo.ui, raw, b'sparse')
 ctx = repo[rev]
 if profiles:
 visited = set()
 while profiles:
 try:
 raw = readprofile(repo, profile, rev)
 except error.ManifestLookupError:
 msg = (
-"warning: sparse profile '%s' not found "
+b"warning: sparse profile '%s' not found "
-"in rev %s - ignoring it\n" % (profile, ctx)
+b"in rev %s - ignoring it\n" % (profile, ctx)
 )
 # experimental config: sparse.missingwarning
-if repo.ui.configbool('sparse', 'missingwarning'):
+if repo.ui.configbool(b'sparse', b'missingwarning'):
 repo.ui.warn(msg)
 else:
 repo.ui.debug(msg)
 continue
-pincludes, pexcludes, subprofs = parseconfig(repo.ui, raw, 'sparse')
+pincludes, pexcludes, subprofs = parseconfig(
+repo.ui, raw, b'sparse'
+)
 includes.update(pincludes)
 excludes.update(pexcludes)
 profiles.update(subprofs)
 profiles = visited
 if includes:
-includes.add('.hg*')
+includes.add(b'.hg*')
 return includes, excludes, profiles
 def activeconfig(repo):
 This is used to construct a cache key for matchers.
 """
 cache = repo._sparsesignaturecache
-signature = cache.get('signature')
+signature = cache.get(b'signature')
 if includetemp:
-tempsignature = cache.get('tempsignature')
+tempsignature = cache.get(b'tempsignature')
 else:
-tempsignature = '0'
+tempsignature = b'0'
 if signature is None or (includetemp and tempsignature is None):
-signature = hex(hashlib.sha1(repo.vfs.tryread('sparse')).digest())
+signature = hex(hashlib.sha1(repo.vfs.tryread(b'sparse')).digest())
-cache['signature'] = signature
+cache[b'signature'] = signature
 if includetemp:
-raw = repo.vfs.tryread('tempsparse')
+raw = repo.vfs.tryread(b'tempsparse')
 tempsignature = hex(hashlib.sha1(raw).digest())
-cache['tempsignature'] = tempsignature
+cache[b'tempsignature'] = tempsignature
-return '%s %s' % (signature, tempsignature)
+return b'%s %s' % (signature, tempsignature)
 def writeconfig(repo, includes, excludes, profiles):
 """Write the sparse config file given a sparse configuration."""
-with repo.vfs('sparse', 'wb') as fh:
+with repo.vfs(b'sparse', b'wb') as fh:
 for p in sorted(profiles):
-fh.write('%%include %s\n' % p)
+fh.write(b'%%include %s\n' % p)
 if includes:
-fh.write('[include]\n')
+fh.write(b'[include]\n')
 for i in sorted(includes):
 fh.write(i)
-fh.write('\n')
+fh.write(b'\n')
 if excludes:
-fh.write('[exclude]\n')
+fh.write(b'[exclude]\n')
 for e in sorted(excludes):
 fh.write(e)
-fh.write('\n')
+fh.write(b'\n')
 repo._sparsesignaturecache.clear()
 def readtemporaryincludes(repo):
-raw = repo.vfs.tryread('tempsparse')
+raw = repo.vfs.tryread(b'tempsparse')
 if not raw:
 return set()
-return set(raw.split('\n'))
+return set(raw.split(b'\n'))
 def writetemporaryincludes(repo, includes):
-repo.vfs.write('tempsparse', '\n'.join(sorted(includes)))
+repo.vfs.write(b'tempsparse', b'\n'.join(sorted(includes)))
 repo._sparsesignaturecache.clear()
 def addtemporaryincludes(repo, additional):
 includes = readtemporaryincludes(repo)
 includes.add(i)
 writetemporaryincludes(repo, includes)
 def prunetemporaryincludes(repo):
-if not enabled or not repo.vfs.exists('tempsparse'):
+if not enabled or not repo.vfs.exists(b'tempsparse'):
 return
 s = repo.status()
 if s.modified or s.added or s.removed or s.deleted:
 # Still have pending changes. Don't bother trying to prune.
 actions = []
 dropped = []
 tempincludes = readtemporaryincludes(repo)
 for file in tempincludes:
 if file in dirstate and not sparsematch(file):
-message = _('dropping temporarily included sparse files')
+message = _(b'dropping temporarily included sparse files')
 actions.append((file, None, message))
 dropped.append(file)
 typeactions = mergemod.emptyactions()
-typeactions['r'] = actions
+typeactions[b'r'] = actions
 mergemod.applyupdates(
-repo, typeactions, repo[None], repo['.'], False, wantfiledata=False
+repo, typeactions, repo[None], repo[b'.'], False, wantfiledata=False
 )
 # Fix dirstate
 for file in dropped:
 dirstate.drop(file)
-repo.vfs.unlink('tempsparse')
+repo.vfs.unlink(b'tempsparse')
 repo._sparsesignaturecache.clear()
 msg = _(
-'cleaned up %d temporarily added file(s) from the ' 'sparse checkout\n'
+b'cleaned up %d temporarily added file(s) from the '
+b'sparse checkout\n'
 )
 repo.ui.status(msg % len(tempincludes))
 def forceincludematcher(matcher, includes):
 """Returns a matcher that returns true for any of the forced includes
 before testing against the actual matcher."""
-kindpats = [('path', include, '') for include in includes]
+kindpats = [(b'path', include, b'') for include in includes]
-includematcher = matchmod.includematcher('', kindpats)
+includematcher = matchmod.includematcher(b'', kindpats)
 return matchmod.unionmatcher([includematcher, matcher])
 def matcher(repo, revs=None, includetemp=True):
 """Obtain a matcher for sparse working directories for the given revs.
 if node != nullid
 ]
 signature = configsignature(repo, includetemp=includetemp)
-key = '%s %s' % (signature, ' '.join(map(pycompat.bytestr, revs)))
+key = b'%s %s' % (signature, b' '.join(map(pycompat.bytestr, revs)))
 result = repo._sparsematchercache.get(key)
 if result:
 return result
 includes, excludes, profiles = patternsforrev(repo, rev)
 if includes or excludes:
 matcher = matchmod.match(
 repo.root,
-'',
+b'',
 [],
 include=includes,
 exclude=excludes,
-default='relpath',
+default=b'relpath',
 )
 matchers.append(matcher)
 except IOError:
 pass
 for file, action in actions.iteritems():
 type, args, msg = action
 files.add(file)
 if sparsematch(file):
 prunedactions[file] = action
-elif type == 'm':
+elif type == b'm':
 temporaryfiles.append(file)
 prunedactions[file] = action
 elif branchmerge:
-if type != 'k':
+if type != b'k':
 temporaryfiles.append(file)
 prunedactions[file] = action
-elif type == 'f':
+elif type == b'f':
 prunedactions[file] = action
 elif file in wctx:
-prunedactions[file] = ('r', args, msg)
+prunedactions[file] = (b'r', args, msg)
 if branchmerge and type == mergemod.ACTION_MERGE:
 f1, f2, fa, move, anc = args
 if not sparsematch(f1):
 temporaryfiles.append(f1)
 if len(temporaryfiles) > 0:
 repo.ui.status(
 _(
-'temporarily included %d file(s) in the sparse '
+b'temporarily included %d file(s) in the sparse '
-'checkout for merging\n'
+b'checkout for merging\n'
 )
 % len(temporaryfiles)
 )
 addtemporaryincludes(repo, temporaryfiles)
 # Add the new files to the working copy so they can be merged, etc
 actions = []
-message = 'temporarily adding to sparse checkout'
+message = b'temporarily adding to sparse checkout'
 wctxmanifest = repo[None].manifest()
 for file in temporaryfiles:
 if file in wctxmanifest:
 fctx = repo[None][file]
 actions.append((file, (fctx.flags(), False), message))
 typeactions = mergemod.emptyactions()
-typeactions['g'] = actions
+typeactions[b'g'] = actions
 mergemod.applyupdates(
-repo, typeactions, repo[None], repo['.'], False, wantfiledata=False
+repo, typeactions, repo[None], repo[b'.'], False, wantfiledata=False
 )
 dirstate = repo.dirstate
 for file, flags, msg in actions:
 dirstate.normal(file)
 for file in mf:
 old = oldsparsematch(file)
 new = sparsematch(file)
 if not old and new:
 flags = mf.flags(file)
-prunedactions[file] = ('g', (flags, False), '')
+prunedactions[file] = (b'g', (flags, False), b'')
 elif old and not new:
-prunedactions[file] = ('r', [], '')
+prunedactions[file] = (b'r', [], b'')
 return prunedactions
 def refreshwdir(repo, origstatus, origsparsematch, force=False):
 sparsematch = matcher(repo)
 abort = False
 for f in pending:
 if not sparsematch(f):
-repo.ui.warn(_("pending changes to '%s'\n") % f)
+repo.ui.warn(_(b"pending changes to '%s'\n") % f)
 abort = not force
 if abort:
 raise error.Abort(
-_('could not update sparseness due to pending ' 'changes')
+_(b'could not update sparseness due to pending ' b'changes')
 )
 # Calculate actions
 dirstate = repo.dirstate
-ctx = repo['.']
+ctx = repo[b'.']
 added = []
 lookup = []
 dropped = []
 mf = ctx.manifest()
 files = set(mf)
 # Add files that are newly included, or that don't exist in
 # the dirstate yet.
 if (new and not old) or (old and new and not file in dirstate):
 fl = mf.flags(file)
 if repo.wvfs.exists(file):
-actions[file] = ('e', (fl,), '')
+actions[file] = (b'e', (fl,), b'')
 lookup.append(file)
 else:
-actions[file] = ('g', (fl, False), '')
+actions[file] = (b'g', (fl, False), b'')
 added.append(file)
 # Drop files that are newly excluded, or that still exist in
 # the dirstate.
 elif (old and not new) or (not old and not new and file in dirstate):
 dropped.append(file)
 if file not in pending:
-actions[file] = ('r', [], '')
+actions[file] = (b'r', [], b'')
 # Verify there are no pending changes in newly included files
 abort = False
 for file in lookup:
-repo.ui.warn(_("pending changes to '%s'\n") % file)
+repo.ui.warn(_(b"pending changes to '%s'\n") % file)
 abort = not force
 if abort:
 raise error.Abort(
 _(
-'cannot change sparseness due to pending '
+b'cannot change sparseness due to pending '
-'changes (delete the files or use '
+b'changes (delete the files or use '
-'--force to bring them back dirty)'
+b'--force to bring them back dirty)'
 )
 )
 # Check for files that were only in the dirstate.
 for file, state in dirstate.iteritems():
 typeactions = mergemod.emptyactions()
 for f, (m, args, msg) in actions.iteritems():
 typeactions[m].append((f, args, msg))
 mergemod.applyupdates(
-repo, typeactions, repo[None], repo['.'], False, wantfiledata=False
+repo, typeactions, repo[None], repo[b'.'], False, wantfiledata=False
 )
 # Fix dirstate
 for file in added:
 dirstate.normal(file)
 def _updateconfigandrefreshwdir(
 repo, includes, excludes, profiles, force=False, removing=False
 ):
 """Update the sparse config and working directory state."""
-raw = repo.vfs.tryread('sparse')
+raw = repo.vfs.tryread(b'sparse')
-oldincludes, oldexcludes, oldprofiles = parseconfig(repo.ui, raw, 'sparse')
+oldincludes, oldexcludes, oldprofiles = parseconfig(repo.ui, raw, b'sparse')
 oldstatus = repo.status()
 oldmatch = matcher(repo)
 oldrequires = set(repo.requirements)
 # re-read. We ideally want to update the cached matcher on the
 # repo instance then flush the new config to disk once wdir is
 # updated. But this requires massive rework to matcher() and its
 # consumers.
-if 'exp-sparse' in oldrequires and removing:
+if b'exp-sparse' in oldrequires and removing:
-repo.requirements.discard('exp-sparse')
+repo.requirements.discard(b'exp-sparse')
 scmutil.writerequires(repo.vfs, repo.requirements)
-elif 'exp-sparse' not in oldrequires:
+elif b'exp-sparse' not in oldrequires:
-repo.requirements.add('exp-sparse')
+repo.requirements.add(b'exp-sparse')
 scmutil.writerequires(repo.vfs, repo.requirements)
 try:
 writeconfig(repo, includes, excludes, profiles)
 return refreshwdir(repo, oldstatus, oldmatch, force=force)
 The remaining sparse config only has profiles, if defined. The working
 directory is refreshed, as needed.
 """
 with repo.wlock():
-raw = repo.vfs.tryread('sparse')
+raw = repo.vfs.tryread(b'sparse')
-includes, excludes, profiles = parseconfig(repo.ui, raw, 'sparse')
+includes, excludes, profiles = parseconfig(repo.ui, raw, b'sparse')
 if not includes and not excludes:
 return
 _updateconfigandrefreshwdir(repo, set(), set(), profiles, force=force)
 The updated sparse config is written out and the working directory
 is refreshed, as needed.
 """
 with repo.wlock():
 # read current configuration
-raw = repo.vfs.tryread('sparse')
+raw = repo.vfs.tryread(b'sparse')
-includes, excludes, profiles = parseconfig(repo.ui, raw, 'sparse')
+includes, excludes, profiles = parseconfig(repo.ui, raw, b'sparse')
 aincludes, aexcludes, aprofiles = activeconfig(repo)
 # Import rules on top; only take in rules that are not yet
 # part of the active rules.
 changed = False
 for p in paths:
-with util.posixfile(util.expandpath(p), mode='rb') as fh:
+with util.posixfile(util.expandpath(p), mode=b'rb') as fh:
 raw = fh.read()
 iincludes, iexcludes, iprofiles = parseconfig(
-repo.ui, raw, 'sparse'
+repo.ui, raw, b'sparse'
 )
 oldsize = len(includes) + len(excludes) + len(profiles)
 includes.update(iincludes - aincludes)
 excludes.update(iexcludes - aexcludes)
 profiles.update(iprofiles - aprofiles)
 Only one of the actions may be performed.
 The new config is written out and a working directory refresh is performed.
 """
 with repo.wlock():
-raw = repo.vfs.tryread('sparse')
+raw = repo.vfs.tryread(b'sparse')
 oldinclude, oldexclude, oldprofiles = parseconfig(
-repo.ui, raw, 'sparse'
+repo.ui, raw, b'sparse'
 )
 if reset:
 newinclude = set()
 newexclude = set()
 newinclude = set(oldinclude)
 newexclude = set(oldexclude)
 newprofiles = set(oldprofiles)
 if any(os.path.isabs(pat) for pat in pats):
-raise error.Abort(_('paths cannot be absolute'))
+raise error.Abort(_(b'paths cannot be absolute'))
 if not usereporootpaths:
 # let's treat paths as relative to cwd
 root, cwd = repo.root, repo.getcwd()
 abspats = []
 for kindpat in pats:
 kind, pat = matchmod._patsplit(kindpat, None)
 if kind in matchmod.cwdrelativepatternkinds or kind is None:
-ap = (kind + ':' if kind else '') + pathutil.canonpath(
+ap = (kind + b':' if kind else b'') + pathutil.canonpath(
 root, cwd, pat
 )
 abspats.append(ap)
 else:
 abspats.append(kindpat)
 added=0,
 dropped=0,
 conflicting=0,
 ):
 """Print output summarizing sparse config changes."""
-with ui.formatter('sparse', opts) as fm:
+with ui.formatter(b'sparse', opts) as fm:
 fm.startitem()
 fm.condwrite(
 ui.verbose,
-'profiles_added',
+b'profiles_added',
-_('Profiles changed: %d\n'),
+_(b'Profiles changed: %d\n'),
 profilecount,
 )
 fm.condwrite(
 ui.verbose,
-'include_rules_added',
+b'include_rules_added',
-_('Include rules changed: %d\n'),
+_(b'Include rules changed: %d\n'),
 includecount,
 )
 fm.condwrite(
 ui.verbose,
-'exclude_rules_added',
+b'exclude_rules_added',
-_('Exclude rules changed: %d\n'),
+_(b'Exclude rules changed: %d\n'),
 excludecount,
 )
 # In 'plain' verbose mode, mergemod.applyupdates already outputs what
 # files are added or removed outside of the templating formatter
 # framework. No point in repeating ourselves in that case.
 if not fm.isplain():
 fm.condwrite(
-ui.verbose, 'files_added', _('Files added: %d\n'), added
+ui.verbose, b'files_added', _(b'Files added: %d\n'), added
 )
 fm.condwrite(
-ui.verbose, 'files_dropped', _('Files dropped: %d\n'), dropped
+ui.verbose, b'files_dropped', _(b'Files dropped: %d\n'), dropped
 )
 fm.condwrite(
 ui.verbose,
-'files_conflicting',
+b'files_conflicting',
-_('Files conflicting: %d\n'),
+_(b'Files conflicting: %d\n'),
 conflicting,
 )

Mercurial > public > mercurial-scm > hg-stable

comparison mercurial/sparse.py @ 43077:687b865b95ad