Home
last modified time | relevance | path

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

/external/grpc-grpc/include/grpcpp/impl/codegen/
Dsync_stream.h659 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()
Dmethod_handler_impl.h175 param.call->cq()->Pluck(&param.server_context->pending_ops_); in RunHandler()
224 param.call->cq()->Pluck(&param.server_context->pending_ops_); in RunHandler()
Dserver_context.h307 pending_ops_; variable