mercurial/bundlerepo.py

35048:80e9b85d96e5

        for chunk in iter(lambda: bundle.deltachunk(None), {}):
            pass
    return bundlefilespos

class bundlerepository(localrepo.localrepository):
    def __init__(self, ui, path, bundlename):
        self._tempparent = None
        try:
            localrepo.localrepository.__init__(self, ui, path)
        except error.RepoError:
            self._tempparent = tempfile.mkdtemp()
            localrepo.instance(ui, self._tempparent, 1)
            localrepo.localrepository.__init__(self, ui, self._tempparent)
        self.ui.setconfig('phases', 'publish', False, 'bundlerepo')

        if path:
            self._url = 'bundle:' + util.expandpath(path) + '+' + bundlename
        else:
            self._url = 'bundle:' + bundlename

        self.tempfile = None
        f = util.posixfile(bundlename, "rb")
        self.bundlefile = self.bundle = exchange.readbundle(ui, f, bundlename)

        if isinstance(self.bundle, bundle2.unbundle20):
            hadchangegroup = False
            for part in self.bundle.iterparts():
                if part.type == 'changegroup':

        elif self.bundle.compressed():
            f = self._writetempbundle(self.bundle.read, '.hg10un',
                                      header='HG10UN')
            self.bundlefile = self.bundle = exchange.readbundle(ui, f,
                                                                bundlename,
                                                                self.vfs)

        # dict with the mapping 'filename' -> position in the bundle
        self.bundlefilespos = {}

35049:4696938d40f9

        for chunk in iter(lambda: bundle.deltachunk(None), {}):
            pass
    return bundlefilespos

class bundlerepository(localrepo.localrepository):
    def __init__(self, ui, repopath, bundlepath):
        self._tempparent = None
        try:
            localrepo.localrepository.__init__(self, ui, repopath)
        except error.RepoError:
            self._tempparent = tempfile.mkdtemp()
            localrepo.instance(ui, self._tempparent, 1)
            localrepo.localrepository.__init__(self, ui, self._tempparent)
        self.ui.setconfig('phases', 'publish', False, 'bundlerepo')

        if repopath:
            self._url = 'bundle:' + util.expandpath(repopath) + '+' + bundlepath
        else:
            self._url = 'bundle:' + bundlepath

        self.tempfile = None
        f = util.posixfile(bundlepath, "rb")
        self.bundlefile = self.bundle = exchange.readbundle(ui, f, bundlepath)

        if isinstance(self.bundle, bundle2.unbundle20):
            hadchangegroup = False
            for part in self.bundle.iterparts():
                if part.type == 'changegroup':

        elif self.bundle.compressed():
            f = self._writetempbundle(self.bundle.read, '.hg10un',
                                      header='HG10UN')
            self.bundlefile = self.bundle = exchange.readbundle(ui, f,
                                                                bundlepath,
                                                                self.vfs)

        # dict with the mapping 'filename' -> position in the bundle
        self.bundlefilespos = {}