comparison tests/test-bundle2.t @ 21146:4676135ac555

bundle2: move all parts into a `bx2` namespace All currently core parts are moved to a `bx2` namespace (for "bundle 2 experimental"). This should avoid conflicts between the final stable format and the one about to be released.
author Pierre-Yves David <pierre-yves.david@fb.com>
date Thu, 17 Apr 2014 15:45:12 -0400
parents 7a20fe8dc080
children 2a246e737f92
comparison
equal deleted inserted replaced
21145:0c5088be66af 21146:4676135ac555
71 > except ValueError, exc: 71 > except ValueError, exc:
72 > raise util.Abort('%s' % exc) 72 > raise util.Abort('%s' % exc)
73 > 73 >
74 > if opts['reply']: 74 > if opts['reply']:
75 > capsstring = 'ping-pong\nelephants=babar,celeste\ncity%3D%21=celeste%2Cville' 75 > capsstring = 'ping-pong\nelephants=babar,celeste\ncity%3D%21=celeste%2Cville'
76 > bundler.addpart(bundle2.bundlepart('replycaps', data=capsstring)) 76 > bundler.addpart(bundle2.bundlepart('b2x:replycaps', data=capsstring))
77 > 77 >
78 > revs = opts['rev'] 78 > revs = opts['rev']
79 > if 'rev' in opts: 79 > if 'rev' in opts:
80 > revs = scmutil.revrange(repo, opts['rev']) 80 > revs = scmutil.revrange(repo, opts['rev'])
81 > if revs: 81 > if revs:
83 > bundled = repo.revs('%ld::%ld', revs, revs) 83 > bundled = repo.revs('%ld::%ld', revs, revs)
84 > headmissing = [c.node() for c in repo.set('heads(%ld)', revs)] 84 > headmissing = [c.node() for c in repo.set('heads(%ld)', revs)]
85 > headcommon = [c.node() for c in repo.set('parents(%ld) - %ld', revs, revs)] 85 > headcommon = [c.node() for c in repo.set('parents(%ld) - %ld', revs, revs)]
86 > outgoing = discovery.outgoing(repo.changelog, headcommon, headmissing) 86 > outgoing = discovery.outgoing(repo.changelog, headcommon, headmissing)
87 > cg = changegroup.getlocalbundle(repo, 'test:bundle2', outgoing, None) 87 > cg = changegroup.getlocalbundle(repo, 'test:bundle2', outgoing, None)
88 > part = bundle2.bundlepart('changegroup', data=cg.getchunks()) 88 > part = bundle2.bundlepart('b2x:changegroup', data=cg.getchunks())
89 > bundler.addpart(part) 89 > bundler.addpart(part)
90 > 90 >
91 > if opts['parts']: 91 > if opts['parts']:
92 > part = bundle2.bundlepart('test:empty') 92 > part = bundle2.bundlepart('test:empty')
93 > bundler.addpart(part) 93 > bundler.addpart(part)
541 3 total verses sung 541 3 total verses sung
542 542
543 The reply is a bundle 543 The reply is a bundle
544 544
545 $ cat ../reply.hg2 545 $ cat ../reply.hg2
546 HG2X\x00\x00\x00\x1b\x06output\x00\x00\x00\x00\x00\x01\x0b\x01in-reply-to3\x00\x00\x00\xd9The choir starts singing: (esc) 546 HG2X\x00\x00\x00\x1f (esc)
547 b2x:output\x00\x00\x00\x00\x00\x01\x0b\x01in-reply-to3\x00\x00\x00\xd9The choir starts singing: (esc)
547 Patali Dirapata, Cromda Cromda Ripalo, Pata Pata, Ko Ko Ko 548 Patali Dirapata, Cromda Cromda Ripalo, Pata Pata, Ko Ko Ko
548 Bokoro Dipoulito, Rondi Rondi Pepino, Pata Pata, Ko Ko Ko 549 Bokoro Dipoulito, Rondi Rondi Pepino, Pata Pata, Ko Ko Ko
549 Emana Karassoli, Loucra Loucra Ponponto, Pata Pata, Ko Ko Ko. 550 Emana Karassoli, Loucra Loucra Ponponto, Pata Pata, Ko Ko Ko.
550 \x00\x00\x00\x00\x00\x1b\x06output\x00\x00\x00\x01\x00\x01\x0b\x01in-reply-to4\x00\x00\x00\xc9debugreply: capabilities: (esc) 551 \x00\x00\x00\x00\x00\x1f (esc)
552 b2x:output\x00\x00\x00\x01\x00\x01\x0b\x01in-reply-to4\x00\x00\x00\xc9debugreply: capabilities: (esc)
551 debugreply: 'city=!' 553 debugreply: 'city=!'
552 debugreply: 'celeste,ville' 554 debugreply: 'celeste,ville'
553 debugreply: 'elephants' 555 debugreply: 'elephants'
554 debugreply: 'babar' 556 debugreply: 'babar'
555 debugreply: 'celeste' 557 debugreply: 'celeste'
556 debugreply: 'ping-pong' 558 debugreply: 'ping-pong'
557 \x00\x00\x00\x00\x00\x1e test:pong\x00\x00\x00\x02\x01\x00\x0b\x01in-reply-to6\x00\x00\x00\x00\x00\x1b\x06output\x00\x00\x00\x03\x00\x01\x0b\x01in-reply-to6\x00\x00\x00=received ping request (id 6) (esc) 559 \x00\x00\x00\x00\x00\x1e test:pong\x00\x00\x00\x02\x01\x00\x0b\x01in-reply-to6\x00\x00\x00\x00\x00\x1f (esc)
560 b2x:output\x00\x00\x00\x03\x00\x01\x0b\x01in-reply-to6\x00\x00\x00=received ping request (id 6) (esc)
558 replying to ping request (id 6) 561 replying to ping request (id 6)
559 \x00\x00\x00\x00\x00\x00 (no-eol) (esc) 562 \x00\x00\x00\x00\x00\x00 (no-eol) (esc)
560 563
561 The reply is valid 564 The reply is valid
562 565
563 $ hg statbundle2 < ../reply.hg2 566 $ hg statbundle2 < ../reply.hg2
564 options count: 0 567 options count: 0
565 :output: 568 :b2x:output:
566 mandatory: 0 569 mandatory: 0
567 advisory: 1 570 advisory: 1
568 payload: 217 bytes 571 payload: 217 bytes
569 :output: 572 :b2x:output:
570 mandatory: 0 573 mandatory: 0
571 advisory: 1 574 advisory: 1
572 payload: 201 bytes 575 payload: 201 bytes
573 :test:pong: 576 :test:pong:
574 mandatory: 1 577 mandatory: 1
575 advisory: 0 578 advisory: 0
576 payload: 0 bytes 579 payload: 0 bytes
577 :output: 580 :b2x:output:
578 mandatory: 0 581 mandatory: 0
579 advisory: 1 582 advisory: 1
580 payload: 61 bytes 583 payload: 61 bytes
581 parts count: 4 584 parts count: 4
582 585
670 eea13746799a9e0bfd88f29d3c2e9dc9389f524f 673 eea13746799a9e0bfd88f29d3c2e9dc9389f524f
671 02de42196ebee42ef284b6780a87cdc96e8eaab6 674 02de42196ebee42ef284b6780a87cdc96e8eaab6
672 start emission of HG2X stream 675 start emission of HG2X stream
673 bundle parameter: 676 bundle parameter:
674 start of parts 677 start of parts
675 bundle part: "changegroup" 678 bundle part: "b2x:changegroup"
676 bundling: 1/4 changesets (25.00%) 679 bundling: 1/4 changesets (25.00%)
677 bundling: 2/4 changesets (50.00%) 680 bundling: 2/4 changesets (50.00%)
678 bundling: 3/4 changesets (75.00%) 681 bundling: 3/4 changesets (75.00%)
679 bundling: 4/4 changesets (100.00%) 682 bundling: 4/4 changesets (100.00%)
680 bundling: 1/4 manifests (25.00%) 683 bundling: 1/4 manifests (25.00%)
685 bundling: E 2/3 files (66.67%) 688 bundling: E 2/3 files (66.67%)
686 bundling: H 3/3 files (100.00%) 689 bundling: H 3/3 files (100.00%)
687 end of bundle 690 end of bundle
688 691
689 $ cat ../rev.hg2 692 $ cat ../rev.hg2
690 HG2X\x00\x00\x00\x12\x0bchangegroup\x00\x00\x00\x00\x00\x00\x00\x00\x06\x13\x00\x00\x00\xa42\xafv\x86\xd4\x03\xcfE\xb5\xd9_-p\xce\xbe\xa5\x87\xac\x80j_\xdd\xd9\x89W\xc8\xa5JMCm\xfe\x1d\xa9\xd8\x7f!\xa1\xb9{\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x002\xafv\x86\xd4\x03\xcfE\xb5\xd9_-p\xce\xbe\xa5\x87\xac\x80j\x00\x00\x00\x00\x00\x00\x00)\x00\x00\x00)6e1f4c47ecb533ffd0c8e52cdc88afb6cd39e20c (esc) 693 HG2X\x00\x00\x00\x16\x0fb2x:changegroup\x00\x00\x00\x00\x00\x00\x00\x00\x06\x13\x00\x00\x00\xa42\xafv\x86\xd4\x03\xcfE\xb5\xd9_-p\xce\xbe\xa5\x87\xac\x80j_\xdd\xd9\x89W\xc8\xa5JMCm\xfe\x1d\xa9\xd8\x7f!\xa1\xb9{\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x002\xafv\x86\xd4\x03\xcfE\xb5\xd9_-p\xce\xbe\xa5\x87\xac\x80j\x00\x00\x00\x00\x00\x00\x00)\x00\x00\x00)6e1f4c47ecb533ffd0c8e52cdc88afb6cd39e20c (esc)
691 \x00\x00\x00f\x00\x00\x00h\x00\x00\x00\x02D (esc) 694 \x00\x00\x00f\x00\x00\x00h\x00\x00\x00\x02D (esc)
692 \x00\x00\x00i\x00\x00\x00j\x00\x00\x00\x01D\x00\x00\x00\xa4\x95 \xee\xa7\x81\xbc\xca\x16\xc1\xe1Z\xcc\x0b\xa1C5\xa0\xe8\xe5\xba\xcd\x01\x0b\x8c\xd9\x98\xf3\x98\x1aZ\x81\x15\xf9O\x8d\xa4\xabP`\x89\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x95 \xee\xa7\x81\xbc\xca\x16\xc1\xe1Z\xcc\x0b\xa1C5\xa0\xe8\xe5\xba\x00\x00\x00\x00\x00\x00\x00)\x00\x00\x00)4dece9c826f69490507b98c6383a3009b295837d (esc) 695 \x00\x00\x00i\x00\x00\x00j\x00\x00\x00\x01D\x00\x00\x00\xa4\x95 \xee\xa7\x81\xbc\xca\x16\xc1\xe1Z\xcc\x0b\xa1C5\xa0\xe8\xe5\xba\xcd\x01\x0b\x8c\xd9\x98\xf3\x98\x1aZ\x81\x15\xf9O\x8d\xa4\xabP`\x89\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x95 \xee\xa7\x81\xbc\xca\x16\xc1\xe1Z\xcc\x0b\xa1C5\xa0\xe8\xe5\xba\x00\x00\x00\x00\x00\x00\x00)\x00\x00\x00)4dece9c826f69490507b98c6383a3009b295837d (esc)
693 \x00\x00\x00f\x00\x00\x00h\x00\x00\x00\x02E (esc) 696 \x00\x00\x00f\x00\x00\x00h\x00\x00\x00\x02E (esc)
694 \x00\x00\x00i\x00\x00\x00j\x00\x00\x00\x01E\x00\x00\x00\xa2\xee\xa17Fy\x9a\x9e\x0b\xfd\x88\xf2\x9d<.\x9d\xc98\x9fRO$\xb68|\x8c\x8c\xae7\x17\x88\x80\xf3\xfa\x95\xde\xd3\xcb\x1c\xf7\x85\x95 \xee\xa7\x81\xbc\xca\x16\xc1\xe1Z\xcc\x0b\xa1C5\xa0\xe8\xe5\xba\xee\xa17Fy\x9a\x9e\x0b\xfd\x88\xf2\x9d<.\x9d\xc98\x9fRO\x00\x00\x00\x00\x00\x00\x00)\x00\x00\x00)365b93d57fdf4814e2b5911d6bacff2b12014441 (esc) 697 \x00\x00\x00i\x00\x00\x00j\x00\x00\x00\x01E\x00\x00\x00\xa2\xee\xa17Fy\x9a\x9e\x0b\xfd\x88\xf2\x9d<.\x9d\xc98\x9fRO$\xb68|\x8c\x8c\xae7\x17\x88\x80\xf3\xfa\x95\xde\xd3\xcb\x1c\xf7\x85\x95 \xee\xa7\x81\xbc\xca\x16\xc1\xe1Z\xcc\x0b\xa1C5\xa0\xe8\xe5\xba\xee\xa17Fy\x9a\x9e\x0b\xfd\x88\xf2\x9d<.\x9d\xc98\x9fRO\x00\x00\x00\x00\x00\x00\x00)\x00\x00\x00)365b93d57fdf4814e2b5911d6bacff2b12014441 (esc)
695 \x00\x00\x00f\x00\x00\x00h\x00\x00\x00\x00\x00\x00\x00i\x00\x00\x00j\x00\x00\x00\x01G\x00\x00\x00\xa4\x02\xdeB\x19n\xbe\xe4.\xf2\x84\xb6x (esc) 698 \x00\x00\x00f\x00\x00\x00h\x00\x00\x00\x00\x00\x00\x00i\x00\x00\x00j\x00\x00\x00\x01G\x00\x00\x00\xa4\x02\xdeB\x19n\xbe\xe4.\xf2\x84\xb6x (esc)
724 $ hg unbundle2 ../rev-reply.hg2 < ../rev-rr.hg2 727 $ hg unbundle2 ../rev-reply.hg2 < ../rev-rr.hg2
725 0 unread bytes 728 0 unread bytes
726 addchangegroup return: 1 729 addchangegroup return: 1
727 730
728 $ cat ../rev-reply.hg2 731 $ cat ../rev-reply.hg2
729 HG2X\x00\x00\x00/\x11reply:changegroup\x00\x00\x00\x00\x00\x02\x0b\x01\x06\x01in-reply-to1return1\x00\x00\x00\x00\x00\x1b\x06output\x00\x00\x00\x01\x00\x01\x0b\x01in-reply-to1\x00\x00\x00dadding changesets (esc) 732 HG2X\x00\x00\x003\x15b2x:reply:changegroup\x00\x00\x00\x00\x00\x02\x0b\x01\x06\x01in-reply-to1return1\x00\x00\x00\x00\x00\x1f (esc)
733 b2x:output\x00\x00\x00\x01\x00\x01\x0b\x01in-reply-to1\x00\x00\x00dadding changesets (esc)
730 adding manifests 734 adding manifests
731 adding file changes 735 adding file changes
732 added 0 changesets with 0 changes to 3 files 736 added 0 changesets with 0 changes to 3 files
733 \x00\x00\x00\x00\x00\x00 (no-eol) (esc) 737 \x00\x00\x00\x00\x00\x00 (no-eol) (esc)
734 738