This is an archive of the discontinued Mercurial Phabricator instance.

Differential D6262

rust-discovery: using from Python code
AbandonedPublic

Authored by gracinet on Apr 17 2019, 8:17 AM.

Details

Reviewers
None
Group Reviewers
hg-reviewers
Summary

As previously done in other topics, the Rust version is used if it's been
built.

Diff Detail

Repository
rHG Mercurial
Lint
Lint Skipped
Unit
Unit Tests Skipped

Event Timeline

gracinet created this revision.Apr 17 2019, 8:17 AM
gracinet updated this revision to Diff 15026.May 6 2019, 11:31 AM
gracinet added a comment.May 22 2019, 12:38 PM

I'm abandoning this revision because I have to resubmit the whole series after partial incorrect application last week and subsequent droping from the actual repo.

gracinet abandoned this revision.May 22 2019, 12:39 PM

Revision Contents
Changeset List

PathPackages
Mmercurial/setdiscovery.py (12 lines)

Diff 15026

mercurial/setdiscovery.py

""" """
from __future__ import absolute_import from __future__ import absolute_import
import collections import collections
import random import random
from .i18n import _ from .i18n import _
try:
from .rustext import discovery as rustdisco
except ImportError:
rustdisco = None
from .node import ( from .node import (
nullid, nullid,
nullrev, nullrev,
) )
from . import ( from . import (
error, error,
util, util,
) )
if len(sample) == len(ownheads) and all(yesno): if len(sample) == len(ownheads) and all(yesno):
ui.note(_("all local heads known remotely\n")) ui.note(_("all local heads known remotely\n"))
ownheadhashes = [clnode(r) for r in ownheads] ownheadhashes = [clnode(r) for r in ownheads]
return ownheadhashes, True, srvheadhashes return ownheadhashes, True, srvheadhashes
# full blown discovery # full blown discovery
randomize = ui.configbool('devel', 'discovery.randomize') randomize = ui.configbool('devel', 'discovery.randomize')
if rustdisco is not None:
disco = rustdisco.PartialDiscovery(local.changelog.index, ownheads,
randomize=randomize)
else:
disco = partialdiscovery(local, ownheads, randomize=randomize) disco = partialdiscovery(local, ownheads, randomize=randomize)
# treat remote heads (and maybe own heads) as a first implicit sample # treat remote heads (and maybe own heads) as a first implicit sample
# response # response
disco.addcommons(knownsrvheads) disco.addcommons(knownsrvheads)
disco.addinfo(zip(sample, yesno)) disco.addinfo(zip(sample, yesno))
full = False full = False
progress = ui.makeprogress(_('searching'), unit=_('queries')) progress = ui.makeprogress(_('searching'), unit=_('queries'))
while not disco.iscomplete(): while not disco.iscomplete():