Skip to content
Snippets Groups Projects
Commit 4fec48b8 authored by Jan Tattermusch's avatar Jan Tattermusch
Browse files

tiny fixes to scenario_config

parent c578e44a
No related branches found
No related tags found
No related merge requests found
...@@ -33,6 +33,11 @@ SINGLE_MACHINE_CORES=8 ...@@ -33,6 +33,11 @@ SINGLE_MACHINE_CORES=8
WARMUP_SECONDS=5 WARMUP_SECONDS=5
BENCHMARK_SECONDS=30 BENCHMARK_SECONDS=30
HISTOGRAM_PARAMS = {
'resolution': 0.01,
'max_possible': 60e9,
}
EMPTY_GENERIC_PAYLOAD = { EMPTY_GENERIC_PAYLOAD = {
'bytebuf_params': { 'bytebuf_params': {
'req_size': 0, 'req_size': 0,
...@@ -83,7 +88,7 @@ class CXXLanguage: ...@@ -83,7 +88,7 @@ class CXXLanguage:
secargs = None secargs = None
yield { yield {
'name': 'generic_async_streaming_ping_pong_%s' 'name': 'cpp_generic_async_streaming_ping_pong_%s'
% secstr, % secstr,
'num_servers': 1, 'num_servers': 1,
'num_clients': 1, 'num_clients': 1,
...@@ -98,6 +103,7 @@ class CXXLanguage: ...@@ -98,6 +103,7 @@ class CXXLanguage:
'closed_loop': {} 'closed_loop': {}
}, },
'payload_config': EMPTY_GENERIC_PAYLOAD, 'payload_config': EMPTY_GENERIC_PAYLOAD,
'histogram_params': HISTOGRAM_PARAMS,
}, },
'server_config': { 'server_config': {
'server_type': 'ASYNC_GENERIC_SERVER', 'server_type': 'ASYNC_GENERIC_SERVER',
...@@ -110,7 +116,7 @@ class CXXLanguage: ...@@ -110,7 +116,7 @@ class CXXLanguage:
'benchmark_seconds': BENCHMARK_SECONDS 'benchmark_seconds': BENCHMARK_SECONDS
} }
yield { yield {
'name': 'generic_async_streaming_qps_unconstrained_%s' 'name': 'cpp_generic_async_streaming_qps_unconstrained_%s'
% secstr, % secstr,
'num_servers': 1, 'num_servers': 1,
'num_clients': 0, 'num_clients': 0,
...@@ -125,6 +131,7 @@ class CXXLanguage: ...@@ -125,6 +131,7 @@ class CXXLanguage:
'closed_loop': {} 'closed_loop': {}
}, },
'payload_config': EMPTY_GENERIC_PAYLOAD, 'payload_config': EMPTY_GENERIC_PAYLOAD,
'histogram_params': HISTOGRAM_PARAMS,
}, },
'server_config': { 'server_config': {
'server_type': 'ASYNC_GENERIC_SERVER', 'server_type': 'ASYNC_GENERIC_SERVER',
...@@ -137,7 +144,7 @@ class CXXLanguage: ...@@ -137,7 +144,7 @@ class CXXLanguage:
'benchmark_seconds': BENCHMARK_SECONDS 'benchmark_seconds': BENCHMARK_SECONDS
} }
yield { yield {
'name': 'generic_async_streaming_qps_one_server_core_%s' 'name': 'cpp_generic_async_streaming_qps_one_server_core_%s'
% secstr, % secstr,
'num_servers': 1, 'num_servers': 1,
'num_clients': 0, 'num_clients': 0,
...@@ -152,6 +159,7 @@ class CXXLanguage: ...@@ -152,6 +159,7 @@ class CXXLanguage:
'closed_loop': {} 'closed_loop': {}
}, },
'payload_config': EMPTY_GENERIC_PAYLOAD, 'payload_config': EMPTY_GENERIC_PAYLOAD,
'histogram_params': HISTOGRAM_PARAMS,
}, },
'server_config': { 'server_config': {
'server_type': 'ASYNC_GENERIC_SERVER', 'server_type': 'ASYNC_GENERIC_SERVER',
...@@ -164,7 +172,7 @@ class CXXLanguage: ...@@ -164,7 +172,7 @@ class CXXLanguage:
'benchmark_seconds': BENCHMARK_SECONDS 'benchmark_seconds': BENCHMARK_SECONDS
} }
yield { yield {
'name': 'protobuf_async_qps_unconstrained_%s' 'name': 'cpp_generic_async_qps_unconstrained_%s'
% secstr, % secstr,
'num_servers': 1, 'num_servers': 1,
'num_clients': 0, 'num_clients': 0,
...@@ -179,6 +187,7 @@ class CXXLanguage: ...@@ -179,6 +187,7 @@ class CXXLanguage:
'closed_loop': {} 'closed_loop': {}
}, },
'payload_config': EMPTY_GENERIC_PAYLOAD, 'payload_config': EMPTY_GENERIC_PAYLOAD,
'histogram_params': HISTOGRAM_PARAMS,
}, },
'server_config': { 'server_config': {
'server_type': 'ASYNC_GENERIC_SERVER', 'server_type': 'ASYNC_GENERIC_SERVER',
...@@ -191,7 +200,7 @@ class CXXLanguage: ...@@ -191,7 +200,7 @@ class CXXLanguage:
'benchmark_seconds': BENCHMARK_SECONDS 'benchmark_seconds': BENCHMARK_SECONDS
} }
yield { yield {
'name': 'single_channel_throughput_%s' 'name': 'cpp_single_channel_throughput_%s'
% secstr, % secstr,
'num_servers': 1, 'num_servers': 1,
'num_clients': 1, 'num_clients': 1,
...@@ -206,6 +215,7 @@ class CXXLanguage: ...@@ -206,6 +215,7 @@ class CXXLanguage:
'closed_loop': {} 'closed_loop': {}
}, },
'payload_config': BIG_GENERIC_PAYLOAD, 'payload_config': BIG_GENERIC_PAYLOAD,
'histogram_params': HISTOGRAM_PARAMS,
}, },
'server_config': { 'server_config': {
'server_type': 'ASYNC_GENERIC_SERVER', 'server_type': 'ASYNC_GENERIC_SERVER',
...@@ -218,7 +228,7 @@ class CXXLanguage: ...@@ -218,7 +228,7 @@ class CXXLanguage:
'benchmark_seconds': BENCHMARK_SECONDS 'benchmark_seconds': BENCHMARK_SECONDS
} }
yield { yield {
'name': 'protobuf_async_ping_pong_%s' 'name': 'cpp_protobuf_async_ping_pong_%s'
% secstr, % secstr,
'num_servers': 1, 'num_servers': 1,
'num_clients': 1, 'num_clients': 1,
...@@ -233,13 +243,13 @@ class CXXLanguage: ...@@ -233,13 +243,13 @@ class CXXLanguage:
'closed_loop': {} 'closed_loop': {}
}, },
'payload_config': EMPTY_PROTO_PAYLOAD, 'payload_config': EMPTY_PROTO_PAYLOAD,
'histogram_params': HISTOGRAM_PARAMS,
}, },
'server_config': { 'server_config': {
'server_type': 'ASYNC_GENERIC_SERVER', 'server_type': 'ASYNC_SERVER',
'security_params': secargs, 'security_params': secargs,
'core_limit': SINGLE_MACHINE_CORES/2, 'core_limit': SINGLE_MACHINE_CORES/2,
'async_server_threads': 1, 'async_server_threads': 1,
'payload_config': EMPTY_PROTO_PAYLOAD,
}, },
'warmup_seconds': WARMUP_SECONDS, 'warmup_seconds': WARMUP_SECONDS,
'benchmark_seconds': BENCHMARK_SECONDS 'benchmark_seconds': BENCHMARK_SECONDS
...@@ -262,8 +272,9 @@ class CSharpLanguage: ...@@ -262,8 +272,9 @@ class CSharpLanguage:
def scenarios(self): def scenarios(self):
# TODO(jtattermusch): add more scenarios # TODO(jtattermusch): add more scenarios
secargs = None
yield { yield {
'name': 'csharp_async_generic_streaming_ping_pong', 'name': 'csharp_generic_async_streaming_ping_pong',
'num_servers': 1, 'num_servers': 1,
'num_clients': 1, 'num_clients': 1,
'client_config': { 'client_config': {
...@@ -277,11 +288,12 @@ class CSharpLanguage: ...@@ -277,11 +288,12 @@ class CSharpLanguage:
'closed_loop': {} 'closed_loop': {}
}, },
'payload_config': EMPTY_GENERIC_PAYLOAD, 'payload_config': EMPTY_GENERIC_PAYLOAD,
'histogram_params': HISTOGRAM_PARAMS,
}, },
'server_config': { 'server_config': {
'server_type': 'ASYNC_GENERIC_SERVER', 'server_type': 'ASYNC_GENERIC_SERVER',
'security_params': secargs, 'security_params': secargs,
'core_limit': SINGLE_MACHINE_CORES/2, 'core_limit': 0,
'async_server_threads': 1, 'async_server_threads': 1,
'payload_config': EMPTY_GENERIC_PAYLOAD, 'payload_config': EMPTY_GENERIC_PAYLOAD,
}, },
...@@ -307,8 +319,9 @@ class NodeLanguage: ...@@ -307,8 +319,9 @@ class NodeLanguage:
def scenarios(self): def scenarios(self):
# TODO(jtattermusch): add more scenarios # TODO(jtattermusch): add more scenarios
secargs = None
yield { yield {
'name': 'node_sync_unary_ping_pong_protobuf', 'name': 'node_protobuf_unary_ping_pong',
'num_servers': 1, 'num_servers': 1,
'num_clients': 1, 'num_clients': 1,
'client_config': { 'client_config': {
...@@ -317,18 +330,18 @@ class NodeLanguage: ...@@ -317,18 +330,18 @@ class NodeLanguage:
'outstanding_rpcs_per_channel': 1, 'outstanding_rpcs_per_channel': 1,
'client_channels': 1, 'client_channels': 1,
'async_client_threads': 1, 'async_client_threads': 1,
'rpc_type': 'STREAMING', 'rpc_type': 'UNARY',
'load_params': { 'load_params': {
'closed_loop': {} 'closed_loop': {}
}, },
'payload_config': EMPTY_PROTO_PAYLOAD, 'payload_config': EMPTY_PROTO_PAYLOAD,
'histogram_params': HISTOGRAM_PARAMS,
}, },
'server_config': { 'server_config': {
'server_type': 'ASYNC_GENERIC_SERVER', 'server_type': 'ASYNC_SERVER',
'security_params': secargs, 'security_params': secargs,
'core_limit': SINGLE_MACHINE_CORES/2, 'core_limit': 0,
'async_server_threads': 1, 'async_server_threads': 1,
'payload_config': EMPTY_PROTO_PAYLOAD,
}, },
'warmup_seconds': WARMUP_SECONDS, 'warmup_seconds': WARMUP_SECONDS,
'benchmark_seconds': BENCHMARK_SECONDS 'benchmark_seconds': BENCHMARK_SECONDS
......
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