Lines Matching refs:ctx_
109 std::vector<std::unique_ptr<CallbackClientRpcContext>> ctx_; member in grpc::testing::CallbackClient
148 ctx_.emplace_back( in CallbackUnaryClient()
173 if (ctx_[vector_idx]->alarm_ == nullptr) { in ScheduleRpc()
174 ctx_[vector_idx]->alarm_.reset(new Alarm); in ScheduleRpc()
176 ctx_[vector_idx]->alarm_->experimental().Set( in ScheduleRpc()
188 ctx_[vector_idx]->stub_->experimental_async()->UnaryCall( in IssueUnaryCallbackRpc()
189 (&ctx_[vector_idx]->context_), &request_, &ctx_[vector_idx]->response_, in IssueUnaryCallbackRpc()
204 ctx_[vector_idx].reset( in IssueUnaryCallbackRpc()
205 new CallbackClientRpcContext(ctx_[vector_idx]->stub_)); in IssueUnaryCallbackRpc()
220 ctx_.emplace_back( in CallbackStreamingClient()
257 : client_(client), ctx_(std::move(ctx)), messages_issued_(0) {} in CallbackStreamingPingPongReactor()
260 ctx_->stub_->experimental_async()->StreamingCall(&(ctx_->context_), this); in StartNewRpc()
275 StartRead(&ctx_->response_); in OnWriteDone()
296 ctx_->alarm_->experimental().Set(next_issue_time, [this](bool /*ok*/) { in OnReadDone()
311 ctx_.reset(new CallbackClientRpcContext(ctx_->stub_)); in OnDone()
320 if (ctx_->alarm_ == nullptr) { in ScheduleRpc()
321 ctx_->alarm_.reset(new Alarm); in ScheduleRpc()
323 ctx_->alarm_->experimental().Set(next_issue_time, in ScheduleRpc()
333 std::unique_ptr<CallbackClientRpcContext> ctx_; member in grpc::testing::CallbackStreamingPingPongReactor
347 new CallbackStreamingPingPongReactor(this, std::move(ctx_[i]))); in CallbackStreamingPingPongClientImpl()