mercurial/localrepo.py

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()