comparison mercurial/wireproto.py @ 26443:d947086d8973

streamclone: move code out of exchange.py

We bulk move functions from exchange.py related to streaming clones.

Function names were renamed slightly to drop a component redundant with
the module name. Docstrings and comments referencing old names and
locations were updated accordingly.

26442:ef8d27f53204

    encoding,
    error,
    exchange,
    peer,
    pushkey as pushkeymod,
    util,
)

class abstractserverproto(object):
    """abstract class that summarizes the protocol API

            yield chunk

    try:
        # LockError may be raised before the first result is yielded. Don't
        # emit output until we're sure we got the lock successfully.
        it = exchange.generatestreamclone(repo)
        return streamres(getstream(it))
    except error.LockError:
        return '2\n'

@wireprotocommand('unbundle', 'heads')

26443:d947086d8973

    encoding,
    error,
    exchange,
    peer,
    pushkey as pushkeymod,
    streamclone,
    util,
)

class abstractserverproto(object):
    """abstract class that summarizes the protocol API

            yield chunk

    try:
        # LockError may be raised before the first result is yielded. Don't
        # emit output until we're sure we got the lock successfully.
        it = streamclone.generatev1(repo)
        return streamres(getstream(it))
    except error.LockError:
        return '2\n'

@wireprotocommand('unbundle', 'heads')