mercurial/localrepo.py

18188:46ed5226503a

        self._applyrequirements(requirements)
        if create:
            self._writerequirements()


        self._branchcache = None
        self.filterpats = {}
        self._datafilters = {}
        self._transref = self._lockref = self._wlockref = None

        # A cache for various files under .hg/ that tracks file changes,

        cl = self.changelog
        return cl.rev(cl.tip())

    def branchmap(self):
        '''returns a dictionary {branch: [branchheads]}'''
        if self.changelog.filteredrevs:
            # some changeset are excluded we can't use the cache
            bmap = branchmap.branchcache()
            bmap.update(self, (self[r] for r in self))
            return bmap
        else:
            branchmap.updatecache(self)
            return self._branchcache


    def _branchtip(self, heads):
        '''return the tipmost branch head in heads'''
        tip = heads[-1]

        if '_tagscache' in vars(self):
            # can't use delattr on proxy
            del self.__dict__['_tagscache']

        self.unfiltered()._branchcache = None # in UTF-8
        self.invalidatevolatilesets()

    def invalidatevolatilesets(self):
        self.filteredrevcache.clear()
        obsolete.clearobscaches(self)

        # it, Otherwise, since nodes were destroyed, the cache is stale and this
        # will be caught the next time it is read.
        if newheadnodes:
            ctxgen = (self[node] for node in newheadnodes
                      if self.changelog.hasnode(node))
            cache = self._branchcache
            cache.update(self, ctxgen)
            cache.write(self)

        # Ensure the persistent tag cache is updated.  Doing it now
        # means that the tag cache only has to worry about destroyed

                    rtiprev = max((int(self.changelog.rev(node))
                            for node in rbheads))
                    cache = branchmap.branchcache(rbranchmap,
                                                  self[rtiprev].node(),
                                                  rtiprev)
                    self._branchcache = cache
                    cache.write(self)
            self.invalidate()
            return len(self.heads()) + 1
        finally:
            lock.release()

18189:b9026ba002f6

        self._applyrequirements(requirements)
        if create:
            self._writerequirements()


        self._branchcaches = {}
        self.filterpats = {}
        self._datafilters = {}
        self._transref = self._lockref = self._wlockref = None

        # A cache for various files under .hg/ that tracks file changes,

        cl = self.changelog
        return cl.rev(cl.tip())

    def branchmap(self):
        '''returns a dictionary {branch: [branchheads]}'''
        if self.filtername and not self.changelog.filteredrevs:
            return self.unfiltered().branchmap()
        branchmap.updatecache(self)
        return self._branchcaches[self.filtername]


    def _branchtip(self, heads):
        '''return the tipmost branch head in heads'''
        tip = heads[-1]

        if '_tagscache' in vars(self):
            # can't use delattr on proxy
            del self.__dict__['_tagscache']

        self.unfiltered()._branchcaches.clear()
        self.invalidatevolatilesets()

    def invalidatevolatilesets(self):
        self.filteredrevcache.clear()
        obsolete.clearobscaches(self)

        # it, Otherwise, since nodes were destroyed, the cache is stale and this
        # will be caught the next time it is read.
        if newheadnodes:
            ctxgen = (self[node] for node in newheadnodes
                      if self.changelog.hasnode(node))
            cache = self._branchcaches[None]
            cache.update(self, ctxgen)
            cache.write(self)

        # Ensure the persistent tag cache is updated.  Doing it now
        # means that the tag cache only has to worry about destroyed

                    rtiprev = max((int(self.changelog.rev(node))
                            for node in rbheads))
                    cache = branchmap.branchcache(rbranchmap,
                                                  self[rtiprev].node(),
                                                  rtiprev)
                    self._branchcaches[None] = cache
                    cache.write(self.unfiltered())
            self.invalidate()
            return len(self.heads()) + 1
        finally:
            lock.release()