| /external/rust/crates/grpcio-sys/grpc/tools/run_tests/performance/ |
| D | scenario_config.py | 111 rpc_type, argument
149 'rpc_type': rpc_type,
247 rpc_type='UNARY',
261 rpc_type='STREAMING_FROM_CLIENT',
275 rpc_type='UNARY',
296 rpc_type='STREAMING',
307 rpc_type='STREAMING',
321 rpc_type='STREAMING',
336 rpc_type='STREAMING',
348 rpc_type='STREAMING',
[all …]
|
| /external/grpc-grpc/tools/run_tests/performance/ |
| D | scenario_config.py | 111 rpc_type, argument
146 'rpc_type': rpc_type,
243 rpc_type='UNARY',
257 rpc_type='STREAMING_FROM_CLIENT',
271 rpc_type='UNARY',
292 rpc_type='STREAMING',
302 rpc_type='STREAMING',
315 rpc_type='STREAMING',
329 rpc_type='STREAMING',
341 rpc_type='STREAMING',
[all …]
|
| /external/grpc-grpc/test/cpp/qps/ |
| D | json_run_localhost_scenarios.bzl | 3 …rpc_type": "UNARY", "load_params": {"poisson": {"offered_load": 37500}}, "histogram_params": {"res…
|
| D | qps_json_driver_scenarios.bzl | 3 …rpc_type": "STREAMING", "load_params": {"closed_loop": {}}, "histogram_params": {"resolution": 0.0…
|
| D | qps_worker.cc | 53 RpcType_Name(config.rpc_type()).c_str(), in CreateClient()
|
| D | client_sync.cc | 406 switch (config.rpc_type()) { in CreateSynchronousClient()
|
| D | client_async.cc | 932 switch (config.rpc_type()) { in CreateAsyncClient()
|
| /external/grpc-grpc/src/php/tests/qps/generated_code/Grpc/Testing/ |
| D | ClientConfig.php | 53 private $rpc_type = 0; variable in Grpc\\Testing\\ClientConfig
270 return $this->rpc_type;
281 $this->rpc_type = $var;
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/qps/ |
| D | worker_server.py | 147 if config.rpc_type == control_pb2.UNARY:
150 elif config.rpc_type == control_pb2.STREAMING:
154 if config.rpc_type == control_pb2.UNARY:
|
| /external/rust/crates/grpcio-sys/grpc/tools/run_tests/ |
| D | run_xds_tests.py | 350 for rpc_type, md_key, md_value in metadata:
352 md.type = rpc_type
410 def wait_until_rpcs_in_flight(rpc_type, timeout_sec, num_rpcs, threshold): argument
430 (timeout_sec, num_rpcs, rpc_type, threshold))
432 error_msg = _check_rpcs_in_flight(rpc_type, num_rpcs, threshold,
442 error_msg = _check_rpcs_in_flight(rpc_type, num_rpcs, threshold,
446 (rpc_type, error_msg))
449 def _check_rpcs_in_flight(rpc_type, num_rpcs, threshold, threshold_fraction): argument
452 rpcs_started = stats.num_rpcs_started_by_method[rpc_type]
453 rpcs_succeeded = stats.num_rpcs_succeeded_by_method[rpc_type]
[all …]
|
| /external/grpc-grpc/src/ruby/qps/ |
| D | client.rb | 93 case config.rpc_type
|
| /external/grpc-grpc/src/proto/grpc/testing/ |
| D | control.proto | 91 RpcType rpc_type = 8; field
|
| /external/grpc-grpc-java/benchmarks/src/main/proto/grpc/testing/ |
| D | control.proto | 92 RpcType rpc_type = 8; field
|
| /external/rust/crates/grpcio-sys/grpc/src/proto/grpc/testing/ |
| D | control.proto | 93 RpcType rpc_type = 8; field
|