comparison mercurial/localrepo.py @ 17124:f1b7683f3f95

obsolete: move obsolete markers read/write logic to obsstore object

This is the first step toward incremental writing of obsolete marker within a
transaction.

For this purpose, obsstore is now given its repo sopener. This make it able to
handles read and write to the obsstore file itself. Most IO logic is removed
from localrepo and handled by obsstore object directly.

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