#require serve no-reposimplestore no-chg

#testcases stream-legacy stream-bundle2

#if stream-legacy

  $ cat << EOF >> $HGRCPATH

  > [server]

  > bundle2.stream = no

  > EOF

#endif

Initialize repository

  $ hg init server

  $ cd server

  $ sh $TESTDIR/testlib/stream_clone_setup.sh

  adding 00changelog-ab349180a0405010.nd

  adding 00changelog.d

  adding 00changelog.i

  adding 00changelog.n

  adding 00manifest.d

  adding 00manifest.i

  adding container/isam-build-centos7/bazel-coverage-generator-sandboxfs-compatibility-0758e3e4f6057904d44399bd666faba9e7f40686.patch

  adding data/foo.d

  adding data/foo.i

  adding data/foo.n

  adding data/undo.babar

  adding data/undo.d

  adding data/undo.foo.d

  adding data/undo.foo.i

  adding data/undo.foo.n

  adding data/undo.i

  adding data/undo.n

  adding data/undo.py

  adding foo.d

  adding foo.i

  adding foo.n

  adding meta/foo.d

  adding meta/foo.i

  adding meta/foo.n

  adding meta/undo.babar

  adding meta/undo.d

  adding meta/undo.foo.d

  adding meta/undo.foo.i

  adding meta/undo.foo.n

  adding meta/undo.i

  adding meta/undo.n

  adding meta/undo.py

  adding savanah/foo.d

  adding savanah/foo.i

  adding savanah/foo.n

  adding savanah/undo.babar

  adding savanah/undo.d

  adding savanah/undo.foo.d

  adding savanah/undo.foo.i

  adding savanah/undo.foo.n

  adding savanah/undo.i

  adding savanah/undo.n

  adding savanah/undo.py

  adding store/C\xc3\xa9lesteVille_is_a_Capital_City (esc)

  adding store/foo.d

  adding store/foo.i

  adding store/foo.n

  adding store/undo.babar

  adding store/undo.d

  adding store/undo.foo.d

  adding store/undo.foo.i

  adding store/undo.foo.n

  adding store/undo.i

  adding store/undo.n

  adding store/undo.py

  adding undo.babar

  adding undo.d

  adding undo.foo.d

  adding undo.foo.i

  adding undo.foo.n

  adding undo.i

  adding undo.n

  adding undo.py

  $ hg --config server.uncompressed=false serve -p $HGPORT -d --pid-file=hg.pid

  $ cat hg.pid > $DAEMON_PIDS

  $ cd ..

Check local clone

==================

The logic is close enough of uncompressed.

This is present here to reuse the testing around file with "special" names.

  $ hg clone server local-clone

  updating to branch default

  1088 files updated, 0 files merged, 0 files removed, 0 files unresolved

Check that the clone went well

  $ hg verify -R local-clone

  checking changesets

  checking manifests

  crosschecking files in changesets and manifests

  checking files

  checked 3 changesets with 1088 changes to 1088 files

Check uncompressed

==================

Cannot stream clone when server.uncompressed is set

  $ get-with-headers.py $LOCALIP:$HGPORT '?cmd=stream_out'

  200 Script output follows

  1

#if stream-legacy

  $ hg debugcapabilities http://localhost:$HGPORT

  Main capabilities:

    batch

    branchmap

    $USUAL_BUNDLE2_CAPS_SERVER$

    changegroupsubset

    compression=$BUNDLE2_COMPRESSIONS$

    getbundle

    httpheader=1024

    httpmediatype=0.1rx,0.1tx,0.2tx

    known

    lookup

    pushkey

    unbundle=HG10GZ,HG10BZ,HG10UN

    unbundlehash

  Bundle2 capabilities:

    HG20

    bookmarks

    changegroup

      01

      02

    checkheads

      related

    digests

      md5

      sha1

      sha512

    error

      abort

      unsupportedcontent

      pushraced

      pushkey

    hgtagsfnodes

    listkeys

    phases

      heads

    pushkey

    remote-changegroup

      http

      https

  $ hg clone --stream -U http://localhost:$HGPORT server-disabled

  warning: stream clone requested but server has them disabled

  requesting all changes

  adding changesets

  adding manifests

  adding file changes

  added 3 changesets with 1088 changes to 1088 files

  new changesets 96ee1d7354c4:5223b5e3265f

  $ get-with-headers.py $LOCALIP:$HGPORT '?cmd=getbundle' content-type --bodyfile body --hgproto 0.2 --requestheader "x-hgarg-1=bundlecaps=HG20%2Cbundle2%3DHG20%250Abookmarks%250Achangegroup%253D01%252C02%250Adigests%253Dmd5%252Csha1%252Csha512%250Aerror%253Dabort%252Cunsupportedcontent%252Cpushraced%252Cpushkey%250Ahgtagsfnodes%250Alistkeys%250Aphases%253Dheads%250Apushkey%250Aremote-changegroup%253Dhttp%252Chttps&cg=0&common=0000000000000000000000000000000000000000&heads=c17445101a72edac06facd130d14808dfbd5c7c2&stream=1"

  200 Script output follows

  content-type: application/mercurial-0.2

  $ f --size body --hexdump --bytes 100

  body: size=232

  0000: 04 6e 6f 6e 65 48 47 32 30 00 00 00 00 00 00 00 |.noneHG20.......|

  0010: cf 0b 45 52 52 4f 52 3a 41 42 4f 52 54 00 00 00 |..ERROR:ABORT...|

  0020: 00 01 01 07 3c 04 72 6d 65 73 73 61 67 65 73 74 |....<.rmessagest|

  0030: 72 65 61 6d 20 64 61 74 61 20 72 65 71 75 65 73 |ream data reques|

  0040: 74 65 64 20 62 75 74 20 73 65 72 76 65 72 20 64 |ted but server d|

  0050: 6f 65 73 20 6e 6f 74 20 61 6c 6c 6f 77 20 74 68 |oes not allow th|

  0060: 69 73 20 66                                     |is f|

#endif

#if stream-bundle2

  $ hg debugcapabilities http://localhost:$HGPORT

  Main capabilities:

    batch

    branchmap

    $USUAL_BUNDLE2_CAPS_SERVER$

    changegroupsubset

    compression=$BUNDLE2_COMPRESSIONS$

    getbundle

    httpheader=1024

    httpmediatype=0.1rx,0.1tx,0.2tx

    known

    lookup

    pushkey

    unbundle=HG10GZ,HG10BZ,HG10UN

    unbundlehash

  Bundle2 capabilities:

    HG20

    bookmarks

    changegroup

      01

      02

    checkheads

      related

    digests

      md5

      sha1

      sha512

    error

      abort

      unsupportedcontent

      pushraced

      pushkey

    hgtagsfnodes

    listkeys

    phases

      heads

    pushkey

    remote-changegroup

      http

      https

  $ hg clone --stream -U http://localhost:$HGPORT server-disabled

  warning: stream clone requested but server has them disabled

  requesting all changes

  adding changesets

  adding manifests

  adding file changes

  added 3 changesets with 1088 changes to 1088 files

  new changesets 96ee1d7354c4:5223b5e3265f

  $ get-with-headers.py $LOCALIP:$HGPORT '?cmd=getbundle' content-type --bodyfile body --hgproto 0.2 --requestheader "x-hgarg-1=bundlecaps=HG20%2Cbundle2%3DHG20%250Abookmarks%250Achangegroup%253D01%252C02%250Adigests%253Dmd5%252Csha1%252Csha512%250Aerror%253Dabort%252Cunsupportedcontent%252Cpushraced%252Cpushkey%250Ahgtagsfnodes%250Alistkeys%250Aphases%253Dheads%250Apushkey%250Aremote-changegroup%253Dhttp%252Chttps&cg=0&common=0000000000000000000000000000000000000000&heads=c17445101a72edac06facd130d14808dfbd5c7c2&stream=1"

  200 Script output follows

  content-type: application/mercurial-0.2

  $ f --size body --hexdump --bytes 100

  body: size=232

  0000: 04 6e 6f 6e 65 48 47 32 30 00 00 00 00 00 00 00 |.noneHG20.......|

  0010: cf 0b 45 52 52 4f 52 3a 41 42 4f 52 54 00 00 00 |..ERROR:ABORT...|

  0020: 00 01 01 07 3c 04 72 6d 65 73 73 61 67 65 73 74 |....<.rmessagest|

  0030: 72 65 61 6d 20 64 61 74 61 20 72 65 71 75 65 73 |ream data reques|

  0040: 74 65 64 20 62 75 74 20 73 65 72 76 65 72 20 64 |ted but server d|

  0050: 6f 65 73 20 6e 6f 74 20 61 6c 6c 6f 77 20 74 68 |oes not allow th|

  0060: 69 73 20 66                                     |is f|

#endif

  $ killdaemons.py

  $ cd server

  $ hg serve -p $HGPORT -d --pid-file=hg.pid --error errors.txt

  $ cat hg.pid > $DAEMON_PIDS

  $ cd ..

Basic clone

#if stream-legacy

  $ hg clone --stream -U http://localhost:$HGPORT clone1

  streaming all changes

  1090 files to transfer, 102 KB of data (no-zstd !)

  transferred 102 KB in * seconds (* */sec) (glob) (no-zstd !)

  1090 files to transfer, 98.8 KB of data (zstd !)

  transferred 98.8 KB in * seconds (* */sec) (glob) (zstd !)

  searching for changes

  no changes found

  $ cat server/errors.txt

#endif

#if stream-bundle2

  $ hg clone --stream -U http://localhost:$HGPORT clone1

  streaming all changes

  1093 files to transfer, 102 KB of data (no-zstd !)

  transferred 102 KB in * seconds (* */sec) (glob) (no-zstd !)

  1093 files to transfer, 98.9 KB of data (zstd !)

  transferred 98.9 KB in * seconds (* */sec) (glob) (zstd !)

  $ ls -1 clone1/.hg/cache

  branch2-base

  branch2-immutable

  branch2-served

  branch2-served.hidden

  branch2-visible

  branch2-visible-hidden

  rbc-names-v1

  rbc-revs-v1

  tags2

  tags2-served

  $ cat server/errors.txt

#endif

getbundle requests with stream=1 are uncompressed

  $ get-with-headers.py $LOCALIP:$HGPORT '?cmd=getbundle' content-type --bodyfile body --hgproto '0.1 0.2 comp=zlib,none' --requestheader "x-hgarg-1=bundlecaps=HG20%2Cbundle2%3DHG20%250Abookmarks%250Achangegroup%253D01%252C02%250Adigests%253Dmd5%252Csha1%252Csha512%250Aerror%253Dabort%252Cunsupportedcontent%252Cpushraced%252Cpushkey%250Ahgtagsfnodes%250Alistkeys%250Aphases%253Dheads%250Apushkey%250Aremote-changegroup%253Dhttp%252Chttps&cg=0&common=0000000000000000000000000000000000000000&heads=c17445101a72edac06facd130d14808dfbd5c7c2&stream=1"

  200 Script output follows

  content-type: application/mercurial-0.2

