|
|
|
@ -513,7 +513,22 @@ class NodeLanguage: |
|
|
|
|
'node_protobuf_unary_ping_pong_1MB', rpc_type='UNARY', |
|
|
|
|
client_type='ASYNC_CLIENT', server_type='ASYNC_SERVER', |
|
|
|
|
req_size=1024*1024, resp_size=1024*1024, |
|
|
|
|
categories=[SCALABLE, SMOKETEST]) |
|
|
|
|
categories=[SCALABLE]) |
|
|
|
|
|
|
|
|
|
sizes = [('1B', 1), ('1KB', 1024), ('10KB', 10 * 1024), |
|
|
|
|
('1MB', 1024 * 1024), ('10MB', 10 * 1024 * 1024), |
|
|
|
|
('100MB', 100 * 1024 * 1024)] |
|
|
|
|
|
|
|
|
|
for size_name, size in sizes: |
|
|
|
|
for secure in (True, False): |
|
|
|
|
yield _ping_pong_scenario( |
|
|
|
|
'node_protobuf_unary_ping_pong_%s_resp_%s' % |
|
|
|
|
(size_name, 'secure' if secure else 'insecure'), |
|
|
|
|
rpc_type='UNARY', |
|
|
|
|
client_type='ASYNC_CLIENT', server_type='ASYNC_SERVER', |
|
|
|
|
req_size=0, resp_size=size, |
|
|
|
|
secure=secure, |
|
|
|
|
categories=[SCALABLE]) |
|
|
|
|
|
|
|
|
|
# TODO(murgatroid99): fix bugs with this scenario and re-enable it |
|
|
|
|
# yield _ping_pong_scenario( |
|
|
|
@ -528,11 +543,10 @@ class NodeLanguage: |
|
|
|
|
# client_type='ASYNC_CLIENT', server_type='ASYNC_SERVER', |
|
|
|
|
# unconstrained_client='async') |
|
|
|
|
|
|
|
|
|
# TODO(jtattermusch): make this scenario work |
|
|
|
|
#yield _ping_pong_scenario( |
|
|
|
|
# 'node_to_cpp_protobuf_async_unary_ping_pong', rpc_type='UNARY', |
|
|
|
|
# client_type='ASYNC_CLIENT', server_type='ASYNC_SERVER', |
|
|
|
|
# server_language='c++', async_server_threads=1) |
|
|
|
|
yield _ping_pong_scenario( |
|
|
|
|
'node_to_cpp_protobuf_async_unary_ping_pong', rpc_type='UNARY', |
|
|
|
|
client_type='ASYNC_CLIENT', server_type='ASYNC_SERVER', |
|
|
|
|
server_language='c++', async_server_threads=1) |
|
|
|
|
|
|
|
|
|
# TODO(jtattermusch): make this scenario work |
|
|
|
|
#yield _ping_pong_scenario( |
|
|
|
@ -829,6 +843,21 @@ class NodeExpressLanguage: |
|
|
|
|
unconstrained_client='async', |
|
|
|
|
categories=[SCALABLE, SMOKETEST]) |
|
|
|
|
|
|
|
|
|
sizes = [('1B', 1), ('1KB', 1024), ('10KB', 10 * 1024), |
|
|
|
|
('1MB', 1024 * 1024), ('10MB', 10 * 1024 * 1024), |
|
|
|
|
('100MB', 100 * 1024 * 1024)] |
|
|
|
|
|
|
|
|
|
for size_name, size in sizes: |
|
|
|
|
for secure in (True, False): |
|
|
|
|
yield _ping_pong_scenario( |
|
|
|
|
'node_express_json_unary_ping_pong_%s_resp_%s' % |
|
|
|
|
(size_name, 'secure' if secure else 'insecure'), |
|
|
|
|
rpc_type='UNARY', |
|
|
|
|
client_type='ASYNC_CLIENT', server_type='ASYNC_SERVER', |
|
|
|
|
req_size=0, resp_size=size, |
|
|
|
|
secure=secure, |
|
|
|
|
categories=[SCALABLE]) |
|
|
|
|
|
|
|
|
|
def __str__(self): |
|
|
|
|
return 'node_express' |
|
|
|
|
|
|
|
|
|