comparison mercurial/exchange.py @ 26700:dbc3d945ba36

exchange: use cg?unpacker.apply() instead of changegroup.addchangegroup()

26699:76f20fc8d54d

        raise error.Abort(_("partial pull cannot be done because "
                           "other repository doesn't support "
                           "changegroupsubset."))
    else:
        cg = pullop.remote.changegroupsubset(pullop.fetch, pullop.heads, 'pull')
    pullop.cgresult = changegroup.addchangegroup(pullop.repo, cg, 'pull',
                                                 pullop.remote.url())

def _pullphase(pullop):
    # Get remote phases data from remote
    if 'phases' in pullop.stepsdone:
        return

                                                  mandatory=False)
                        parts.append(part)
                raise
        else:
            lockandtr[1] = repo.lock()
            r = changegroup.addchangegroup(repo, cg, source, url)
    finally:
        lockmod.release(lockandtr[2], lockandtr[1], lockandtr[0])
        if recordout is not None:
            recordout(repo.ui.popbuffer())
    return r

                cg = readbundle(ui, fh, 'stream')

                if isinstance(cg, bundle2.unbundle20):
                    bundle2.processbundle(repo, cg, lambda: tr)
                else:
                    changegroup.addchangegroup(repo, cg, 'clonebundles', url)
                tr.close()
                return True
            except urllib2.HTTPError as e:
                ui.warn(_('HTTP error fetching bundle: %s\n') % str(e))
            except urllib2.URLError as e:

26700:dbc3d945ba36

        raise error.Abort(_("partial pull cannot be done because "
                           "other repository doesn't support "
                           "changegroupsubset."))
    else:
        cg = pullop.remote.changegroupsubset(pullop.fetch, pullop.heads, 'pull')
    pullop.cgresult = cg.apply(pullop.repo, 'pull', pullop.remote.url())

def _pullphase(pullop):
    # Get remote phases data from remote
    if 'phases' in pullop.stepsdone:
        return

                                                  mandatory=False)
                        parts.append(part)
                raise
        else:
            lockandtr[1] = repo.lock()
            r = cg.apply(repo, source, url)
    finally:
        lockmod.release(lockandtr[2], lockandtr[1], lockandtr[0])
        if recordout is not None:
            recordout(repo.ui.popbuffer())
    return r

                cg = readbundle(ui, fh, 'stream')

                if isinstance(cg, bundle2.unbundle20):
                    bundle2.processbundle(repo, cg, lambda: tr)
                else:
                    cg.apply(repo, 'clonebundles', url)
                tr.close()
                return True
            except urllib2.HTTPError as e:
                ui.warn(_('HTTP error fetching bundle: %s\n') % str(e))
            except urllib2.URLError as e: