mercurial/bundle2.py

24046:6e1d9f9932a9

        for part in iterparts:
            _processpart(op, part)
    except Exception, exc:
        for part in iterparts:
            # consume the bundle content
            part.read()
        # Small hack to let caller code distinguish exceptions from bundle2
        # processing from processing the old format. This is mostly
        # needed to handle different return codes to unbundle according to the
        # type of bundle. We should probably clean up or drop this return code
        # craziness in a future version.

            outpart = op.reply.newpart('b2x:output', data=output,
                                       mandatory=False)
            outpart.addparam('in-reply-to', str(part.id), mandatory=False)
    finally:
        # consume the part content to not corrupt the stream.
        part.read()


def decodecaps(blob):
    """decode a bundle2 caps bytes blob into a dictionary

24047:731fa8e3e580

        for part in iterparts:
            _processpart(op, part)
    except Exception, exc:
        for part in iterparts:
            # consume the bundle content
            part.seek(0, 2)
        # Small hack to let caller code distinguish exceptions from bundle2
        # processing from processing the old format. This is mostly
        # needed to handle different return codes to unbundle according to the
        # type of bundle. We should probably clean up or drop this return code
        # craziness in a future version.

            outpart = op.reply.newpart('b2x:output', data=output,
                                       mandatory=False)
            outpart.addparam('in-reply-to', str(part.id), mandatory=False)
    finally:
        # consume the part content to not corrupt the stream.
        part.seek(0, 2)


def decodecaps(blob):
    """decode a bundle2 caps bytes blob into a dictionary