comparison mercurial/localrepo.py @ 16657:b6081c2c4647

phases: introduce phasecache

The original motivation was changectx.phase() had special logic to
correctly lookup in repo._phaserev, including invalidating it when
necessary. And at other places, repo._phaserev was accessed directly.

This led to the discovery that phases state including _phaseroots,
_phaserev and _dirtyphase was manipulated in localrepository.py,
phases.py, repair.py, etc. phasecache helps encapsulating that.

This patch replaces all phase state in localrepo with phasecache and
adjust related code except for advance/retractboundary() in phases.
These still access to phasecache internals directly. This will be
addressed in a followup.

16656:4ae3ba9e4d7a

        self.auditor = scmutil.pathauditor(self.root, self._checknested)
        self.opener = scmutil.opener(self.path)
        self.wopener = scmutil.opener(self.root)
        self.baseui = baseui
        self.ui = baseui.copy()
        self._dirtyphases = False
        # A list of callback to shape the phase if no data were found.
        # Callback are in the form: func(repo, roots) --> processed root.
        # This list it to be filled by extension during repo setup
        self._phasedefaults = []

    def _writebookmarks(self, marks):
      bookmarks.write(self)

    @storecache('phaseroots')
    def _phaseroots(self):
        phaseroots, self._dirtyphases = phases.readroots(
            self, self._phasedefaults)
        return phaseroots

    @propertycache
    def _phaserev(self):
        cache = [phases.public] * len(self)
        for phase in phases.trackedphases:
            roots = map(self.changelog.rev, self._phaseroots[phase])
            if roots:
                for rev in roots:
                    cache[rev] = phase
                for rev in self.changelog.descendants(*roots):
                    cache[rev] = phase
        return cache

    @storecache('00changelog.i')
    def changelog(self):
        c = changelog.changelog(self.sopener)
        if 'HG_PENDING' in os.environ:

        repo = (remote and remote.local()) and remote or self
        return repo[key].branch()

    def known(self, nodes):
        nm = self.changelog.nodemap
        result = []
        for n in nodes:
            r = nm.get(n)
            resp = not (r is None or self._phaserev[r] >= phases.secret)
            result.append(resp)
        return result

    def local(self):
        return self

                delattr(self, name)
            except AttributeError:
                pass

        delcache('_tagscache')
        delcache('_phaserev')

        self._branchcache = None # in UTF-8
        self._branchcachetip = None

    def invalidatedirstate(self):

            l.lock()
            return l

        def unlock():
            self.store.write()
            if self._dirtyphases:
                phases.writeroots(self, self._phaseroots)
                self._dirtyphases = False
            for k, ce in self._filecache.items():
                if k == 'dirstate':
                    continue
                ce.refresh()

16657:b6081c2c4647

        self.auditor = scmutil.pathauditor(self.root, self._checknested)
        self.opener = scmutil.opener(self.path)
        self.wopener = scmutil.opener(self.root)
        self.baseui = baseui
        self.ui = baseui.copy()
        # A list of callback to shape the phase if no data were found.
        # Callback are in the form: func(repo, roots) --> processed root.
        # This list it to be filled by extension during repo setup
        self._phasedefaults = []

    def _writebookmarks(self, marks):
      bookmarks.write(self)

    @storecache('phaseroots')
    def _phasecache(self):
        return phases.phasecache(self, self._phasedefaults)

    @storecache('00changelog.i')
    def changelog(self):
        c = changelog.changelog(self.sopener)
        if 'HG_PENDING' in os.environ:

        repo = (remote and remote.local()) and remote or self
        return repo[key].branch()

    def known(self, nodes):
        nm = self.changelog.nodemap
        pc = self._phasecache
        result = []
        for n in nodes:
            r = nm.get(n)
            resp = not (r is None or pc.phase(self, r) >= phases.secret)
            result.append(resp)
        return result

    def local(self):
        return self

                delattr(self, name)
            except AttributeError:
                pass

        delcache('_tagscache')

        self._branchcache = None # in UTF-8
        self._branchcachetip = None

    def invalidatedirstate(self):

            l.lock()
            return l

        def unlock():
            self.store.write()
            if '_phasecache' in vars(self):
                self._phasecache.write()
            for k, ce in self._filecache.items():
                if k == 'dirstate':
                    continue
                ce.refresh()