comparison mercurial/localrepo.py @ 17295:1f08ecc7febb stable

pushkey: splits obsolete marker exchange into multiple keys

Obsolete markers are now exchanged in smaller pieces that fit in a http header.

This changes is done to avoid 400 bad request error when exchanging obsolete
puskey over http.

The last key pushed is always hold by the "dump0" key to ensure an easy place to
hook for people who need it.

17294:d2217df3a7cf

                # should be seen as public
                phases.advanceboundary(self, phases.public, subset)

            self.ui.debug('fetching remote obsolete markers')
            remoteobs = remote.listkeys('obsolete')
            if 'dump' in remoteobs:
                if tr is None:
                    tr = self.transaction(trname)
                data = base85.b85decode(remoteobs['dump'])
                self.obsstore.mergemarkers(tr, data)
            if tr is not None:
                tr.close()
        finally:
            if tr is not None:
                tr.release()

                            self.ui.warn(_('updating %s to public failed!\n')
                                            % newremotehead)
                self.ui.debug('try to push obsolete markers to remote\n')
                if (self.obsstore and
                    'obsolete' in remote.listkeys('namespaces')):
                    data = self.listkeys('obsolete')['dump']
                    r = remote.pushkey('obsolete', 'dump', '', data)
                    if not r:
                        self.ui.warn(_('failed to push obsolete markers!\n'))
            finally:
                if lock is not None:
                    lock.release()
        finally:
            locallock.release()

17295:1f08ecc7febb

                # should be seen as public
                phases.advanceboundary(self, phases.public, subset)

            self.ui.debug('fetching remote obsolete markers')
            remoteobs = remote.listkeys('obsolete')
            if 'dump0' in remoteobs:
                if tr is None:
                    tr = self.transaction(trname)
                for key in sorted(remoteobs, reverse=True):
                    if key.startswith('dump'):
                        data = base85.b85decode(remoteobs[key])
                        self.obsstore.mergemarkers(tr, data)
            if tr is not None:
                tr.close()
        finally:
            if tr is not None:
                tr.release()

                            self.ui.warn(_('updating %s to public failed!\n')
                                            % newremotehead)
                self.ui.debug('try to push obsolete markers to remote\n')
                if (self.obsstore and
                    'obsolete' in remote.listkeys('namespaces')):
                    rslts = []
                    remotedata = self.listkeys('obsolete')
                    for key in sorted(remotedata, reverse=True):
                        # reverse sort to ensure we end with dump0
                        data = remotedata[key]
                        rslts.append(remote.pushkey('obsolete', key, '', data))
                    if [r for r in rslts if not r]:
                        msg = _('failed to push some obsolete markers!\n')
                        self.ui.warn(msg)
            finally:
                if lock is not None:
                    lock.release()
        finally:
            locallock.release()