Searched refs:pending_ops_ (Results 1 – 3 of 3) sorted by relevance
659 if (!ctx_->pending_ops_.SendMessage(msg, options).ok()) { in Write()663 ctx_->pending_ops_.SendInitialMetadata(ctx_->initial_metadata_, in Write()666 ctx_->pending_ops_.set_compression_level(ctx_->compression_level()); in Write()670 call_->PerformOps(&ctx_->pending_ops_); in Write()679 return call_->cq()->Pluck(&ctx_->pending_ops_); in Write()737 if (!ctx_->pending_ops_.SendMessage(msg, options).ok()) { in Write()741 ctx_->pending_ops_.SendInitialMetadata(ctx_->initial_metadata_, in Write()744 ctx_->pending_ops_.set_compression_level(ctx_->compression_level()); in Write()748 call_->PerformOps(&ctx_->pending_ops_); in Write()757 return call_->cq()->Pluck(&ctx_->pending_ops_); in Write()
175 param.call->cq()->Pluck(¶m.server_context->pending_ops_); in RunHandler()224 param.call->cq()->Pluck(¶m.server_context->pending_ops_); in RunHandler()
307 pending_ops_; variable