comparison mercurial/wireprotoserver.py @ 37783:9d818539abfa

wireproto: move supportedcompengines out of wireproto

This function is used by both version 1 and version 2. It belongs in
a common module.

"wireprototypes" may not be the best module name. I may rename it...

Differential Revision: https://phab.mercurial-scm.org/D3398

37782:99accae4cc59

        # FUTURE advertise 0.2rx once support is implemented
        # FUTURE advertise minrx and mintx after consulting config option
        caps.append('httpmediatype=0.1rx,0.1tx,0.2tx')

        compengines = wireproto.supportedcompengines(repo.ui, util.SERVERROLE)
        if compengines:
            comptypes = ','.join(urlreq.quote(e.wireprotosupport().name)
                                 for e in compengines)
            caps.append('compression=%s' % comptypes)

        if prefer_uncompressed:
            return HGTYPE2, util._noopengine(), {}

        # Now find an agreed upon compression format.
        compformats = wireproto.clientcompressionsupport(proto)
        for engine in wireproto.supportedcompengines(ui, util.SERVERROLE):
            if engine.wireprotosupport().name in compformats:
                opts = {}
                level = ui.configint('server', '%slevel' % engine.name())
                if level is not None:
                    opts['level'] = level

37783:9d818539abfa

        # FUTURE advertise 0.2rx once support is implemented
        # FUTURE advertise minrx and mintx after consulting config option
        caps.append('httpmediatype=0.1rx,0.1tx,0.2tx')

        compengines = wireprototypes.supportedcompengines(repo.ui,
                                                          util.SERVERROLE)
        if compengines:
            comptypes = ','.join(urlreq.quote(e.wireprotosupport().name)
                                 for e in compengines)
            caps.append('compression=%s' % comptypes)

        if prefer_uncompressed:
            return HGTYPE2, util._noopengine(), {}

        # Now find an agreed upon compression format.
        compformats = wireproto.clientcompressionsupport(proto)
        for engine in wireprototypes.supportedcompengines(ui, util.SERVERROLE):
            if engine.wireprotosupport().name in compformats:
                opts = {}
                level = ui.configint('server', '%slevel' % engine.name())
                if level is not None:
                    opts['level'] = level