Home
last modified time | relevance | path

Searched refs:next_issue_ (Results 1 – 1 of 1) sorted by relevance

/third_party/grpc/test/cpp/qps/
Dclient_async.cc82 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 …]