Searched refs:lb_call_ (Results 1 – 3 of 3) sorted by relevance
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/ |
| D | grpclb.cc | 205 grpc_call* lb_call_ = nullptr; member in grpc_core::__anon194416590111::GrpcLb::BalancerCallState
774 lb_call_ = grpc_channel_create_pollset_set_call( in BalancerCallState()
795 GPR_ASSERT(lb_call_ != nullptr); in ~BalancerCallState()
796 grpc_call_unref(lb_call_); in ~BalancerCallState()
805 GPR_ASSERT(lb_call_ != nullptr); in Orphan()
810 grpc_call_cancel_internal(lb_call_); in Orphan()
820 GPR_ASSERT(lb_call_ != nullptr); in StartQuery()
823 grpclb_policy_.get(), this, lb_call_); in StartQuery()
849 call_error = grpc_call_start_batch_and_execute(lb_call_, ops, in StartQuery()
873 lb_call_, ops, static_cast<size_t>(op - ops), in StartQuery()
[all …]
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/ |
| D | grpclb.cc | 214 grpc_call* lb_call_ = nullptr; member in grpc_core::__anon21ecf8450111::GrpcLb::BalancerCallState
513 lb_call_ = grpc_channel_create_pollset_set_call( in BalancerCallState()
540 GPR_ASSERT(lb_call_ != nullptr); in ~BalancerCallState()
541 grpc_call_unref(lb_call_); in ~BalancerCallState()
550 GPR_ASSERT(lb_call_ != nullptr); in Orphan()
555 grpc_call_cancel(lb_call_, nullptr); in Orphan()
565 GPR_ASSERT(lb_call_ != nullptr); in StartQuery()
569 grpclb_policy_.get(), this, lb_call_); in StartQuery()
595 lb_call_, ops, (size_t)(op - ops), &lb_on_initial_request_sent_); in StartQuery()
617 lb_call_, ops, (size_t)(op - ops), &lb_on_balancer_message_received_); in StartQuery()
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/ |
| D | client_channel.cc | 843 RefCountedPtr<LoadBalancedCall> lb_call_; member in grpc_core::__anon983758c10111::RetryingCall
1133 if (GPR_LIKELY(calld->lb_call_ != nullptr)) { in Destroy()
1134 subchannel_call = calld->lb_call_->subchannel_call(); in Destroy()
1155 calld->lb_call_->StartTransportStreamOpBatch(batch); in StartTransportStreamOpBatch()
1190 calld->lb_call_ = in SetPollent()
1195 chand, client_channel, calld->lb_call_.get()); in SetPollent()
1221 RefCountedPtr<LoadBalancedCall> lb_call_; member in grpc_core::__anon983758c10111::DynamicTerminationFilterCallData
3293 if (lb_call_ == nullptr) { in StartTransportStreamOpBatch()
3302 lb_call_->StartTransportStreamOpBatch(batch); in StartTransportStreamOpBatch()
3312 if (lb_call_ == nullptr) { in StartTransportStreamOpBatch()
[all …]
|