mercurial/localrepo.py

15817:8f377751b510

        phases.filterunknown(self, phaseroots)
        return phaseroots

    @propertycache
    def _phaserev(self):
        cache = [0] * len(self)
        for phase in phases.trackedphases:
            roots = map(self.changelog.rev, self._phaseroots[phase])
            if roots:
                for rev in roots:
                    cache[rev] = phase

            xp1, xp2 = p1.hex(), p2 and p2.hex() or ''
            self.hook('pretxncommit', throw=True, node=hex(n), parent1=xp1,
                      parent2=xp2, pending=p)
            self.changelog.finalize(trp)
            # set the new commit is proper phase
            targetphase = self.ui.configint('phases', 'new-commit', 1)
            if targetphase:
                # retract boundary do not alter parent changeset.
                # if a parent have higher the resulting phase will
                # be compliant anyway
                #

                for phase, boundary in enumerate(rheads):
                    phases.advanceboundary(self, phase, boundary)
            else:
                # Remote is old or publishing all common changesets
                # should be seen as public
                phases.advanceboundary(self, 0, common + added)
        finally:
            lock.release()

        return result

                        ret = remote.addchangegroup(cg, 'push', self.url())

                # even when we don't push, exchanging phase data is useful
                remotephases = remote.listkeys('phases')
                if not remotephases: # old server or public only repo
                    phases.advanceboundary(self, 0, fut)
                    # don't push any phase data as there is nothing to push
                else:
                    ana = phases.analyzeremotephases(self, fut, remotephases)
                    rheads, rroots = ana
                    ### Apply remote phase on local
                    if remotephases.get('publishing', False):
                        phases.advanceboundary(self, 0, fut)
                    else: # publish = False
                        for phase, rpheads in enumerate(rheads):
                            phases.advanceboundary(self, phase, rpheads)
                    ### Apply local phase on remote
                    #

            added = [cl.node(r) for r in xrange(clstart, clend)]
            publishing = self.ui.configbool('phases', 'publish', True)
            if publishing and srctype == 'push':
                # Old server can not push the boundary themself.
                # This clause ensure pushed changeset are alway marked as public
                phases.advanceboundary(self, 0, added)
            elif srctype != 'strip': # strip should not touch boundary at all
                phases.retractboundary(self, 1, added)

            # make changelog see real files again
            cl.finalize(trp)

            tr.close()

15818:57241845a4bb

        phases.filterunknown(self, phaseroots)
        return phaseroots

    @propertycache
    def _phaserev(self):
        cache = [phases.public] * len(self)
        for phase in phases.trackedphases:
            roots = map(self.changelog.rev, self._phaseroots[phase])
            if roots:
                for rev in roots:
                    cache[rev] = phase

            xp1, xp2 = p1.hex(), p2 and p2.hex() or ''
            self.hook('pretxncommit', throw=True, node=hex(n), parent1=xp1,
                      parent2=xp2, pending=p)
            self.changelog.finalize(trp)
            # set the new commit is proper phase
            targetphase = self.ui.configint('phases', 'new-commit',
                                            phases.draft)
            if targetphase:
                # retract boundary do not alter parent changeset.
                # if a parent have higher the resulting phase will
                # be compliant anyway
                #

                for phase, boundary in enumerate(rheads):
                    phases.advanceboundary(self, phase, boundary)
            else:
                # Remote is old or publishing all common changesets
                # should be seen as public
                phases.advanceboundary(self, phases.public, common + added)
        finally:
            lock.release()

        return result

                        ret = remote.addchangegroup(cg, 'push', self.url())

                # even when we don't push, exchanging phase data is useful
                remotephases = remote.listkeys('phases')
                if not remotephases: # old server or public only repo
                    phases.advanceboundary(self, phases.public, fut)
                    # don't push any phase data as there is nothing to push
                else:
                    ana = phases.analyzeremotephases(self, fut, remotephases)
                    rheads, rroots = ana
                    ### Apply remote phase on local
                    if remotephases.get('publishing', False):
                        phases.advanceboundary(self, phases.public, fut)
                    else: # publish = False
                        for phase, rpheads in enumerate(rheads):
                            phases.advanceboundary(self, phase, rpheads)
                    ### Apply local phase on remote
                    #

            added = [cl.node(r) for r in xrange(clstart, clend)]
            publishing = self.ui.configbool('phases', 'publish', True)
            if publishing and srctype == 'push':
                # Old server can not push the boundary themself.
                # This clause ensure pushed changeset are alway marked as public
                phases.advanceboundary(self, phases.public, added)
            elif srctype != 'strip': # strip should not touch boundary at all
                phases.retractboundary(self, phases.draft, added)

            # make changelog see real files again
            cl.finalize(trp)

            tr.close()