mercurial/localrepo.py

15584:9df9444e96ec

                    raise util.Abort(_("partial pull cannot be done because "
                                           "other repository doesn't support "
                                           "changegroupsubset."))
                else:
                    cg = remote.changegroupsubset(fetch, heads, 'pull')
                result = self.addchangegroup(cg, 'pull', remote.url(),
                                             lock=lock)
            phases.advanceboundary(self, 0, common)
        finally:
            lock.release()

        return result

                        # ssh: return remote's addchangegroup()
                        # http: return remote's addchangegroup() or 0 for error
                        ret = remote.unbundle(cg, remote_heads, 'push')
                    else:
                        # we return an integer indicating remote head count change
                        ret = remote.addchangegroup(cg, 'push', self.url(),
                                                    lock=lock)
                # if we don't push, the common data is already useful
                # everything exchange is public for now
                phases.advanceboundary(self, 0, fut)
            finally:
                locallock.release()

            if nodes:
                self.hook('outgoing', node=hex(nodes[0]), source=source)

        return changegroup.unbundle10(util.chunkbuffer(gengroup()), 'UN')

    def addchangegroup(self, source, srctype, url, emptyok=False, lock=None):
        """Add the changegroup returned by source.read() to this repo.
        srctype is a string like 'push', 'pull', or 'unbundle'.  url is
        the URL of the repo where this changegroup is coming from.
        If lock is not None, the function takes ownership of the lock
        and releases it after the changegroup is added.

        Return an integer summarizing the change to this repo:
        - nothing changed or no source: 0
        - more heads than before: 1+added heads (2..n)
        - fewer heads than before: -1-removed heads (-2..-n)

                                  url=url)
            self._postrelease(postaddchangegroup)

        finally:
            tr.release()
            if lock:
                lock.release()
        # never return 0 here:
        if dh < 0:
            return dh - 1
        else:
            return dh + 1

15585:a348739da8f0

                    raise util.Abort(_("partial pull cannot be done because "
                                           "other repository doesn't support "
                                           "changegroupsubset."))
                else:
                    cg = remote.changegroupsubset(fetch, heads, 'pull')
                result = self.addchangegroup(cg, 'pull', remote.url())
            phases.advanceboundary(self, 0, common)
        finally:
            lock.release()

        return result

                        # ssh: return remote's addchangegroup()
                        # http: return remote's addchangegroup() or 0 for error
                        ret = remote.unbundle(cg, remote_heads, 'push')
                    else:
                        # we return an integer indicating remote head count change
                        ret = remote.addchangegroup(cg, 'push', self.url())
                # if we don't push, the common data is already useful
                # everything exchange is public for now
                phases.advanceboundary(self, 0, fut)
            finally:
                locallock.release()

            if nodes:
                self.hook('outgoing', node=hex(nodes[0]), source=source)

        return changegroup.unbundle10(util.chunkbuffer(gengroup()), 'UN')

    def addchangegroup(self, source, srctype, url, emptyok=False):
        """Add the changegroup returned by source.read() to this repo.
        srctype is a string like 'push', 'pull', or 'unbundle'.  url is
        the URL of the repo where this changegroup is coming from.

        Return an integer summarizing the change to this repo:
        - nothing changed or no source: 0
        - more heads than before: 1+added heads (2..n)
        - fewer heads than before: -1-removed heads (-2..-n)

                                  url=url)
            self._postrelease(postaddchangegroup)

        finally:
            tr.release()
        # never return 0 here:
        if dh < 0:
            return dh - 1
        else:
            return dh + 1