|
|
|
@ -267,6 +267,13 @@ class CXXLanguage: |
|
|
|
|
categories=smoketest_categories+[SCALABLE], |
|
|
|
|
excluded_poll_engines = ['poll-cv']) |
|
|
|
|
|
|
|
|
|
yield _ping_pong_scenario( |
|
|
|
|
'cpp_protobuf_async_unary_ping_pong_%s_1mb' % secstr, rpc_type='UNARY', |
|
|
|
|
client_type='ASYNC_CLIENT', server_type='ASYNC_SERVER', |
|
|
|
|
req_size=1024*1024, resp_size=1024*1024, |
|
|
|
|
secure=secure, |
|
|
|
|
categories=smoketest_categories) |
|
|
|
|
|
|
|
|
|
for rpc_type in ['unary', 'streaming']: |
|
|
|
|
for synchronicity in ['sync', 'async']: |
|
|
|
|
yield _ping_pong_scenario( |
|
|
|
@ -399,6 +406,12 @@ class CSharpLanguage: |
|
|
|
|
unconstrained_client='async', 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]) |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def __str__(self): |
|
|
|
|
return 'csharp' |
|
|
|
@ -436,9 +449,15 @@ class NodeLanguage: |
|
|
|
|
|
|
|
|
|
yield _ping_pong_scenario( |
|
|
|
|
'cpp_to_node_unary_ping_pong', rpc_type='UNARY', |
|
|
|
|
client_type='ASYNC_CLIENT', server_type='async_server', |
|
|
|
|
client_type='ASYNC_CLIENT', server_type='ASYNC_SERVER', |
|
|
|
|
client_language='c++') |
|
|
|
|
|
|
|
|
|
yield _ping_pong_scenario( |
|
|
|
|
'node_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]) |
|
|
|
|
|
|
|
|
|
# TODO(murgatroid99): fix bugs with this scenario and re-enable it |
|
|
|
|
# yield _ping_pong_scenario( |
|
|
|
|
# 'node_protobuf_async_unary_qps_unconstrained', rpc_type='UNARY', |
|
|
|
@ -519,6 +538,12 @@ class PythonLanguage: |
|
|
|
|
client_type='SYNC_CLIENT', server_type='ASYNC_SERVER', |
|
|
|
|
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]) |
|
|
|
|
|
|
|
|
|
def __str__(self): |
|
|
|
|
return 'python' |
|
|
|
|
|
|
|
|
@ -565,6 +590,12 @@ class RubyLanguage: |
|
|
|
|
client_type='SYNC_CLIENT', server_type='SYNC_SERVER', |
|
|
|
|
server_language='c++', async_server_threads=1) |
|
|
|
|
|
|
|
|
|
yield _ping_pong_scenario( |
|
|
|
|
'ruby_protobuf_async_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]) |
|
|
|
|
|
|
|
|
|
def __str__(self): |
|
|
|
|
return 'ruby' |
|
|
|
|
|
|
|
|
|