| /external/rust/crates/grpcio-sys/grpc/tools/run_tests/xds_k8s_test_driver/framework/rpc/ |
| D | grpc_testing.py | 42 num_rpcs: int,
50 num_rpcs=num_rpcs,
|
| /external/grpc-grpc/test/cpp/end2end/ |
| D | generic_end2end_test.cc | 102 void SendRpc(int num_rpcs) { in SendRpc() argument
103 SendRpc(num_rpcs, false, gpr_inf_future(GPR_CLOCK_MONOTONIC)); in SendRpc()
106 void SendRpc(int num_rpcs, bool check_deadline, gpr_timespec deadline) { in SendRpc() argument
108 for (int i = 0; i < num_rpcs; i++) { in SendRpc()
201 const int num_rpcs = 10; in TEST_F() local
203 for (int i = 0; i < num_rpcs; i++) { in TEST_F()
|
| D | client_callback_end2end_test.cc | 69 void SendRpcs(int num_rpcs, bool with_binary_metadata) { in SendRpcs() argument
71 for (int i = 0; i < num_rpcs; i++) { in SendRpcs()
107 void SendRpcsGeneric(int num_rpcs, bool maybe_except) { in SendRpcsGeneric() argument
110 for (int i = 0; i < num_rpcs; i++) { in SendRpcsGeneric()
|
| D | thread_stress_test.cc | 271 static void SendRpc(grpc::testing::EchoTestService::Stub* stub, int num_rpcs, in SendRpc() argument
277 for (int i = 0; i < num_rpcs; ++i) { in SendRpc()
359 void AsyncSendRpc(int num_rpcs) { in AsyncSendRpc() argument
360 for (int i = 0; i < num_rpcs; ++i) { in AsyncSendRpc()
|
| D | nonblocking_test.cc | 114 void SendRpc(int num_rpcs) { in SendRpc() argument
115 for (int i = 0; i < num_rpcs; i++) { in SendRpc()
|
| D | filter_end2end_test.cc | 161 void SendRpc(int num_rpcs) { in SendRpc() argument
163 for (int i = 0; i < num_rpcs; i++) { in SendRpc()
|
| D | end2end_test.cc | 340 static void SendRpc(grpc::testing::EchoTestService::Stub* stub, int num_rpcs, in SendRpc() argument
346 for (int i = 0; i < num_rpcs; ++i) { in SendRpc()
|
| D | async_end2end_test.cc | 303 void SendRpc(int num_rpcs) { in SendRpc() argument
304 for (int i = 0; i < num_rpcs; i++) { in SendRpc()
|
| /external/rust/crates/grpcio-sys/grpc/tools/run_tests/xds_k8s_test_driver/framework/ |
| D | xds_k8s_testcase.py | 126 num_rpcs: int = 100):
127 lb_stats = self.sendRpcs(test_client, num_rpcs)
137 num_rpcs: Optional[int] = 100):
138 lb_stats = self.sendRpcs(test_client, num_rpcs)
142 num_rpcs,
147 num_rpcs: int) -> LoadBalancerStatsResponse:
148 lb_stats = test_client.get_load_balancer_stats(num_rpcs=num_rpcs)
|
| /external/rust/crates/grpcio-sys/grpc/tools/run_tests/ |
| D | run_xds_tests.py | 298 def get_client_stats(num_rpcs, timeout_sec): argument
308 request.num_rpcs = num_rpcs
369 def _verify_rpcs_to_given_backends(backends, timeout_sec, num_rpcs, argument
377 stats = get_client_stats(num_rpcs, timeout_sec)
394 num_rpcs=_NUM_TEST_RPCS): argument
397 num_rpcs,
403 num_rpcs=_NUM_TEST_RPCS): argument
406 num_rpcs,
410 def wait_until_rpcs_in_flight(rpc_type, timeout_sec, num_rpcs, threshold): argument
430 (timeout_sec, num_rpcs, rpc_type, threshold))
[all …]
|
| /external/grpc-grpc/test/cpp/cocoapods/generic/ |
| D | generic.mm | 162 - (void)SendRpc:(int)num_rpcs {
163 [self SendRpc:num_rpcs check_deadline:false deadline:gpr_inf_future(GPR_CLOCK_MONOTONIC)];
166 - (void)SendRpc:(int)num_rpcs check_deadline:(bool)check_deadline deadline:(gpr_timespec)deadline {
168 for (int i = 0; i < num_rpcs; i++) {
|
| /external/rust/crates/grpcio-sys/grpc/tools/run_tests/xds_k8s_test_driver/framework/test_app/ |
| D | client_app.py | 77 num_rpcs: int,
84 num_rpcs=num_rpcs, timeout_sec=timeout_sec)
|
| /external/rust/crates/grpcio-sys/grpc/src/proto/grpc/testing/ |
| D | messages.proto | 198 // Request stats for the next num_rpcs sent by client.
199 int32 num_rpcs = 1; field
200 // If num_rpcs have not completed within timeout_sec, return partial results.
|