You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by gm...@apache.org on 2021/03/23 22:16:23 UTC
[qpid-dispatch] branch master updated: DISPATCH-2008: Additional
fix. Added new grpc option grpc.http2.max_ping_strikes.
This is an automated email from the ASF dual-hosted git repository.
gmurthy pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/qpid-dispatch.git
The following commit(s) were added to refs/heads/master by this push:
new 7f2cb4c DISPATCH-2008: Additional fix. Added new grpc option grpc.http2.max_ping_strikes.
7f2cb4c is described below
commit 7f2cb4c204f9a613dfaaea41fc4372cb05877ab9
Author: Ganesh Murthy <gm...@apache.org>
AuthorDate: Tue Mar 23 15:30:56 2021 -0400
DISPATCH-2008: Additional fix. Added new grpc option grpc.http2.max_ping_strikes.
---
tests/friendship_server.py | 5 +++--
tests/system_tests_grpc.py | 11 ++++++++---
2 files changed, 11 insertions(+), 5 deletions(-)
diff --git a/tests/friendship_server.py b/tests/friendship_server.py
index be55851..41e0737 100644
--- a/tests/friendship_server.py
+++ b/tests/friendship_server.py
@@ -90,8 +90,9 @@ class FriendShipService(FriendshipServicer):
return None
-def serve(port):
- server = grpc.server(futures.ThreadPoolExecutor(max_workers=1))
+def serve(port, options=None):
+ server = grpc.server(futures.ThreadPoolExecutor(max_workers=1),
+ options=options)
add_FriendshipServicer_to_server(FriendShipService(), server)
server.add_insecure_port('[::]:%s' % port)
server.start()
diff --git a/tests/system_tests_grpc.py b/tests/system_tests_grpc.py
index 5140830..a444cf6 100644
--- a/tests/system_tests_grpc.py
+++ b/tests/system_tests_grpc.py
@@ -91,7 +91,10 @@ class GrpcServiceMethodsTest(TestCase):
cls.grpc_server_port = str(cls.tester.get_port())
# Run the gRPC server (see friendship.proto for more info)
- cls.grpc_server = fs.serve(cls.grpc_server_port)
+ cls.grpc_server = fs.serve(cls.grpc_server_port,
+ options=(
+ ('grpc.http2.max_ping_strikes',
+ 10),))
# Prepare router to communicate with the gRPC server
cls.connector_props = {
@@ -112,8 +115,10 @@ class GrpcServiceMethodsTest(TestCase):
])
cls.router_qdr = cls.tester.qdrouterd("grpc-test-router", config, wait=True)
- # If you wanna try it without the router, set the grpc_channel directly to the grpc_server_port
- cls.grpc_channel = grpc.insecure_channel('127.0.0.1:%s' % cls.router_http_port)
+ # If you wanna try it without the router, set the grpc_channel
+ # directly to the grpc_server_port
+ cls.grpc_channel = grpc.insecure_channel('127.0.0.1:%s' %
+ cls.router_http_port)
cls.grpc_stub = FriendshipStub(cls.grpc_channel)
@classmethod
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org