|
|
@ -304,11 +304,11 @@ class CXXLanguage: |
|
|
|
excluded_poll_engines = ['poll-cv']) |
|
|
|
excluded_poll_engines = ['poll-cv']) |
|
|
|
|
|
|
|
|
|
|
|
yield _ping_pong_scenario( |
|
|
|
yield _ping_pong_scenario( |
|
|
|
'cpp_protobuf_async_unary_ping_pong_%s_1mb' % secstr, rpc_type='UNARY', |
|
|
|
'cpp_protobuf_async_unary_ping_pong_%s_1MB' % secstr, rpc_type='UNARY', |
|
|
|
client_type='ASYNC_CLIENT', server_type='ASYNC_SERVER', |
|
|
|
client_type='ASYNC_CLIENT', server_type='ASYNC_SERVER', |
|
|
|
req_size=1024*1024, resp_size=1024*1024, |
|
|
|
req_size=1024*1024, resp_size=1024*1024, |
|
|
|
secure=secure, |
|
|
|
secure=secure, |
|
|
|
categories=smoketest_categories) |
|
|
|
categories=smoketest_categories + [SCALABLE]) |
|
|
|
|
|
|
|
|
|
|
|
for rpc_type in ['unary', 'streaming']: |
|
|
|
for rpc_type in ['unary', 'streaming']: |
|
|
|
for synchronicity in ['sync', 'async']: |
|
|
|
for synchronicity in ['sync', 'async']: |
|
|
@ -464,10 +464,10 @@ class CSharpLanguage: |
|
|
|
categories=[SCALABLE]) |
|
|
|
categories=[SCALABLE]) |
|
|
|
|
|
|
|
|
|
|
|
yield _ping_pong_scenario( |
|
|
|
yield _ping_pong_scenario( |
|
|
|
'csharp_protobuf_async_unary_ping_pong_1mb', rpc_type='UNARY', |
|
|
|
'csharp_protobuf_async_unary_ping_pong_1MB', rpc_type='UNARY', |
|
|
|
client_type='ASYNC_CLIENT', server_type='ASYNC_SERVER', |
|
|
|
client_type='ASYNC_CLIENT', server_type='ASYNC_SERVER', |
|
|
|
req_size=1024*1024, resp_size=1024*1024, |
|
|
|
req_size=1024*1024, resp_size=1024*1024, |
|
|
|
categories=[SMOKETEST]) |
|
|
|
categories=[SMOKETEST, SCALABLE]) |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def __str__(self): |
|
|
|
def __str__(self): |
|
|
@ -510,10 +510,10 @@ class NodeLanguage: |
|
|
|
client_language='c++') |
|
|
|
client_language='c++') |
|
|
|
|
|
|
|
|
|
|
|
yield _ping_pong_scenario( |
|
|
|
yield _ping_pong_scenario( |
|
|
|
'node_protobuf_async_unary_ping_pong_1mb', rpc_type='UNARY', |
|
|
|
'node_protobuf_unary_ping_pong_1MB', rpc_type='UNARY', |
|
|
|
client_type='ASYNC_CLIENT', server_type='ASYNC_SERVER', |
|
|
|
client_type='ASYNC_CLIENT', server_type='ASYNC_SERVER', |
|
|
|
req_size=1024*1024, resp_size=1024*1024, |
|
|
|
req_size=1024*1024, resp_size=1024*1024, |
|
|
|
categories=[SMOKETEST]) |
|
|
|
categories=[SCALABLE, SMOKETEST]) |
|
|
|
|
|
|
|
|
|
|
|
# TODO(murgatroid99): fix bugs with this scenario and re-enable it |
|
|
|
# TODO(murgatroid99): fix bugs with this scenario and re-enable it |
|
|
|
# yield _ping_pong_scenario( |
|
|
|
# yield _ping_pong_scenario( |
|
|
@ -596,10 +596,10 @@ class PythonLanguage: |
|
|
|
server_language='c++', async_server_threads=1) |
|
|
|
server_language='c++', async_server_threads=1) |
|
|
|
|
|
|
|
|
|
|
|
yield _ping_pong_scenario( |
|
|
|
yield _ping_pong_scenario( |
|
|
|
'python_protobuf_sync_unary_ping_pong_1mb', rpc_type='UNARY', |
|
|
|
'python_protobuf_sync_unary_ping_pong_1MB', rpc_type='UNARY', |
|
|
|
client_type='SYNC_CLIENT', server_type='ASYNC_SERVER', |
|
|
|
client_type='SYNC_CLIENT', server_type='ASYNC_SERVER', |
|
|
|
req_size=1024*1024, resp_size=1024*1024, |
|
|
|
req_size=1024*1024, resp_size=1024*1024, |
|
|
|
categories=[SMOKETEST]) |
|
|
|
categories=[SMOKETEST, SCALABLE]) |
|
|
|
|
|
|
|
|
|
|
|
def __str__(self): |
|
|
|
def __str__(self): |
|
|
|
return 'python' |
|
|
|
return 'python' |
|
|
@ -648,10 +648,10 @@ class RubyLanguage: |
|
|
|
server_language='c++', async_server_threads=1) |
|
|
|
server_language='c++', async_server_threads=1) |
|
|
|
|
|
|
|
|
|
|
|
yield _ping_pong_scenario( |
|
|
|
yield _ping_pong_scenario( |
|
|
|
'ruby_protobuf_async_unary_ping_pong_1mb', rpc_type='UNARY', |
|
|
|
'ruby_protobuf_unary_ping_pong_1MB', rpc_type='UNARY', |
|
|
|
client_type='SYNC_CLIENT', server_type='SYNC_SERVER', |
|
|
|
client_type='SYNC_CLIENT', server_type='SYNC_SERVER', |
|
|
|
req_size=1024*1024, resp_size=1024*1024, |
|
|
|
req_size=1024*1024, resp_size=1024*1024, |
|
|
|
categories=[SMOKETEST]) |
|
|
|
categories=[SMOKETEST, SCALABLE]) |
|
|
|
|
|
|
|
|
|
|
|
def __str__(self): |
|
|
|
def __str__(self): |
|
|
|
return 'ruby' |
|
|
|
return 'ruby' |
|
|
|