mercurial/localrepo.py

17123:8e030168b09e

    def _phasecache(self):
        return phases.phasecache(self, self._phasedefaults)

    @storecache('obsstore')
    def obsstore(self):
        store = obsolete.obsstore()
        data = self.sopener.tryread('obsstore')
        if data:
            store.loadmarkers(data)
        return store

    @storecache('00changelog.i')
    def changelog(self):
        c = changelog.changelog(self.sopener)

        def unlock():
            self.store.write()
            if '_phasecache' in vars(self):
                self._phasecache.write()
            if 'obsstore' in vars(self) and self.obsstore._new:
                # XXX: transaction logic should be used here. But for
                # now rewriting the whole file is good enough.
                f = self.sopener('obsstore', 'wb', atomictemp=True)
                try:
                    self.obsstore.flushmarkers(f)
                    f.close()
                except: # re-raises
                    f.discard()
                    raise
            for k, ce in self._filecache.items():
                if k == 'dirstate':
                    continue
                ce.refresh()

17124:f1b7683f3f95

    def _phasecache(self):
        return phases.phasecache(self, self._phasedefaults)

    @storecache('obsstore')
    def obsstore(self):
        store = obsolete.obsstore(self.sopener)
        return store

    @storecache('00changelog.i')
    def changelog(self):
        c = changelog.changelog(self.sopener)

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