comparison mercurial/bundle2.py @ 21176:70fcb0a71445 stable

bundle2: decorate exception raised during bundle processing

This is a small hack to help us do some graceful error handling in bundle2
without major refactoring. See embedded comment for details.

21175:dae36d3e1c60

                                     advisoryparams=[('in-reply-to',
                                                      str(part.id))],
                                     data=output)
                op.reply.addpart(outpart)
            part.read()
    except Exception:
        if part is not None:
            # consume the bundle content
            part.read()
        for part in iterparts:
            # consume the bundle content
            part.read()
        raise
    return op

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

21176:70fcb0a71445

                                     advisoryparams=[('in-reply-to',
                                                      str(part.id))],
                                     data=output)
                op.reply.addpart(outpart)
            part.read()
    except Exception, exc:
        if part is not None:
            # consume the bundle content
            part.read()
        for part in iterparts:
            # consume the bundle content
            part.read()
        # Small hack to let caller code distinguish exceptions from bundle2
        # processing fron the ones from bundle1 processing. 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.
        exc.duringunbundle2 = True
        raise
    return op

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