outgoing: add a simple fastpath when there is no common This further speed up case like `hg bundle --all` for larger repository. ### data-env-vars.name = mozilla-try-2023-03-22-zstd-sparse-revlog # benchmark.name = hg.command.bundle # bin-env-vars.hg.flavor = default # bin-env-vars.hg.py-re2-module = default # benchmark.variants.revs = all # benchmark.variants.type = none-streamv2 before: 316.749699 after: 311.165461 (-1.76%, -5.58) There is further work to be done in this area like not doing any outgoing computation in the stream case for example. however the recent changes already gives use a large win for a small amount of local work. ### benchmark.name = hg.command.bundle # bin-env-vars.hg.flavor = default # bin-env-vars.hg.py-re2-module = default # benchmark.variants.revs = all # benchmark.variants.type = none-streamv2 ## data-env-vars.name = mercurial-public-2024-03-22-zstd-sparse-revlog pre-%ln-change: 1.263859 the-%ln-change: 0.700229 (-44.60%, -0.56) prev-changeset: 0.496050 (-60.75%, -0.77) this-changeset: 0.495243 (-60.81%, -0.77) ## data-env-vars.name = tryton-public-2024-03-22-zstd-sparse-revlog pre-%ln-change: 2.975765 the-%ln-change: 1.870798 (-37.13%, -1.10) prev-changeset: 1.461583 (-50.88%, -1.51) this-changeset: 1.469185 (-50.63%, -1.51) ## data-env-vars.name = pypy-2024-03-22-zstd-sparse-revlog pre-%ln-change: 4.540080 the-%ln-change: 3.401700 (-25.07%, -1.14) prev-changeset: 2.915810 (-35.78%, -1.62) this-changeset: 2.911643 (-35.87%, -1.63) ## data-env-vars.name = heptapod-public-2024-03-25-zstd-sparse-revlog pre-%ln-change: 10.138396 the-%ln-change: 7.750458 (-23.55%, -2.39) prev-changeset: 6.665565 (-34.25%, -3.47) this-changeset: 6.672078 (-34.19%, -3.47) ## data-env-vars.name = mozilla-try-2023-03-22-zstd-sparse-revlog pre-%ln-change: 399.484481 the-%ln-change: 346.508952 (-13.26%, -52.98) prev-changeset: 316.749699 (-20.71%, -82.73) this-changeset: 311.165461 (-22.11%, -88.32)

     1

import io

     2

import unittest

     3

     4

import silenttestrunner

     5

     6

from mercurial import (

     7

    wireprotoserver,

     8

    wireprotov1server,

     9

)

    10

    11

from mercurial.utils import procutil

    12

    13

    14

class SSHServerGetArgsTests(unittest.TestCase):

    15

    def testparseknown(self):

    16

        tests = [

    17

            (b'* 0\nnodes 0\n', [b'', {}]),

    18

            (

    19

                b'* 0\nnodes 40\n1111111111111111111111111111111111111111\n',

    20

                [b'1111111111111111111111111111111111111111', {}],

    21

            ),

    22

        ]

    23

        for input, expected in tests:

    24

            self.assertparse(b'known', input, expected)

    25

    26

    def assertparse(self, cmd, input, expected):

    27

        server = mockserver(input)

    28

        proto = wireprotoserver.sshv1protocolhandler(

    29

            server._ui, server._fin, server._fout

    30

        )

    31

        _func, spec = wireprotov1server.commands[cmd]

    32

        self.assertEqual(proto.getargs(spec), expected)

    33

    34

    35

def mockserver(inbytes):

    36

    ui = mockui(inbytes)

    37

    repo = mockrepo(ui)

    38

    return wireprotoserver.sshserver(ui, repo)

    39

    40

    41

class mockrepo:

    42

    def __init__(self, ui):

    43

        self.ui = ui

    44

    45

    46

class mockui:

    47

    def __init__(self, inbytes):

    48

        self.fin = io.BytesIO(inbytes)

    49

        self.fout = io.BytesIO()

    50

        self.ferr = io.BytesIO()

    51

    52

    def protectfinout(self):

    53

        return self.fin, self.fout

    54

    55

    def restorefinout(self, fin, fout):

    56

        pass

    57

    58

    59

if __name__ == '__main__':

    60

    # Don't call into msvcrt to set BytesIO to binary mode

    61

    procutil.setbinary = lambda fp: True

    62

    silenttestrunner.main(__name__)