aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/python/grpcio_tests/tests/qps
diff options
context:
space:
mode:
authorGravatar Craig Tiller <ctiller@google.com>2016-08-09 16:05:12 -0700
committerGravatar Craig Tiller <ctiller@google.com>2016-08-09 16:05:12 -0700
commit8a3df2ecbe5acd62e203ffdecaea216630619b83 (patch)
tree4a19f9eec7de131bc9fd81b61925c9e185dc7bec /src/python/grpcio_tests/tests/qps
parentc919aff578cf59d4a1d610e1f7ed26db3aa601c3 (diff)
parent2f24f497c4e9578d9cc8a4a5606b3846c14e51d7 (diff)
Merge github.com:grpc/grpc into moovee
Diffstat (limited to 'src/python/grpcio_tests/tests/qps')
-rw-r--r--src/python/grpcio_tests/tests/qps/qps_worker.py2
-rw-r--r--src/python/grpcio_tests/tests/qps/worker_server.py2
2 files changed, 2 insertions, 2 deletions
diff --git a/src/python/grpcio_tests/tests/qps/qps_worker.py b/src/python/grpcio_tests/tests/qps/qps_worker.py
index 3abf0d08dd..2371ff0956 100644
--- a/src/python/grpcio_tests/tests/qps/qps_worker.py
+++ b/src/python/grpcio_tests/tests/qps/qps_worker.py
@@ -40,7 +40,7 @@ from tests.qps import worker_server
def run_worker_server(port):
- server = grpc.server((), futures.ThreadPoolExecutor(max_workers=5))
+ server = grpc.server(futures.ThreadPoolExecutor(max_workers=5))
servicer = worker_server.WorkerServer()
services_pb2.add_WorkerServiceServicer_to_server(servicer, server)
server.add_insecure_port('[::]:{}'.format(port))
diff --git a/src/python/grpcio_tests/tests/qps/worker_server.py b/src/python/grpcio_tests/tests/qps/worker_server.py
index 932a1ffe2b..46d542940f 100644
--- a/src/python/grpcio_tests/tests/qps/worker_server.py
+++ b/src/python/grpcio_tests/tests/qps/worker_server.py
@@ -82,7 +82,7 @@ class WorkerServer(services_pb2.WorkerServiceServicer):
server_threads = multiprocessing.cpu_count() * 5
else:
server_threads = config.async_server_threads
- server = grpc.server((), futures.ThreadPoolExecutor(
+ server = grpc.server(futures.ThreadPoolExecutor(
max_workers=server_threads))
if config.server_type == control_pb2.ASYNC_SERVER:
servicer = benchmark_server.BenchmarkServer()