Imported Upstream version 1.27.0

[platform/upstream/grpc.git] / tools / run_tests / performance / scenario_config.py

diff --git a/tools/run_tests/performance/scenario_config.py b/tools/run_tests/performance/scenario_config.py
index ac25b22..1d30a79 100644 (file)
--- a/tools/run_tests/performance/scenario_config.py
+++ b/tools/run_tests/performance/scenario_config.py
@@ -509,8 +509,8 @@ class CXXLanguage:
             ]:
                 for synchronicity in ['sync', 'async']:
                     yield _ping_pong_scenario(
-                        'cpp_protobuf_%s_%s_ping_pong_%s' % (synchronicity,
-                                                             rpc_type, secstr),
+                        'cpp_protobuf_%s_%s_ping_pong_%s' %
+                        (synchronicity, rpc_type, secstr),
                         rpc_type=rpc_type.upper(),
                         client_type='%s_CLIENT' % synchronicity.upper(),
                         server_type='%s_SERVER' % synchronicity.upper(),
@@ -623,13 +623,12 @@ class CSharpLanguage:
         return 100
 
     def scenarios(self):
-        yield _ping_pong_scenario(
-            'csharp_generic_async_streaming_ping_pong',
-            rpc_type='STREAMING',
-            client_type='ASYNC_CLIENT',
-            server_type='ASYNC_GENERIC_SERVER',
-            use_generic_payload=True,
-            categories=[SMOKETEST, SCALABLE])
+        yield _ping_pong_scenario('csharp_generic_async_streaming_ping_pong',
+                                  rpc_type='STREAMING',
+                                  client_type='ASYNC_CLIENT',
+                                  server_type='ASYNC_GENERIC_SERVER',
+                                  use_generic_payload=True,
+                                  categories=[SMOKETEST, SCALABLE])
 
         yield _ping_pong_scenario(
             'csharp_generic_async_streaming_ping_pong_insecure_1MB',
@@ -652,18 +651,16 @@ class CSharpLanguage:
             secure=False,
             categories=[SMOKETEST, SCALABLE])
 
-        yield _ping_pong_scenario(
-            'csharp_protobuf_async_streaming_ping_pong',
-            rpc_type='STREAMING',
-            client_type='ASYNC_CLIENT',
-            server_type='ASYNC_SERVER')
+        yield _ping_pong_scenario('csharp_protobuf_async_streaming_ping_pong',
+                                  rpc_type='STREAMING',
+                                  client_type='ASYNC_CLIENT',
+                                  server_type='ASYNC_SERVER')
 
-        yield _ping_pong_scenario(
-            'csharp_protobuf_async_unary_ping_pong',
-            rpc_type='UNARY',
-            client_type='ASYNC_CLIENT',
-            server_type='ASYNC_SERVER',
-            categories=[SMOKETEST, SCALABLE])
+        yield _ping_pong_scenario('csharp_protobuf_async_unary_ping_pong',
+                                  rpc_type='UNARY',
+                                  client_type='ASYNC_CLIENT',
+                                  server_type='ASYNC_SERVER',
+                                  categories=[SMOKETEST, SCALABLE])
 
         yield _ping_pong_scenario(
             'csharp_protobuf_sync_to_async_unary_ping_pong',
@@ -687,14 +684,13 @@ class CSharpLanguage:
             unconstrained_client='async',
             categories=[SCALABLE])
 
-        yield _ping_pong_scenario(
-            'csharp_to_cpp_protobuf_sync_unary_ping_pong',
-            rpc_type='UNARY',
-            client_type='SYNC_CLIENT',
-            server_type='SYNC_SERVER',
-            server_language='c++',
-            async_server_threads=1,
-            categories=[SMOKETEST, SCALABLE])
+        yield _ping_pong_scenario('csharp_to_cpp_protobuf_sync_unary_ping_pong',
+                                  rpc_type='UNARY',
+                                  client_type='SYNC_CLIENT',
+                                  server_type='SYNC_SERVER',
+                                  server_language='c++',
+                                  async_server_threads=1,
+                                  categories=[SMOKETEST, SCALABLE])
 
         yield _ping_pong_scenario(
             'csharp_to_cpp_protobuf_async_streaming_ping_pong',
@@ -731,14 +727,13 @@ class CSharpLanguage:
             client_language='c++',
             categories=[SCALABLE])
 
-        yield _ping_pong_scenario(
-            'csharp_protobuf_async_unary_ping_pong_1MB',
-            rpc_type='UNARY',
-            client_type='ASYNC_CLIENT',
-            server_type='ASYNC_SERVER',
-            req_size=1024 * 1024,
-            resp_size=1024 * 1024,
-            categories=[SMOKETEST, SCALABLE])
+        yield _ping_pong_scenario('csharp_protobuf_async_unary_ping_pong_1MB',
+                                  rpc_type='UNARY',
+                                  client_type='ASYNC_CLIENT',
+                                  server_type='ASYNC_SERVER',
+                                  req_size=1024 * 1024,
+                                  resp_size=1024 * 1024,
+                                  categories=[SMOKETEST, SCALABLE])
 
     def __str__(self):
         return 'csharp'
@@ -756,32 +751,28 @@ class PythonLanguage:
         return 500
 
     def scenarios(self):
-        yield _ping_pong_scenario(
-            'python_generic_sync_streaming_ping_pong',
-            rpc_type='STREAMING',
-            client_type='SYNC_CLIENT',
-            server_type='ASYNC_GENERIC_SERVER',
-            use_generic_payload=True,
-            categories=[SMOKETEST, SCALABLE])
-
-        yield _ping_pong_scenario(
-            'python_protobuf_sync_streaming_ping_pong',
-            rpc_type='STREAMING',
-            client_type='SYNC_CLIENT',
-            server_type='ASYNC_SERVER')
-
-        yield _ping_pong_scenario(
-            'python_protobuf_async_unary_ping_pong',
-            rpc_type='UNARY',
-            client_type='ASYNC_CLIENT',
-            server_type='ASYNC_SERVER')
-
-        yield _ping_pong_scenario(
-            'python_protobuf_sync_unary_ping_pong',
-            rpc_type='UNARY',
-            client_type='SYNC_CLIENT',
-            server_type='ASYNC_SERVER',
-            categories=[SMOKETEST, SCALABLE])
+        yield _ping_pong_scenario('python_generic_sync_streaming_ping_pong',
+                                  rpc_type='STREAMING',
+                                  client_type='SYNC_CLIENT',
+                                  server_type='ASYNC_GENERIC_SERVER',
+                                  use_generic_payload=True,
+                                  categories=[SMOKETEST, SCALABLE])
+
+        yield _ping_pong_scenario('python_protobuf_sync_streaming_ping_pong',
+                                  rpc_type='STREAMING',
+                                  client_type='SYNC_CLIENT',
+                                  server_type='ASYNC_SERVER')
+
+        yield _ping_pong_scenario('python_protobuf_async_unary_ping_pong',
+                                  rpc_type='UNARY',
+                                  client_type='ASYNC_CLIENT',
+                                  server_type='ASYNC_SERVER')
+
+        yield _ping_pong_scenario('python_protobuf_sync_unary_ping_pong',
+                                  rpc_type='UNARY',
+                                  client_type='SYNC_CLIENT',
+                                  server_type='ASYNC_SERVER',
+                                  categories=[SMOKETEST, SCALABLE])
 
         yield _ping_pong_scenario(
             'python_protobuf_sync_unary_qps_unconstrained',
@@ -797,14 +788,13 @@ class PythonLanguage:
             server_type='ASYNC_SERVER',
             unconstrained_client='sync')
 
-        yield _ping_pong_scenario(
-            'python_to_cpp_protobuf_sync_unary_ping_pong',
-            rpc_type='UNARY',
-            client_type='SYNC_CLIENT',
-            server_type='ASYNC_SERVER',
-            server_language='c++',
-            async_server_threads=1,
-            categories=[SMOKETEST, SCALABLE])
+        yield _ping_pong_scenario('python_to_cpp_protobuf_sync_unary_ping_pong',
+                                  rpc_type='UNARY',
+                                  client_type='SYNC_CLIENT',
+                                  server_type='ASYNC_SERVER',
+                                  server_language='c++',
+                                  async_server_threads=1,
+                                  categories=[SMOKETEST, SCALABLE])
 
         yield _ping_pong_scenario(
             'python_to_cpp_protobuf_sync_streaming_ping_pong',
@@ -814,14 +804,13 @@ class PythonLanguage:
             server_language='c++',
             async_server_threads=1)
 
-        yield _ping_pong_scenario(
-            'python_protobuf_sync_unary_ping_pong_1MB',
-            rpc_type='UNARY',
-            client_type='SYNC_CLIENT',
-            server_type='ASYNC_SERVER',
-            req_size=1024 * 1024,
-            resp_size=1024 * 1024,
-            categories=[SMOKETEST, SCALABLE])
+        yield _ping_pong_scenario('python_protobuf_sync_unary_ping_pong_1MB',
+                                  rpc_type='UNARY',
+                                  client_type='SYNC_CLIENT',
+                                  server_type='ASYNC_SERVER',
+                                  req_size=1024 * 1024,
+                                  resp_size=1024 * 1024,
+                                  categories=[SMOKETEST, SCALABLE])
 
     def __str__(self):
         return 'python'
@@ -840,26 +829,23 @@ class RubyLanguage:
         return 300
 
     def scenarios(self):
-        yield _ping_pong_scenario(
-            'ruby_protobuf_sync_streaming_ping_pong',
-            rpc_type='STREAMING',
-            client_type='SYNC_CLIENT',
-            server_type='SYNC_SERVER',
-            categories=[SMOKETEST, SCALABLE])
-
-        yield _ping_pong_scenario(
-            'ruby_protobuf_unary_ping_pong',
-            rpc_type='UNARY',
-            client_type='SYNC_CLIENT',
-            server_type='SYNC_SERVER',
-            categories=[SMOKETEST, SCALABLE])
-
-        yield _ping_pong_scenario(
-            'ruby_protobuf_sync_unary_qps_unconstrained',
-            rpc_type='UNARY',
-            client_type='SYNC_CLIENT',
-            server_type='SYNC_SERVER',
-            unconstrained_client='sync')
+        yield _ping_pong_scenario('ruby_protobuf_sync_streaming_ping_pong',
+                                  rpc_type='STREAMING',
+                                  client_type='SYNC_CLIENT',
+                                  server_type='SYNC_SERVER',
+                                  categories=[SMOKETEST, SCALABLE])
+
+        yield _ping_pong_scenario('ruby_protobuf_unary_ping_pong',
+                                  rpc_type='UNARY',
+                                  client_type='SYNC_CLIENT',
+                                  server_type='SYNC_SERVER',
+                                  categories=[SMOKETEST, SCALABLE])
+
+        yield _ping_pong_scenario('ruby_protobuf_sync_unary_qps_unconstrained',
+                                  rpc_type='UNARY',
+                                  client_type='SYNC_CLIENT',
+                                  server_type='SYNC_SERVER',
+                                  unconstrained_client='sync')
 
         yield _ping_pong_scenario(
             'ruby_protobuf_sync_streaming_qps_unconstrained',
@@ -868,13 +854,12 @@ class RubyLanguage:
             server_type='SYNC_SERVER',
             unconstrained_client='sync')
 
-        yield _ping_pong_scenario(
-            'ruby_to_cpp_protobuf_sync_unary_ping_pong',
-            rpc_type='UNARY',
-            client_type='SYNC_CLIENT',
-            server_type='SYNC_SERVER',
-            server_language='c++',
-            async_server_threads=1)
+        yield _ping_pong_scenario('ruby_to_cpp_protobuf_sync_unary_ping_pong',
+                                  rpc_type='UNARY',
+                                  client_type='SYNC_CLIENT',
+                                  server_type='SYNC_SERVER',
+                                  server_language='c++',
+                                  async_server_threads=1)
 
         yield _ping_pong_scenario(
             'ruby_to_cpp_protobuf_sync_streaming_ping_pong',
@@ -884,14 +869,13 @@ class RubyLanguage:
             server_language='c++',
             async_server_threads=1)
 
-        yield _ping_pong_scenario(
-            'ruby_protobuf_unary_ping_pong_1MB',
-            rpc_type='UNARY',
-            client_type='SYNC_CLIENT',
-            server_type='SYNC_SERVER',
-            req_size=1024 * 1024,
-            resp_size=1024 * 1024,
-            categories=[SMOKETEST, SCALABLE])
+        yield _ping_pong_scenario('ruby_protobuf_unary_ping_pong_1MB',
+                                  rpc_type='UNARY',
+                                  client_type='SYNC_CLIENT',
+                                  server_type='SYNC_SERVER',
+                                  req_size=1024 * 1024,
+                                  resp_size=1024 * 1024,
+                                  categories=[SMOKETEST, SCALABLE])
 
     def __str__(self):
         return 'ruby'
@@ -922,13 +906,13 @@ class Php7Language:
         if self.php7_protobuf_c:
             php7_extension_mode = 'php7_protobuf_c_extension'
 
-        yield _ping_pong_scenario(
-            '%s_to_cpp_protobuf_sync_unary_ping_pong' % php7_extension_mode,
-            rpc_type='UNARY',
-            client_type='SYNC_CLIENT',
-            server_type='SYNC_SERVER',
-            server_language='c++',
-            async_server_threads=1)
+        yield _ping_pong_scenario('%s_to_cpp_protobuf_sync_unary_ping_pong' %
+                                  php7_extension_mode,
+                                  rpc_type='UNARY',
+                                  client_type='SYNC_CLIENT',
+                                  server_type='SYNC_SERVER',
+                                  server_language='c++',
+                                  async_server_threads=1)
 
         yield _ping_pong_scenario(
             '%s_to_cpp_protobuf_sync_streaming_ping_pong' % php7_extension_mode,
@@ -1005,24 +989,24 @@ class JavaLanguage:
                 secure=secure,
                 warmup_seconds=JAVA_WARMUP_SECONDS)
 
-            yield _ping_pong_scenario(
-                'java_protobuf_async_unary_ping_pong_%s' % secstr,
-                rpc_type='UNARY',
-                client_type='ASYNC_CLIENT',
-                server_type='ASYNC_SERVER',
-                async_server_threads=1,
-                secure=secure,
-                warmup_seconds=JAVA_WARMUP_SECONDS,
-                categories=smoketest_categories)
-
-            yield _ping_pong_scenario(
-                'java_protobuf_unary_ping_pong_%s' % secstr,
-                rpc_type='UNARY',
-                client_type='SYNC_CLIENT',
-                server_type='SYNC_SERVER',
-                async_server_threads=1,
-                secure=secure,
-                warmup_seconds=JAVA_WARMUP_SECONDS)
+            yield _ping_pong_scenario('java_protobuf_async_unary_ping_pong_%s' %
+                                      secstr,
+                                      rpc_type='UNARY',
+                                      client_type='ASYNC_CLIENT',
+                                      server_type='ASYNC_SERVER',
+                                      async_server_threads=1,
+                                      secure=secure,
+                                      warmup_seconds=JAVA_WARMUP_SECONDS,
+                                      categories=smoketest_categories)
+
+            yield _ping_pong_scenario('java_protobuf_unary_ping_pong_%s' %
+                                      secstr,
+                                      rpc_type='UNARY',
+                                      client_type='SYNC_CLIENT',
+                                      server_type='SYNC_SERVER',
+                                      async_server_threads=1,
+                                      secure=secure,
+                                      warmup_seconds=JAVA_WARMUP_SECONDS)
 
             yield _ping_pong_scenario(
                 'java_protobuf_async_unary_qps_unconstrained_%s' % secstr,
@@ -1091,15 +1075,15 @@ class GoLanguage:
 
             # ASYNC_GENERIC_SERVER for Go actually uses a sync streaming server,
             # but that's mostly because of lack of better name of the enum value.
-            yield _ping_pong_scenario(
-                'go_generic_sync_streaming_ping_pong_%s' % secstr,
-                rpc_type='STREAMING',
-                client_type='SYNC_CLIENT',
-                server_type='ASYNC_GENERIC_SERVER',
-                use_generic_payload=True,
-                async_server_threads=1,
-                secure=secure,
-                categories=smoketest_categories)
+            yield _ping_pong_scenario('go_generic_sync_streaming_ping_pong_%s' %
+                                      secstr,
+                                      rpc_type='STREAMING',
+                                      client_type='SYNC_CLIENT',
+                                      server_type='ASYNC_GENERIC_SERVER',
+                                      use_generic_payload=True,
+                                      async_server_threads=1,
+                                      secure=secure,
+                                      categories=smoketest_categories)
 
             yield _ping_pong_scenario(
                 'go_protobuf_sync_streaming_ping_pong_%s' % secstr,
@@ -1109,14 +1093,14 @@ class GoLanguage:
                 async_server_threads=1,
                 secure=secure)
 
-            yield _ping_pong_scenario(
-                'go_protobuf_sync_unary_ping_pong_%s' % secstr,
-                rpc_type='UNARY',
-                client_type='SYNC_CLIENT',
-                server_type='SYNC_SERVER',
-                async_server_threads=1,
-                secure=secure,
-                categories=smoketest_categories)
+            yield _ping_pong_scenario('go_protobuf_sync_unary_ping_pong_%s' %
+                                      secstr,
+                                      rpc_type='UNARY',
+                                      client_type='SYNC_CLIENT',
+                                      server_type='SYNC_SERVER',
+                                      async_server_threads=1,
+                                      secure=secure,
+                                      categories=smoketest_categories)
 
             # unconstrained_client='async' is intended (client uses goroutines)
             yield _ping_pong_scenario(