Searched refs:NewStub (Results 1 – 25 of 69) sorted by relevance
123
61 ReconnectService::NewStub( in main()87 ReconnectService::NewStub(retry_channel)); in main()
99 if (!PrintMetrics(MetricsService::NewStub(channel), FLAGS_total_only, in main()
86 grpc::testing::EchoTestService::NewStub(grpc::CreateChannel( in BM_E2eLatencyCensusDisabled()106 grpc::testing::EchoTestService::NewStub(grpc::CreateChannel( in BM_E2eLatencyCensusEnabled()
56 EchoTestService::NewStub(fixture->channel())); in BM_PumpStreamClientToServer()125 EchoTestService::NewStub(fixture->channel())); in BM_PumpStreamServerToClient()
66 EchoTestService::NewStub(fixture->channel())); in BM_StreamingPingPong()159 EchoTestService::NewStub(fixture->channel())); in BM_StreamingPingPongMsgs()263 EchoTestService::NewStub(fixture->channel())); in BM_StreamingPingPongWithCoalescingApi()
73 EchoTestService::NewStub(fixture->channel())); in BM_UnaryPingPong()
279 servers[i].stub = WorkerService::NewStub(CreateChannel( in RunScenario()283 servers[i].stub = WorkerService::NewStub( in RunScenario()338 clients[i].stub = WorkerService::NewStub( in RunScenario()342 clients[i].stub = WorkerService::NewStub( in RunScenario()542 auto stub = WorkerService::NewStub(CreateChannel( in RunQuit()
133 : Reporter(name), stub_(ReportQpsScenarioService::NewStub(channel)) {} in RpcReporter()
96 auto stub = EchoTestService::NewStub( in ClientMakeEchoCalls()128 auto stub = ::grpc::lb::v1::LoadReporter::NewStub(channel); in TEST_F()
47 auto stub = grpc::testing::EchoTestService::NewStub( in main()
76 stub_ = grpc::testing::EchoTestService::NewStub(channel_); in ResetStub()
62 return grpc::testing::EchoTestService::NewStub( in CreateServerAndStub()
62 stubs_.push_back(grpc::testing::EchoTestService::NewStub(channel)); in AddChannelToBackend()137 channelz_stub_ = grpc::channelz::v1::Channelz::NewStub(channel); in ResetStubs()138 echo_stub_ = grpc::testing::EchoTestService::NewStub(channel); in ResetStubs()
150 stub_ = grpc::testing::EchoTestService::NewStub(channel); in ResetStub()
90 stub_ = grpc::testing::EchoTestService::NewStub(channel_); in ResetStub()
100 this->stub_ = grpc::testing::EchoTestService::NewStub(channel); in ResetStub()124 this->stub_ = grpc::testing::EchoTestService::NewStub(channel); in ResetStub()
41 : stub_(Greeter::NewStub(channel)) {} in GreeterClient()
40 : stub_(Greeter::NewStub(channel)) {} in GreeterClient()
69 xla_service_ = grpc::XlaService::NewStub(channel); in GRPCClientTestBase()
13 : stub_(Greeter::NewStub(channel)) {} in GreeterClient()
42 grpc::TpuCompilationCacheService::NewStub( in NewStub() function in tensorflow::tpu::grpc::TpuCompilationCacheService
117 auto stub = testing::EchoTestService::NewStub( in TEST()
76 : stub_(Greeter::NewStub(channel)) {} in GreeterClient()
79 stub_ = grpc::testing::EchoTestService::NewStub(channel_); in ResetStub()