Lines Matching refs:chand
207 ExternalConnectivityWatcher(ChannelData* chand, grpc_polling_entity pollent,
215 static void RemoveWatcherFromExternalWatchersMap(ChannelData* chand,
242 explicit ChannelConfigHelper(ChannelData* chand) : chand_(chand) {} in ChannelConfigHelper() argument
598 CallData(grpc_call_element* elem, const ChannelData& chand,
605 void FreeCachedSendInitialMetadata(ChannelData* chand);
607 void FreeCachedSendMessage(ChannelData* chand, size_t idx);
608 void FreeCachedSendTrailingMetadata(ChannelData* chand);
895 SubchannelWrapper(ChannelData* chand, Subchannel* subchannel, in SubchannelWrapper() argument
901 chand_(chand), in SubchannelWrapper()
907 chand, this, subchannel_); in SubchannelWrapper()
1199 ChannelData* chand, grpc_polling_entity pollent, in ExternalConnectivityWatcher() argument
1202 : chand_(chand), in ExternalConnectivityWatcher()
1214 GPR_ASSERT(chand->external_watchers_[on_complete] == nullptr); in ExternalConnectivityWatcher()
1216 chand->external_watchers_[on_complete] = in ExternalConnectivityWatcher()
1236 RemoveWatcherFromExternalWatchersMap(ChannelData* chand, in RemoveWatcherFromExternalWatchersMap() argument
1241 MutexLock lock(&chand->external_watchers_mu_); in RemoveWatcherFromExternalWatchersMap()
1242 auto it = chand->external_watchers_.find(on_complete); in RemoveWatcherFromExternalWatchersMap()
1243 if (it != chand->external_watchers_.end()) { in RemoveWatcherFromExternalWatchersMap()
1245 chand->external_watchers_.erase(it); in RemoveWatcherFromExternalWatchersMap()
1304 ChannelData* chand, grpc_connectivity_state initial_state, in ConnectivityWatcherAdder() argument
1306 : chand_(chand), in ConnectivityWatcherAdder()
1332 ConnectivityWatcherRemover(ChannelData* chand, in ConnectivityWatcherRemover() argument
1334 : chand_(chand), watcher_(watcher) { in ConnectivityWatcherRemover()
1359 explicit ClientChannelControlHelper(ChannelData* chand) : chand_(chand) { in ClientChannelControlHelper() argument
1599 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in Destroy() local
1600 chand->~ChannelData(); in Destroy()
2013 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in StartTransportOp() local
2017 grpc_pollset_set_add_pollset(chand->interested_parties_, op->bind_pollset); in StartTransportOp()
2020 GRPC_CHANNEL_STACK_REF(chand->owning_stack_, "start_transport_op"); in StartTransportOp()
2021 chand->work_serializer_->Run( in StartTransportOp()
2022 [chand, op]() { chand->StartTransportOpLocked(op); }, DEBUG_LOCATION); in StartTransportOp()
2027 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in GetChannelInfo() local
2028 MutexLock lock(&chand->info_mu_); in GetChannelInfo()
2030 *info->lb_policy_name = gpr_strdup(chand->info_lb_policy_name_.get()); in GetChannelInfo()
2034 gpr_strdup(chand->info_service_config_json_.get()); in GetChannelInfo()
2142 CallData::CallData(grpc_call_element* elem, const ChannelData& chand, in CallData() argument
2145 GPR_LIKELY(chand.deadline_checking_enabled()) in CallData()
2159 enable_retries_(chand.enable_retries()), in CallData()
2178 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in Init() local
2179 new (elem->call_data) CallData(elem, *chand, *args); in Init()
2201 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in StartTransportStreamOpBatch() local
2202 if (GPR_LIKELY(chand->deadline_checking_enabled())) { in StartTransportStreamOpBatch()
2209 chand, calld, grpc_error_string(calld->cancel_error_)); in StartTransportStreamOpBatch()
2227 gpr_log(GPR_INFO, "chand=%p calld=%p: recording cancel_error=%s", chand, in StartTransportStreamOpBatch()
2256 "chand=%p calld=%p: starting batch on subchannel_call=%p", chand, in StartTransportStreamOpBatch()
2269 chand, calld); in StartTransportStreamOpBatch()
2276 "chand=%p calld=%p: saved batch, yielding call combiner", chand, in StartTransportStreamOpBatch()
2331 void CallData::FreeCachedSendInitialMetadata(ChannelData* chand) { in FreeCachedSendInitialMetadata() argument
2334 "chand=%p calld=%p: destroying calld->send_initial_metadata", chand, in FreeCachedSendInitialMetadata()
2340 void CallData::FreeCachedSendMessage(ChannelData* chand, size_t idx) { in FreeCachedSendMessage() argument
2344 chand, this, idx); in FreeCachedSendMessage()
2349 void CallData::FreeCachedSendTrailingMetadata(ChannelData* chand) { in FreeCachedSendTrailingMetadata() argument
2353 chand, this); in FreeCachedSendTrailingMetadata()
2360 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in FreeCachedSendOpDataAfterCommit() local
2362 FreeCachedSendInitialMetadata(chand); in FreeCachedSendOpDataAfterCommit()
2365 FreeCachedSendMessage(chand, i); in FreeCachedSendOpDataAfterCommit()
2368 FreeCachedSendTrailingMetadata(chand); in FreeCachedSendOpDataAfterCommit()
2375 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in FreeCachedSendOpDataForCompletedBatch() local
2377 FreeCachedSendInitialMetadata(chand); in FreeCachedSendOpDataForCompletedBatch()
2380 FreeCachedSendMessage(chand, retry_state->completed_send_message_count - 1); in FreeCachedSendOpDataForCompletedBatch()
2383 FreeCachedSendTrailingMetadata(chand); in FreeCachedSendOpDataForCompletedBatch()
2459 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in PendingBatchesAdd() local
2463 "chand=%p calld=%p: adding pending batch at index %" PRIuPTR, chand, in PendingBatchesAdd()
2489 chand->per_rpc_retry_buffer_size())) { in PendingBatchesAdd()
2493 chand, this); in PendingBatchesAdd()
2506 chand, this); in PendingBatchesAdd()
2531 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in MaybeClearPendingBatch() local
2545 gpr_log(GPR_INFO, "chand=%p calld=%p: clearing pending batch", chand, in MaybeClearPendingBatch()
2614 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in PendingBatchesResume() local
2628 chand, this, num_batches, subchannel_call_.get()); in PendingBatchesResume()
2655 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in PendingBatchFind() local
2662 "chand=%p calld=%p: %s pending batch at index %" PRIuPTR, chand, in PendingBatchFind()
2677 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in RetryCommit() local
2681 gpr_log(GPR_INFO, "chand=%p calld=%p: committing retries", chand, this); in RetryCommit()
2691 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in DoRetry() local
2716 "chand=%p calld=%p: retrying failed call in %" PRId64 " ms", chand, in DoRetry()
2731 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in MaybeRetry() local
2745 gpr_log(GPR_INFO, "chand=%p calld=%p: retry already dispatched", chand, in MaybeRetry()
2757 gpr_log(GPR_INFO, "chand=%p calld=%p: call succeeded", chand, this); in MaybeRetry()
2765 "chand=%p calld=%p: status %s not configured as retryable", chand, in MaybeRetry()
2780 gpr_log(GPR_INFO, "chand=%p calld=%p: retries throttled", chand, this); in MaybeRetry()
2787 gpr_log(GPR_INFO, "chand=%p calld=%p: retries already committed", chand, in MaybeRetry()
2796 gpr_log(GPR_INFO, "chand=%p calld=%p: exceeded %d retry attempts", chand, in MaybeRetry()
2806 chand, this); in MaybeRetry()
2819 chand, this); in MaybeRetry()
2825 chand, this, ms); in MaybeRetry()
2925 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in RecvInitialMetadataReady() local
2930 chand, calld, grpc_error_string(error)); in RecvInitialMetadataReady()
2955 chand, calld); in RecvInitialMetadataReady()
3016 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in RecvMessageReady() local
3020 chand, calld, grpc_error_string(error)); in RecvMessageReady()
3044 chand, calld); in RecvMessageReady()
3174 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in AddClosuresToFailUnstartedPendingBatches() local
3182 chand, this, i); in AddClosuresToFailUnstartedPendingBatches()
3222 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in RecvTrailingMetadataReady() local
3227 chand, calld, grpc_error_string(error)); in RecvTrailingMetadataReady()
3241 gpr_log(GPR_INFO, "chand=%p calld=%p: call finished, status=%s", chand, in RecvTrailingMetadataReady()
3300 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in AddClosuresForReplayOrPendingSendOps() local
3322 chand, this); in AddClosuresForReplayOrPendingSendOps()
3336 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in OnComplete() local
3340 chand, calld, grpc_error_string(error), in OnComplete()
3409 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in AddClosureForSubchannelBatch() local
3414 gpr_log(GPR_INFO, "chand=%p calld=%p: starting subchannel batch: %s", chand, in AddClosureForSubchannelBatch()
3472 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in AddRetriableSendMessageOp() local
3476 chand, this, retry_state->started_send_message_count); in AddRetriableSendMessageOp()
3555 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in StartInternalRecvTrailingMetadata() local
3560 chand, this); in StartInternalRecvTrailingMetadata()
3582 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in MaybeCreateSubchannelBatchForReplay() local
3592 chand, this); in MaybeCreateSubchannelBatchForReplay()
3608 chand, this); in MaybeCreateSubchannelBatchForReplay()
3628 chand, this); in MaybeCreateSubchannelBatchForReplay()
3768 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in StartRetriableSubchannelBatches() local
3772 chand, calld); in StartRetriableSubchannelBatches()
3799 chand, calld, closures.size(), calld->subchannel_call_.get()); in StartRetriableSubchannelBatches()
3810 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in CreateSubchannelCall() local
3823 chand, this, subchannel_call_.get(), grpc_error_string(error)); in CreateSubchannelCall()
3843 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in PickDone() local
3848 "chand=%p calld=%p: failed to pick subchannel: error=%s", chand, in PickDone()
3872 auto* chand = static_cast<ChannelData*>(self->elem_->channel_data); in CancelLocked() local
3874 MutexLock lock(chand->data_plane_mu()); in CancelLocked()
3879 chand, calld, grpc_error_string(error), self, in CancelLocked()
3900 auto* chand = static_cast<ChannelData*>(elem->channel_data); in MaybeRemoveCallFromQueuedPicksLocked() local
3903 chand, this); in MaybeRemoveCallFromQueuedPicksLocked()
3905 chand->RemoveQueuedPick(&pick_, pollent_); in MaybeRemoveCallFromQueuedPicksLocked()
3913 auto* chand = static_cast<ChannelData*>(elem->channel_data); in MaybeAddCallToQueuedPicksLocked() local
3915 gpr_log(GPR_INFO, "chand=%p calld=%p: adding to queued picks list", chand, in MaybeAddCallToQueuedPicksLocked()
3920 chand->AddQueuedPick(&pick_, pollent_); in MaybeAddCallToQueuedPicksLocked()
3927 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in ApplyServiceConfigToCallLocked() local
3930 chand, this); in ApplyServiceConfigToCallLocked()
3932 ConfigSelector* config_selector = chand->config_selector(); in ApplyServiceConfigToCallLocked()
3955 if (chand->deadline_checking_enabled() && in ApplyServiceConfigToCallLocked()
3982 retry_throttle_data_ = chand->retry_throttle_data(); in ApplyServiceConfigToCallLocked()
4015 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in PickSubchannel() local
4018 MutexLock lock(chand->data_plane_mu()); in PickSubchannel()
4029 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in PickSubchannelLocked() local
4034 if (chand->picker() == nullptr) { in PickSubchannelLocked()
4035 GRPC_CHANNEL_STACK_REF(chand->owning_stack(), "PickSubchannelLocked"); in PickSubchannelLocked()
4043 auto* chand = static_cast<ChannelData*>(arg); in PickSubchannelLocked() local
4044 chand->work_serializer()->Run( in PickSubchannelLocked()
4045 [chand]() { in PickSubchannelLocked()
4046 chand->CheckConnectivityState(/*try_to_connect=*/true); in PickSubchannelLocked()
4047 GRPC_CHANNEL_STACK_UNREF(chand->owning_stack(), in PickSubchannelLocked()
4052 chand, nullptr), in PickSubchannelLocked()
4072 if (GPR_UNLIKELY(!chand->received_service_config_data())) { in PickSubchannelLocked()
4075 grpc_error* resolver_error = chand->resolver_transient_failure_error(); in PickSubchannelLocked()
4111 auto result = chand->picker()->Pick(pick_args); in PickSubchannelLocked()
4115 chand, this, PickResultTypeName(result.type), in PickSubchannelLocked()
4121 grpc_error* disconnect_error = chand->disconnect_error(); in PickSubchannelLocked()
4172 chand->GetConnectedSubchannelInDataPlane(result.subchannel.get()); in PickSubchannelLocked()
4210 auto* chand = static_cast<ChannelData*>(elem->channel_data); in grpc_client_channel_check_connectivity_state() local
4211 return chand->CheckConnectivityState(try_to_connect); in grpc_client_channel_check_connectivity_state()
4216 auto* chand = static_cast<ChannelData*>(elem->channel_data); in grpc_client_channel_num_external_connectivity_watchers() local
4217 return chand->NumExternalConnectivityWatchers(); in grpc_client_channel_num_external_connectivity_watchers()
4224 auto* chand = static_cast<ChannelData*>(elem->channel_data); in grpc_client_channel_watch_connectivity_state() local
4228 chand->RemoveExternalConnectivityWatcher(closure, /*cancel=*/true); in grpc_client_channel_watch_connectivity_state()
4232 return chand->AddExternalConnectivityWatcher(pollent, state, closure, in grpc_client_channel_watch_connectivity_state()
4240 auto* chand = static_cast<ChannelData*>(elem->channel_data); in grpc_client_channel_start_connectivity_watch() local
4241 chand->AddConnectivityWatcher(initial_state, std::move(watcher)); in grpc_client_channel_start_connectivity_watch()
4247 auto* chand = static_cast<ChannelData*>(elem->channel_data); in grpc_client_channel_stop_connectivity_watch() local
4248 chand->RemoveConnectivityWatcher(watcher); in grpc_client_channel_stop_connectivity_watch()