Searched refs:next_issue_ (Results 1 – 1 of 1) sorted by relevance
/third_party/grpc/test/cpp/qps/ |
D | client_async.cc | 82 next_issue_(std::move(next_issue)), in ClientRpcContextUnaryImpl() 112 auto* clone = new ClientRpcContextUnaryImpl(stub_, req_, next_issue_, in StartNewClone() 128 std::function<gpr_timespec()> next_issue_; member in grpc::testing::ClientRpcContextUnaryImpl 140 if (!next_issue_) { // ready to issue in StartInternal() 144 alarm_->Set(cq_, next_issue_(), ClientRpcContext::tag(this)); in StartInternal() 353 next_issue_(std::move(next_issue)), in ClientRpcContextStreamingPingPongImpl() 364 if (!next_issue_) { // ready to issue in RunNextState() 373 alarm_->Set(cq_, next_issue_(), ClientRpcContext::tag(this)); in RunNextState() 428 stub_, req_, next_issue_, prepare_req_, callback_); in StartNewClone() 452 std::function<gpr_timespec()> next_issue_; member in grpc::testing::ClientRpcContextStreamingPingPongImpl [all …]
|