| /third_party/grpc/test/cpp/end2end/ |
| D | flaky_network_test.cc | 206 bool SendRpc( in SendRpc() function in grpc::testing::__anondeb12ea00111::FlakyNetworkTest
367 EXPECT_TRUE(SendRpc(stub)); in TEST_P()
376 SendRpc(stub); in TEST_P()
414 EXPECT_TRUE(SendRpc(stub)); in TEST_P()
423 SendRpc(stub); in TEST_P()
449 EXPECT_TRUE(SendRpc(stub)); in TEST_P()
457 EXPECT_FALSE(SendRpc(stub, /*timeout_ms=*/500, /*wait_for_ready=*/true)); in TEST_P()
459 EXPECT_TRUE(SendRpc(stub, /*timeout_ms=*/0, /*wait_for_ready=*/true)); in TEST_P()
484 EXPECT_TRUE(SendRpc(stub)); in TEST_P()
490 SendRpc(stub); in TEST_P()
[all …]
|
| D | port_sharing_end2end_test.cc | 298 static void SendRpc(EchoTestService::Stub* stub, int num_rpcs) { in SendRpc() function
341 SendRpc(stub_handoff1_.get(), 5); in TEST_P()
343 SendRpc(stub_direct_.get(), 5); in TEST_P()
350 SendRpc(stub_handoff2_.get(), 1); in TEST_P()
357 SendRpc(stub_handoff1_.get(), 5); in TEST_P()
358 SendRpc(stub_handoff2_.get(), 5); in TEST_P()
|
| D | generic_end2end_test.cc | 109 void SendRpc(int num_rpcs) { in SendRpc() function in grpc::testing::__anon55e56ffc0111::GenericEnd2endTest
110 SendRpc(num_rpcs, false, gpr_inf_future(GPR_CLOCK_MONOTONIC)); in SendRpc()
113 void SendRpc(int num_rpcs, bool check_deadline, gpr_timespec deadline) { in SendRpc() function in grpc::testing::__anon55e56ffc0111::GenericEnd2endTest
257 SendRpc(1); in TEST_F()
262 SendRpc(10); in TEST_F()
393 SendRpc(1, true, in TEST_F()
|
| D | filter_end2end_test.cc | 172 void SendRpc(int num_rpcs) { in SendRpc() function in grpc::testing::__anonf05b3b850111::FilterEnd2endTest
248 SendRpc(1); in TEST_F()
257 SendRpc(10); in TEST_F()
|
| D | nonblocking_test.cc | 124 void SendRpc(int num_rpcs) { in SendRpc() function in grpc::testing::__anonb00edf140211::NonblockingTest
185 SendRpc(10); in TEST_F()
|
| D | service_config_end2end_test.cc | 257 bool SendRpc( in SendRpc() function in grpc::testing::__anonfb1076050111::ServiceConfigEnd2endTest
280 SendRpc(stub, &response, 2000, &status, wait_for_ready); in CheckRpcSendOk()
292 const bool success = SendRpc(stub); in CheckRpcSendFailure()
358 SendRpc(stub); in WaitForServer()
|
| D | grpclb_end2end_test.cc | 501 const Status status = SendRpc(); in SendRpcAndCount()
538 (void)SendRpc(); in WaitForBackend()
630 Status SendRpc(EchoResponse* response = nullptr, int timeout_ms = 1000, in SendRpc() function in grpc::testing::__anon039512b90111::GrpclbEnd2endTest
654 const Status status = SendRpc(&response, timeout_ms, wait_for_ready); in CheckRpcSendOk()
662 const Status status = SendRpc(); in CheckRpcSendFailure()
780 Status actual = SendRpc(/*response=*/nullptr, /*timeout_ms=*/1000, in TEST_F()
1001 const Status status = SendRpc(); in TEST_F()
1780 const Status status = SendRpc(&response); in TEST_F()
1812 const Status status = SendRpc(nullptr, 1000, true); in TEST_F()
1837 status = SendRpc(nullptr, 1000, true); in TEST_F()
[all …]
|
| D | cfstream_test.cc | 160 void SendRpc( in SendRpc() function in grpc::testing::__anon6b05a8f50111::CFStreamTest
336 SendRpc(stub, /*expect_success=*/true); in TEST_P()
345 SendRpc(stub); in TEST_P()
|
| D | client_lb_end2end_test.cc | 290 bool SendRpc( in SendRpc() function in grpc::testing::__anonb6f7b24b0111::ClientLbEnd2endTest
317 SendRpc(stub, &response, 2000, &status, wait_for_ready); in CheckRpcSendOk()
329 const bool success = SendRpc(stub); in CheckRpcSendFailure()
395 SendRpc(stub); in WaitForServer()
1192 for (size_t i = 0; i < 10; ++i) SendRpc(stub); in TEST_F()
1205 for (size_t i = 0; i < kNumServers; ++i) SendRpc(stub); in TEST_F()
1281 if (SendRpc(stub)) break; in TEST_F()
1368 while (!SendRpc(stub)) { in TEST_F()
1501 SendRpc(stub); in TEST_F()
|
| D | xds_end2end_test.cc | 1330 const Status status = SendRpc(rpc_options); in SendRpcAndCount()
1367 Status status = SendRpc(); in WaitForBackend()
1466 Status SendRpc(const RpcOptions& rpc_options = RpcOptions(), in SendRpc() function in grpc::testing::__anon5b583b8e0111::XdsEnd2endTest
1506 const Status status = SendRpc(rpc_options, &response); in CheckRpcSendOk()
1515 const Status status = SendRpc(RpcOptions().set_server_fail(server_fail)); in CheckRpcSendFailure()
1855 const Status status = SendRpc(); in TEST_P()
1944 } while (SendRpc(RpcOptions(), nullptr).ok()); in TEST_P()
2277 (void)SendRpc(); in TEST_P()
2298 } while (SendRpc(RpcOptions(), nullptr).ok()); in TEST_P()
2338 (void)SendRpc(); in TEST_P()
[all …]
|
| D | thread_stress_test.cc | 278 static void SendRpc(grpc::testing::EchoTestService::Stub* stub, int num_rpcs, in SendRpc() function
320 threads.emplace_back(SendRpc, this->common_.GetStub(), kNumRpcs, in TYPED_TEST()
|
| D | end2end_test.cc | 469 static void SendRpc(grpc::testing::EchoTestService::Stub* stub, int num_rpcs, in SendRpc() function
831 threads.emplace_back(SendRpc, stub_.get(), 10, true); in TEST_P()
843 threads.emplace_back(SendRpc, stub_.get(), 10, false); in TEST_P()
888 SendRpc(stub_.get(), 1, false); in TEST_P()
898 SendRpc(stub_.get(), 1, false); in TEST_P()
1478 SendRpc(stub_.get(), 1, false); in TEST_P()
1496 threads.emplace_back(SendRpc, stub_.get(), 10, false); in TEST_P()
|
| D | async_end2end_test.cc | 307 void SendRpc(int num_rpcs) { in SendRpc() function in grpc::testing::__anon598b16bd0111::AsyncEnd2endTest
351 SendRpc(1); in TEST_P()
402 SendRpc(10); in TEST_P()
420 SendRpc(1); in TEST_P()
435 SendRpc(1); in TEST_P()
447 SendRpc(1); in TEST_P()
456 SendRpc(1); in TEST_P()
|
| /third_party/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 {
233 [self SendRpc:1];
238 [self SendRpc:10];
|