refactor(proto): request_id is now an integer

gnes/client/benchmark.py

@@ -26,7 +26,7 @@ def __init__(self, args):
         all_bytes = [b'a' * args.request_length] * args.num_requests
 
         with grpc.insecure_channel(
-                '%s:%s' % (args.grpc_host, args.grpc_port),
+                '%s:%d' % (args.grpc_host, args.grpc_port),
                 options=[('grpc.max_send_message_length', args.max_message_size * 1024 * 1024),
                          ('grpc.max_receive_message_length', args.max_message_size * 1024 * 1024)]) as channel:
             stub = gnes_pb2_grpc.GnesRPCStub(channel)

gnes/client/cli.py

@@ -40,7 +40,7 @@ def __init__(self, args):
             raise AttributeError('--txt_file, --image_zip_file, --video_zip_file one must be given')
 
         with grpc.insecure_channel(
-                '%s:%s' % (args.grpc_host, args.grpc_port),
+                '%s:%d' % (args.grpc_host, args.grpc_port),
                 options=[('grpc.max_send_message_length', args.max_message_size * 1024 * 1024),
                          ('grpc.max_receive_message_length', args.max_message_size * 1024 * 1024)]) as channel:
             stub = gnes_pb2_grpc.GnesRPCStub(channel)

tests/test_dummy_transformer.py

@@ -44,7 +44,7 @@ def test_pymode(self):
         with ServiceManager(EncoderService, e_args), \
              ServiceManager(PreprocessorService, p_args), \
              ServiceManager(FrontendService, args), \
-             grpc.insecure_channel('%s:%s' % (args.grpc_host, args.grpc_port),
+             grpc.insecure_channel('%s:%d' % (args.grpc_host, args.grpc_port),
                                    options=[('grpc.max_send_message_length', 70 * 1024 * 1024),
                                             ('grpc.max_receive_message_length', 70 * 1024 * 1024)]) as channel:
             stub = gnes_pb2_grpc.GnesRPCStub(channel)

tests/test_service_mgr.py

@@ -44,7 +44,7 @@ def _test_grpc_multiple_router(self, backend='thread', num_parallel=5):
         ])
 
         with ServiceManager(RouterService, p_args), FrontendService(args), grpc.insecure_channel(
-                '%s:%s' % (args.grpc_host, args.grpc_port),
+                '%s:%d' % (args.grpc_host, args.grpc_port),
                 options=[('grpc.max_send_message_length', 70 * 1024 * 1024),
                          ('grpc.max_receive_message_length', 70 * 1024 * 1024)]) as channel:
             stub = gnes_pb2_grpc.GnesRPCStub(channel)
@@ -68,7 +68,7 @@ def _test_grpc_multiple_pub(self, backend='thread', num_parallel=5):
         ])
 
         with ServiceManager(RouterService, p_args), FrontendService(args), grpc.insecure_channel(
-                '%s:%s' % (args.grpc_host, args.grpc_port),
+                '%s:%d' % (args.grpc_host, args.grpc_port),
                 options=[('grpc.max_send_message_length', 70 * 1024 * 1024),
                          ('grpc.max_receive_message_length', 70 * 1024 * 1024)]) as channel:
             stub = gnes_pb2_grpc.GnesRPCStub(channel)

tests/test_stream_grpc.py

@@ -75,7 +75,7 @@ def test_grpc_frontend(self):
         ])
 
         with RouterService(p_args), FrontendService(args), grpc.insecure_channel(
-                '%s:%s' % (args.grpc_host, args.grpc_port),
+                '%s:%d' % (args.grpc_host, args.grpc_port),
                 options=[('grpc.max_send_message_length', 70 * 1024 * 1024),
                          ('grpc.max_receive_message_length', 70 * 1024 * 1024)]) as channel:
             stub = gnes_pb2_grpc.GnesRPCStub(channel)
@@ -106,7 +106,7 @@ def test_async_block(self):
         ])
 
         with FrontendService(args), Router1(p1_args), Router2(p2_args), grpc.insecure_channel(
-                '%s:%s' % (args.grpc_host, args.grpc_port),
+                '%s:%d' % (args.grpc_host, args.grpc_port),
                 options=[('grpc.max_send_message_length', 70 * 1024 * 1024),
                          ('grpc.max_receive_message_length', 70 * 1024 * 1024)]) as channel:
             stub = gnes_pb2_grpc.GnesRPCStub(channel)