| mitrandir |
| Restricted Project |
Without this, we get develwarnings about vfs being deprecated for accessing
files under .hg/cache/.
run-tests, more tests pass
| Lint OK |
| Unit Test Errors |
| Path | Packages | |||
|---|---|---|---|---|
| M | hgext3rd/perftweaks.py (6 lines) |
| Commit | Local | Parents | Author | Summary | Date |
|---|---|---|---|---|---|
| e028cd252702 | 3527 | 978437e9b140 | Ryan McElroy | perftweaks: start using cachevfs (Show More…) | Jul 18 2017, 9:41 AM |
| # full texts to be written over and over again. | # full texts to be written over and over again. | ||||
| if (l > textlen or compresseddeltalen > textlen * 2 or | if (l > textlen or compresseddeltalen > textlen * 2 or | ||||
| (self._maxchainlen and chainlen > self._maxchainlen)): | (self._maxchainlen and chainlen > self._maxchainlen)): | ||||
| return False | return False | ||||
| return True | return True | ||||
| def _cachefilename(name): | def _cachefilename(name): | ||||
| return 'cache/noderevs/%s' % name | return 'noderevs/%s' % name | ||||
| def _preloadrevs(repo): | def _preloadrevs(repo): | ||||
| # Preloading the node-rev map for likely to be used revs saves 100ms on | # Preloading the node-rev map for likely to be used revs saves 100ms on | ||||
| # every command. This is because normally to look up a node, hg has to scan | # every command. This is because normally to look up a node, hg has to scan | ||||
| # the changelog.i file backwards, potentially reading through hundreds of | # the changelog.i file backwards, potentially reading through hundreds of | ||||
| # thousands of entries and building a cache of them. Looking up a rev | # thousands of entries and building a cache of them. Looking up a rev | ||||
| # however is fast, because we know exactly what offset in the file to read. | # however is fast, because we know exactly what offset in the file to read. | ||||
| # Reading old commits is common, since the branchmap needs to to convert old | # Reading old commits is common, since the branchmap needs to to convert old | ||||
| # branch heads from node to rev. | # branch heads from node to rev. | ||||
| if repo.ui.configbool('perftweaks', 'cachenoderevs', True): | if repo.ui.configbool('perftweaks', 'cachenoderevs', True): | ||||
| repo = repo.unfiltered() | repo = repo.unfiltered() | ||||
| revs = set() | revs = set() | ||||
| cachedir = repo.vfs.join('cache', 'noderevs') | cachedir = repo.vfs.join('cache', 'noderevs') | ||||
| try: | try: | ||||
| for cachefile in os.listdir(cachedir): | for cachefile in os.listdir(cachedir): | ||||
| filename = _cachefilename(cachefile) | filename = _cachefilename(cachefile) | ||||
| revs.update(int(r) for r in repo.vfs.open(filename).readlines()) | revs.update(int(r) for r in repo.cachevfs(filename)) | ||||
| getnode = repo.changelog.node | getnode = repo.changelog.node | ||||
| nodemap = repo.changelog.nodemap | nodemap = repo.changelog.nodemap | ||||
| for r in revs: | for r in revs: | ||||
| try: | try: | ||||
| node = getnode(r) | node = getnode(r) | ||||
| nodemap[node] = r | nodemap[node] = r | ||||
| except (IndexError, ValueError): | except (IndexError, ValueError): | ||||
| # If we failed because the directory already exists, | # If we failed because the directory already exists, | ||||
| # continue. In all other cases (e.g., no permission to create the | # continue. In all other cases (e.g., no permission to create the | ||||
| # directory), just silently return without doing anything. | # directory), just silently return without doing anything. | ||||
| if ex.errno != errno.EEXIST: | if ex.errno != errno.EEXIST: | ||||
| return | return | ||||
| try: | try: | ||||
| filename = _cachefilename(name) | filename = _cachefilename(name) | ||||
| f = repo.vfs.open(filename, mode='w+', atomictemp=True) | f = repo.cachevfs.open(filename, mode='w+', atomictemp=True) | ||||
| f.write('\n'.join(str(r) for r in revs)) | f.write('\n'.join(str(r) for r in revs)) | ||||
| f.close() | f.close() | ||||
| except EnvironmentError: | except EnvironmentError: | ||||
| # No permission to write? No big deal | # No permission to write? No big deal | ||||
| pass | pass | ||||
| def _trackdirstatesizes(runcommand, lui, repo, *args): | def _trackdirstatesizes(runcommand, lui, repo, *args): | ||||
| res = runcommand(lui, repo, *args) | res = runcommand(lui, repo, *args) | ||||