Cross Reference: /external/grpc-grpc/test/cpp/qps/client

Lines Matching refs:Stub
46 static std::unique_ptr<BenchmarkService::Stub> BenchmarkStubCreator(
52     : public ClientImpl<BenchmarkService::Stub, SimpleRequest> {
55       : ClientImpl<BenchmarkService::Stub, SimpleRequest>(
127     auto* stub = channels_[thread_idx % channels_.size()].get_stub();
132         stub->UnaryCall(&context, request_, &responses_[thread_idx]);
232     auto* stub = channels_[thread_idx % channels_.size()].get_stub();
235       stream_[thread_idx] = stub->StreamingCall(&context_[thread_idx]);
264     auto* stub = channels_[thread_idx % channels_.size()].get_stub();
267       stream_[thread_idx] = stub->StreamingCall(&context_[thread_idx]);
291     auto* stub = channels_[thread_idx % channels_.size()].get_stub();
294       stream_[thread_idx] = stub->StreamingFromClient(&context_[thread_idx],
317     auto* stub = channels_[thread_idx % channels_.size()].get_stub();
320       stream_[thread_idx] = stub->StreamingFromClient(&context_[thread_idx],
341     auto* stub = channels_[thread_idx % channels_.size()].get_stub();
345           stub->StreamingFromServer(&context_[thread_idx], request_);
362     auto* stub = channels_[thread_idx % channels_.size()].get_stub();
366           stub->StreamingFromServer(&context_[thread_idx], request_);
388     auto* stub = channels_[thread_idx % channels_.size()].get_stub();
391       stream_[thread_idx] = stub->StreamingBothWays(&context_[thread_idx]);
OpenGrok
