Show More
@@ -472,28 +472,28 b' Setting up' | |||||
472 | > |
|
472 | > | |
473 | > configtable = {} |
|
473 | > configtable = {} | |
474 | > configitem = registrar.configitem(configtable) |
|
474 | > configitem = registrar.configitem(configtable) | |
475 | > configitem('failpush', 'reason', |
|
475 | > configitem(b'failpush', b'reason', | |
476 | > default=None, |
|
476 | > default=None, | |
477 | > ) |
|
477 | > ) | |
478 | > |
|
478 | > | |
479 | > def _pushbundle2failpart(pushop, bundler): |
|
479 | > def _pushbundle2failpart(pushop, bundler): | |
480 | > reason = pushop.ui.config('failpush', 'reason') |
|
480 | > reason = pushop.ui.config(b'failpush', b'reason') | |
481 | > part = None |
|
481 | > part = None | |
482 | > if reason == 'abort': |
|
482 | > if reason == b'abort': | |
483 | > bundler.newpart('test:abort') |
|
483 | > bundler.newpart(b'test:abort') | |
484 | > if reason == 'unknown': |
|
484 | > if reason == b'unknown': | |
485 | > bundler.newpart('test:unknown') |
|
485 | > bundler.newpart(b'test:unknown') | |
486 | > if reason == 'race': |
|
486 | > if reason == b'race': | |
487 | > # 20 Bytes of crap |
|
487 | > # 20 Bytes of crap | |
488 | > bundler.newpart('check:heads', data='01234567890123456789') |
|
488 | > bundler.newpart(b'check:heads', data=b'01234567890123456789') | |
489 | > |
|
489 | > | |
490 | > @bundle2.parthandler("test:abort") |
|
490 | > @bundle2.parthandler(b"test:abort") | |
491 | > def handleabort(op, part): |
|
491 | > def handleabort(op, part): | |
492 | > raise error.Abort('Abandon ship!', hint="don't panic") |
|
492 | > raise error.Abort(b'Abandon ship!', hint=b"don't panic") | |
493 | > |
|
493 | > | |
494 | > def uisetup(ui): |
|
494 | > def uisetup(ui): | |
495 | > exchange.b2partsgenmapping['failpart'] = _pushbundle2failpart |
|
495 | > exchange.b2partsgenmapping[b'failpart'] = _pushbundle2failpart | |
496 | > exchange.b2partsgenorder.insert(0, 'failpart') |
|
496 | > exchange.b2partsgenorder.insert(0, b'failpart') | |
497 | > |
|
497 | > | |
498 | > EOF |
|
498 | > EOF | |
499 |
|
499 | |||
@@ -782,16 +782,16 b' Check abort from mandatory pushkey' | |||||
782 | > from mercurial import pushkey |
|
782 | > from mercurial import pushkey | |
783 | > from mercurial import node |
|
783 | > from mercurial import node | |
784 | > from mercurial import error |
|
784 | > from mercurial import error | |
785 | > @exchange.b2partsgenerator('failingpuskey') |
|
785 | > @exchange.b2partsgenerator(b'failingpuskey') | |
786 | > def addfailingpushey(pushop, bundler): |
|
786 | > def addfailingpushey(pushop, bundler): | |
787 | > enc = pushkey.encode |
|
787 | > enc = pushkey.encode | |
788 | > part = bundler.newpart('pushkey') |
|
788 | > part = bundler.newpart(b'pushkey') | |
789 | > part.addparam('namespace', enc('phases')) |
|
789 | > part.addparam(b'namespace', enc(b'phases')) | |
790 | > part.addparam('key', enc('cd010b8cd998f3981a5a8115f94f8da4ab506089')) |
|
790 | > part.addparam(b'key', enc(b'cd010b8cd998f3981a5a8115f94f8da4ab506089')) | |
791 |
> part.addparam('old', enc( |
|
791 | > part.addparam(b'old', enc(b'0')) # successful update | |
792 |
> part.addparam('new', enc( |
|
792 | > part.addparam(b'new', enc(b'0')) | |
793 | > def fail(pushop, exc): |
|
793 | > def fail(pushop, exc): | |
794 | > raise error.Abort('Correct phase push failed (because hooks)') |
|
794 | > raise error.Abort(b'Correct phase push failed (because hooks)') | |
795 | > pushop.pkfailcb[part.id] = fail |
|
795 | > pushop.pkfailcb[part.id] = fail | |
796 | > EOF |
|
796 | > EOF | |
797 | $ cat >> $HGRCPATH << EOF |
|
797 | $ cat >> $HGRCPATH << EOF | |
@@ -858,16 +858,16 b' Check abort from mandatory pushkey' | |||||
858 | > from mercurial import pushkey |
|
858 | > from mercurial import pushkey | |
859 | > from mercurial import node |
|
859 | > from mercurial import node | |
860 | > from mercurial import error |
|
860 | > from mercurial import error | |
861 | > @exchange.b2partsgenerator('failingpuskey') |
|
861 | > @exchange.b2partsgenerator(b'failingpuskey') | |
862 | > def addfailingpushey(pushop, bundler): |
|
862 | > def addfailingpushey(pushop, bundler): | |
863 | > enc = pushkey.encode |
|
863 | > enc = pushkey.encode | |
864 | > part = bundler.newpart('pushkey') |
|
864 | > part = bundler.newpart(b'pushkey') | |
865 | > part.addparam('namespace', enc('phases')) |
|
865 | > part.addparam(b'namespace', enc(b'phases')) | |
866 | > part.addparam('key', enc('cd010b8cd998f3981a5a8115f94f8da4ab506089')) |
|
866 | > part.addparam(b'key', enc(b'cd010b8cd998f3981a5a8115f94f8da4ab506089')) | |
867 |
> part.addparam('old', enc( |
|
867 | > part.addparam(b'old', enc(b'4')) # will fail | |
868 |
> part.addparam('new', enc( |
|
868 | > part.addparam(b'new', enc(b'3')) | |
869 | > def fail(pushop, exc): |
|
869 | > def fail(pushop, exc): | |
870 | > raise error.Abort('Clown phase push failed') |
|
870 | > raise error.Abort(b'Clown phase push failed') | |
871 | > pushop.pkfailcb[part.id] = fail |
|
871 | > pushop.pkfailcb[part.id] = fail | |
872 | > EOF |
|
872 | > EOF | |
873 | $ cat >> $HGRCPATH << EOF |
|
873 | $ cat >> $HGRCPATH << EOF |
General Comments 0
You need to be logged in to leave comments.
Login now