comparison mercurial/localrepo.py @ 17070:ad0d6c2b3279

obsolete: introduction of obsolete markers

Markers are stored as binary records in a log structured file in
.hg/store/obsstore.

17069:2b1c78674230

# This software may be used and distributed according to the terms of the
# GNU General Public License version 2 or any later version.

from node import bin, hex, nullid, nullrev, short
from i18n import _
import repo, changegroup, subrepo, discovery, pushkey
import changelog, dirstate, filelog, manifest, context, bookmarks, phases
import lock, transaction, store, encoding
import scmutil, util, extensions, hook, error, revset
import match as matchmod
import merge as mergemod

    @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:
            p = os.environ['HG_PENDING']

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

17070:ad0d6c2b3279

# This software may be used and distributed according to the terms of the
# GNU General Public License version 2 or any later version.

from node import bin, hex, nullid, nullrev, short
from i18n import _
import repo, changegroup, subrepo, discovery, pushkey, obsolete
import changelog, dirstate, filelog, manifest, context, bookmarks, phases
import lock, transaction, store, encoding
import scmutil, util, extensions, hook, error, revset
import match as matchmod
import merge as mergemod

    @storecache('phaseroots')
    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)
        if 'HG_PENDING' in os.environ:
            p = os.environ['HG_PENDING']

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