comparison mercurial/dirstate.py @ 50122:72b4d9284411

dirstate: track that changes are pending in a transaction

Nothing is currently broken because if this, but this make the
`_invalidated_context` attribute more accurate.
Being more accurate here will help us later, when dealing with `status` call.

50121:15531d101313

        # the change currently underway
        self._change_type = None
        # True if the current dirstate changing operations have been
        # invalidated (used to make sure all nested contexts have been exited)
        self._invalidated_context = False
        self._filename = b'dirstate'
        self._filename_th = b'dirstate-tracked-hint'
        self._pendingfilename = b'%s.pending' % self._filename
        self._plchangecallbacks = {}
        self._origpl = None

        for a in ("_map", "_branch", "_ignore"):
            if a in self.__dict__:
                delattr(self, a)
        self._dirty = False
        self._dirty_tracked_set = False
        self._invalidated_context = self._changing_level > 0
        self._origpl = None

    @requires_changing_any
    def copy(self, source, dest):
        """Mark dest as a copy of source. Unmark dest if source is None."""

        # XXX move before the dirty check once `unlock` stop calling `write`
        assert not self._invalidated_context

        write_key = self._use_tracked_hint and self._dirty_tracked_set
        if tr:
            # make sure we invalidate the current change on abort
            if tr is not None:
                tr.addabort(
                    b'dirstate-invalidate',
                    lambda tr: self.invalidate(),
                )
            # delay writing in-memory changes out
            tr.addfilegenerator(
                b'dirstate-1-main',
                (self._filename,),
                lambda f: self._writedirstate(tr, f),
                location=b'plain',
                post_finalize=True,
            )
            if write_key:
                tr.addfilegenerator(

50122:72b4d9284411

        # the change currently underway
        self._change_type = None
        # True if the current dirstate changing operations have been
        # invalidated (used to make sure all nested contexts have been exited)
        self._invalidated_context = False
        self._attached_to_a_transaction = False
        self._filename = b'dirstate'
        self._filename_th = b'dirstate-tracked-hint'
        self._pendingfilename = b'%s.pending' % self._filename
        self._plchangecallbacks = {}
        self._origpl = None

        for a in ("_map", "_branch", "_ignore"):
            if a in self.__dict__:
                delattr(self, a)
        self._dirty = False
        self._dirty_tracked_set = False
        self._invalidated_context = (
            self._changing_level > 0 or self._attached_to_a_transaction
        )
        self._origpl = None

    @requires_changing_any
    def copy(self, source, dest):
        """Mark dest as a copy of source. Unmark dest if source is None."""

        # XXX move before the dirty check once `unlock` stop calling `write`
        assert not self._invalidated_context

        write_key = self._use_tracked_hint and self._dirty_tracked_set
        if tr:

            def on_abort(tr):
                self._attached_to_a_transaction = False
                self.invalidate()

            # make sure we invalidate the current change on abort
            if tr is not None:
                tr.addabort(b'dirstate-invalidate', on_abort)

            self._attached_to_a_transaction = True

            def on_success(f):
                self._attached_to_a_transaction = False
                self._writedirstate(tr, f),

            # delay writing in-memory changes out
            tr.addfilegenerator(
                b'dirstate-1-main',
                (self._filename,),
                on_success,
                location=b'plain',
                post_finalize=True,
            )
            if write_key:
                tr.addfilegenerator(