D318: wireproto: remove support for local results in @batchable (API)
indygreg (Gregory Szorc)
phabricator at mercurial-scm.org
Fri Aug 11 14:52:07 EDT 2017
This revision was automatically updated to reflect the committed changes.
Closed by commit rHGe2fc2122029c: wireproto: remove support for local results in @batchable (API) (authored by indygreg).
REPOSITORY
rHG Mercurial
CHANGES SINCE LAST UPDATE
https://phab.mercurial-scm.org/D318?vs=733&id=792
REVISION DETAIL
https://phab.mercurial-scm.org/D318
AFFECTED FILES
mercurial/peer.py
mercurial/wireproto.py
tests/test-batching.py
tests/test-batching.py.out
CHANGE DETAILS
diff --git a/tests/test-batching.py.out b/tests/test-batching.py.out
--- a/tests/test-batching.py.out
+++ b/tests/test-batching.py.out
@@ -4,7 +4,6 @@
Un and Deux
Eins und Zwei
One and Two
-Nope
Eins und Zwei
Hello, John Smith
Ready.
@@ -25,7 +24,6 @@
REQ: batch?cmds=bar:b=Vop,a=Evf
-> Vop!voe!Evf
One and Two
-Nope
Eins und Zwei
Hello, John Smith
Ready.
diff --git a/tests/test-batching.py b/tests/test-batching.py
--- a/tests/test-batching.py
+++ b/tests/test-batching.py
@@ -45,7 +45,6 @@
batch = it.batch()
# The calls return futures to eventually hold results.
foo = batch.foo(one="One", two="Two")
- foo2 = batch.foo(None)
bar = batch.bar("Eins", "Zwei")
# We can call non-batchable proxy methods, but the break the current batch
# request and cause additional roundtrips.
@@ -58,7 +57,6 @@
batch.submit()
# After the call to submit, the futures actually contain values.
print(foo.value)
- print(foo2.value)
print(bar.value)
print(greet.value)
print(hello.value)
@@ -153,8 +151,6 @@
@peer.batchable
def foo(self, one, two=None):
- if not one:
- yield "Nope", None
encargs = [('one', mangle(one),), ('two', mangle(two),)]
encresref = peer.future()
yield encargs, encresref
diff --git a/mercurial/wireproto.py b/mercurial/wireproto.py
--- a/mercurial/wireproto.py
+++ b/mercurial/wireproto.py
@@ -95,11 +95,9 @@
if batchablefn is not None:
batchable = batchablefn(mtd.im_self, *args, **opts)
encargsorres, encresref = next(batchable)
- if encresref:
- req.append((name, encargsorres,))
- rsp.append((batchable, encresref, resref,))
- else:
- resref.set(encargsorres)
+ assert encresref
+ req.append((name, encargsorres,))
+ rsp.append((batchable, encresref, resref,))
else:
if req:
self._submitreq(req, rsp)
diff --git a/mercurial/peer.py b/mercurial/peer.py
--- a/mercurial/peer.py
+++ b/mercurial/peer.py
@@ -78,9 +78,6 @@
@batchable
def sample(self, one, two=None):
- # Handle locally computable results first:
- if not one:
- yield "a local result", None
# Build list of encoded arguments suitable for your wire protocol:
encargs = [('one', encode(one),), ('two', encode(two),)]
# Create future for injection of encoded result:
To: indygreg, #hg-reviewers
Cc: mercurial-devel
More information about the Mercurial-devel
mailing list