#if no-zstd no-rust

  $ f --size --hex --bytes 256 body

  body: size=119123

  0000: 04 6e 6f 6e 65 48 47 32 30 00 00 00 00 00 00 00 |.noneHG20.......|

  0010: 62 07 53 54 52 45 41 4d 32 00 00 00 00 03 00 09 |b.STREAM2.......|

  0020: 06 09 04 0c 26 62 79 74 65 63 6f 75 6e 74 31 30 |....&bytecount10|

  0030: 34 31 31 35 66 69 6c 65 63 6f 75 6e 74 31 30 39 |4115filecount109|

  0040: 33 72 65 71 75 69 72 65 6d 65 6e 74 73 67 65 6e |3requirementsgen|

  0050: 65 72 61 6c 64 65 6c 74 61 25 32 43 72 65 76 6c |eraldelta%2Crevl|

  0060: 6f 67 76 31 25 32 43 73 70 61 72 73 65 72 65 76 |ogv1%2Csparserev|

  0070: 6c 6f 67 00 00 80 00 73 08 42 64 61 74 61 2f 30 |log....s.Bdata/0|

  0080: 2e 69 00 03 00 01 00 00 00 00 00 00 00 02 00 00 |.i..............|

  0090: 00 01 00 00 00 00 00 00 00 01 ff ff ff ff ff ff |................|

  00a0: ff ff 80 29 63 a0 49 d3 23 87 bf ce fe 56 67 92 |...)c.I.#....Vg.|

  00b0: 67 2c 69 d1 ec 39 00 00 00 00 00 00 00 00 00 00 |g,i..9..........|

  00c0: 00 00 75 30 73 26 45 64 61 74 61 2f 30 30 63 68 |..u0s&Edata/00ch|

  00d0: 61 6e 67 65 6c 6f 67 2d 61 62 33 34 39 31 38 30 |angelog-ab349180|

  00e0: 61 30 34 30 35 30 31 30 2e 6e 64 2e 69 00 03 00 |a0405010.nd.i...|

  00f0: 01 00 00 00 00 00 00 00 05 00 00 00 04 00 00 00 |................|

#endif

#if zstd no-rust

  $ f --size --hex --bytes 256 body

  body: size=116310 (no-bigendian !)

  body: size=116305 (bigendian !)

  0000: 04 6e 6f 6e 65 48 47 32 30 00 00 00 00 00 00 00 |.noneHG20.......|

  0010: 7c 07 53 54 52 45 41 4d 32 00 00 00 00 03 00 09 ||.STREAM2.......|

  0020: 06 09 04 0c 40 62 79 74 65 63 6f 75 6e 74 31 30 |....@bytecount10|

  0030: 31 32 37 36 66 69 6c 65 63 6f 75 6e 74 31 30 39 |1276filecount109| (no-bigendian !)

  0030: 31 32 37 31 66 69 6c 65 63 6f 75 6e 74 31 30 39 |1271filecount109| (bigendian !)

  0040: 33 72 65 71 75 69 72 65 6d 65 6e 74 73 67 65 6e |3requirementsgen|

  0050: 65 72 61 6c 64 65 6c 74 61 25 32 43 72 65 76 6c |eraldelta%2Crevl|

  0060: 6f 67 2d 63 6f 6d 70 72 65 73 73 69 6f 6e 2d 7a |og-compression-z|

  0070: 73 74 64 25 32 43 72 65 76 6c 6f 67 76 31 25 32 |std%2Crevlogv1%2|

  0080: 43 73 70 61 72 73 65 72 65 76 6c 6f 67 00 00 80 |Csparserevlog...|

  0090: 00 73 08 42 64 61 74 61 2f 30 2e 69 00 03 00 01 |.s.Bdata/0.i....|

  00a0: 00 00 00 00 00 00 00 02 00 00 00 01 00 00 00 00 |................|

  00b0: 00 00 00 01 ff ff ff ff ff ff ff ff 80 29 63 a0 |.............)c.|

  00c0: 49 d3 23 87 bf ce fe 56 67 92 67 2c 69 d1 ec 39 |I.#....Vg.g,i..9|

  00d0: 00 00 00 00 00 00 00 00 00 00 00 00 75 30 73 26 |............u0s&|

  00e0: 45 64 61 74 61 2f 30 30 63 68 61 6e 67 65 6c 6f |Edata/00changelo|