Skip to content
Snippets Groups Projects
Commit a09219c3 authored by kpayson64's avatar kpayson64 Committed by GitHub
Browse files

Merge pull request #7323 from kpayson64/fix_py_qps

Updated python qps tests to use GA server API
parents b6f760f4 b5b6f93e
No related branches found
No related tags found
No related merge requests found
...@@ -40,7 +40,7 @@ from tests.qps import worker_server ...@@ -40,7 +40,7 @@ from tests.qps import worker_server
def run_worker_server(port): 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() servicer = worker_server.WorkerServer()
services_pb2.add_WorkerServiceServicer_to_server(servicer, server) services_pb2.add_WorkerServiceServicer_to_server(servicer, server)
server.add_insecure_port('[::]:{}'.format(port)) server.add_insecure_port('[::]:{}'.format(port))
......
...@@ -82,7 +82,7 @@ class WorkerServer(services_pb2.WorkerServiceServicer): ...@@ -82,7 +82,7 @@ class WorkerServer(services_pb2.WorkerServiceServicer):
server_threads = multiprocessing.cpu_count() * 5 server_threads = multiprocessing.cpu_count() * 5
else: else:
server_threads = config.async_server_threads server_threads = config.async_server_threads
server = grpc.server((), futures.ThreadPoolExecutor( server = grpc.server(futures.ThreadPoolExecutor(
max_workers=server_threads)) max_workers=server_threads))
if config.server_type == control_pb2.ASYNC_SERVER: if config.server_type == control_pb2.ASYNC_SERVER:
servicer = benchmark_server.BenchmarkServer() servicer = benchmark_server.BenchmarkServer()
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment