Lines Matching refs:chand
190 ExternalConnectivityWatcher(ChannelData* chand, grpc_polling_entity pollent,
437 CallData(grpc_call_element* elem, const ChannelData& chand,
444 void FreeCachedSendInitialMetadata(ChannelData* chand);
446 void FreeCachedSendMessage(ChannelData* chand, size_t idx);
447 void FreeCachedSendTrailingMetadata(ChannelData* chand);
726 ChannelData* chand, grpc_connectivity_state state, const char* reason, in ConnectivityStateAndPickerSetter() argument
728 : chand_(chand), picker_(std::move(picker)) { in ConnectivityStateAndPickerSetter()
730 grpc_connectivity_state_set(&chand->state_tracker_, state, reason); in ConnectivityStateAndPickerSetter()
731 if (chand->channelz_node_ != nullptr) { in ConnectivityStateAndPickerSetter()
732 chand->channelz_node_->SetConnectivityState(state); in ConnectivityStateAndPickerSetter()
733 chand->channelz_node_->AddTraceEvent( in ConnectivityStateAndPickerSetter()
739 GRPC_CHANNEL_STACK_REF(chand->owning_stack_, in ConnectivityStateAndPickerSetter()
742 grpc_combiner_scheduler(chand->data_plane_combiner_)); in ConnectivityStateAndPickerSetter()
793 ChannelData* chand, in ServiceConfigSetter() argument
797 : chand_(chand), in ServiceConfigSetter()
800 GRPC_CHANNEL_STACK_REF(chand->owning_stack_, "ServiceConfigSetter"); in ServiceConfigSetter()
802 grpc_combiner_scheduler(chand->data_plane_combiner_)); in ServiceConfigSetter()
809 ChannelData* chand = self->chand_; in SetServiceConfigData() local
811 chand->received_service_config_data_ = true; in SetServiceConfigData()
813 chand->retry_throttle_data_ = in SetServiceConfigData()
815 chand->server_name_.get(), in SetServiceConfigData()
819 chand->service_config_ = std::move(self->service_config_); in SetServiceConfigData()
821 for (QueuedPick* pick = chand->queued_picks_; pick != nullptr; in SetServiceConfigData()
893 ChannelData* chand, grpc_polling_entity pollent, in ExternalConnectivityWatcher() argument
896 : chand_(chand), in ExternalConnectivityWatcher()
969 GrpcSubchannel(ChannelData* chand, Subchannel* subchannel, in GrpcSubchannel() argument
971 : chand_(chand), in GrpcSubchannel()
1045 explicit ClientChannelControlHelper(ChannelData* chand) : chand_(chand) { in ClientChannelControlHelper() argument
1140 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in Destroy() local
1141 chand->~ChannelData(); in Destroy()
1346 ChannelData* chand = static_cast<ChannelData*>(arg); in ProcessResolverResultLocked() local
1354 if (chand->saved_service_config_ != nullptr) { in ProcessResolverResultLocked()
1355 service_config = chand->saved_service_config_; in ProcessResolverResultLocked()
1360 chand); in ProcessResolverResultLocked()
1362 } else if (chand->default_service_config_ != nullptr) { in ProcessResolverResultLocked()
1367 chand); in ProcessResolverResultLocked()
1369 service_config = chand->default_service_config_; in ProcessResolverResultLocked()
1372 if (chand->default_service_config_ != nullptr) { in ProcessResolverResultLocked()
1377 chand); in ProcessResolverResultLocked()
1379 service_config = chand->default_service_config_; in ProcessResolverResultLocked()
1402 (chand->saved_service_config_ == nullptr)) || in ProcessResolverResultLocked()
1405 chand->saved_service_config_->service_config_json()) != 0); in ProcessResolverResultLocked()
1413 chand, service_config_json.get()); in ProcessResolverResultLocked()
1417 chand->health_check_service_name_.reset( in ProcessResolverResultLocked()
1420 chand->health_check_service_name_.reset(); in ProcessResolverResultLocked()
1423 chand->saved_service_config_ = std::move(service_config); in ProcessResolverResultLocked()
1428 if (service_config_changed || !chand->received_first_resolver_result_) { in ProcessResolverResultLocked()
1429 chand->received_first_resolver_result_ = true; in ProcessResolverResultLocked()
1437 New<ServiceConfigSetter>(chand, retry_throttle_data, in ProcessResolverResultLocked()
1438 chand->saved_service_config_); in ProcessResolverResultLocked()
1441 chand->ProcessLbPolicy(result, parsed_service_config, in ProcessResolverResultLocked()
1445 MutexLock lock(&chand->info_mu_); in ProcessResolverResultLocked()
1446 chand->info_lb_policy_name_ = std::move(processed_lb_policy_name); in ProcessResolverResultLocked()
1448 chand->info_service_config_json_ = std::move(service_config_json); in ProcessResolverResultLocked()
1452 *lb_policy_name = chand->info_lb_policy_name_.get(); in ProcessResolverResultLocked()
1479 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in StartTransportOpLocked() local
1483 &chand->state_tracker_, op->connectivity_state, in StartTransportOpLocked()
1490 grpc_error* error = chand->DoPingLocked(op); in StartTransportOpLocked()
1501 if (chand->resolving_lb_policy_ != nullptr) { in StartTransportOpLocked()
1502 chand->resolving_lb_policy_->ResetBackoffLocked(); in StartTransportOpLocked()
1508 GPR_ASSERT(chand->disconnect_error_.CompareExchangeStrong( in StartTransportOpLocked()
1511 chand->DestroyResolvingLoadBalancingPolicyLocked(); in StartTransportOpLocked()
1514 chand, GRPC_CHANNEL_SHUTDOWN, "shutdown from API", in StartTransportOpLocked()
1519 GRPC_CHANNEL_STACK_UNREF(chand->owning_stack_, "start_transport_op"); in StartTransportOpLocked()
1525 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in StartTransportOp() local
1529 grpc_pollset_set_add_pollset(chand->interested_parties_, op->bind_pollset); in StartTransportOp()
1533 GRPC_CHANNEL_STACK_REF(chand->owning_stack_, "start_transport_op"); in StartTransportOp()
1537 grpc_combiner_scheduler(chand->combiner_)), in StartTransportOp()
1543 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in GetChannelInfo() local
1544 MutexLock lock(&chand->info_mu_); in GetChannelInfo()
1546 *info->lb_policy_name = gpr_strdup(chand->info_lb_policy_name_.get()); in GetChannelInfo()
1550 gpr_strdup(chand->info_service_config_json_.get()); in GetChannelInfo()
1579 auto* chand = static_cast<ChannelData*>(arg); in TryToConnectLocked() local
1580 if (chand->resolving_lb_policy_ != nullptr) { in TryToConnectLocked()
1581 chand->resolving_lb_policy_->ExitIdleLocked(); in TryToConnectLocked()
1583 chand->CreateResolvingLoadBalancingPolicyLocked(); in TryToConnectLocked()
1585 GRPC_CHANNEL_STACK_UNREF(chand->owning_stack_, "TryToConnect"); in TryToConnectLocked()
1639 CallData::CallData(grpc_call_element* elem, const ChannelData& chand, in CallData() argument
1642 GPR_LIKELY(chand.deadline_checking_enabled()) in CallData()
1656 enable_retries_(chand.enable_retries()), in CallData()
1671 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in Init() local
1672 new (elem->call_data) CallData(elem, *chand, *args); in Init()
1692 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in StartTransportStreamOpBatch() local
1693 if (GPR_LIKELY(chand->deadline_checking_enabled())) { in StartTransportStreamOpBatch()
1700 chand, calld, grpc_error_string(calld->cancel_error_)); in StartTransportStreamOpBatch()
1718 gpr_log(GPR_INFO, "chand=%p calld=%p: recording cancel_error=%s", chand, in StartTransportStreamOpBatch()
1747 "chand=%p calld=%p: starting batch on subchannel_call=%p", chand, in StartTransportStreamOpBatch()
1759 chand, calld); in StartTransportStreamOpBatch()
1764 grpc_combiner_scheduler(chand->data_plane_combiner())), in StartTransportStreamOpBatch()
1770 "chand=%p calld=%p: saved batch, yielding call combiner", chand, in StartTransportStreamOpBatch()
1825 void CallData::FreeCachedSendInitialMetadata(ChannelData* chand) { in FreeCachedSendInitialMetadata() argument
1828 "chand=%p calld=%p: destroying calld->send_initial_metadata", chand, in FreeCachedSendInitialMetadata()
1834 void CallData::FreeCachedSendMessage(ChannelData* chand, size_t idx) { in FreeCachedSendMessage() argument
1838 chand, this, idx); in FreeCachedSendMessage()
1843 void CallData::FreeCachedSendTrailingMetadata(ChannelData* chand) { in FreeCachedSendTrailingMetadata() argument
1847 chand, this); in FreeCachedSendTrailingMetadata()
1854 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in FreeCachedSendOpDataAfterCommit() local
1856 FreeCachedSendInitialMetadata(chand); in FreeCachedSendOpDataAfterCommit()
1859 FreeCachedSendMessage(chand, i); in FreeCachedSendOpDataAfterCommit()
1862 FreeCachedSendTrailingMetadata(chand); in FreeCachedSendOpDataAfterCommit()
1869 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in FreeCachedSendOpDataForCompletedBatch() local
1871 FreeCachedSendInitialMetadata(chand); in FreeCachedSendOpDataForCompletedBatch()
1874 FreeCachedSendMessage(chand, retry_state->completed_send_message_count - 1); in FreeCachedSendOpDataForCompletedBatch()
1877 FreeCachedSendTrailingMetadata(chand); in FreeCachedSendOpDataForCompletedBatch()
1931 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in PendingBatchesAdd() local
1935 "chand=%p calld=%p: adding pending batch at index %" PRIuPTR, chand, in PendingBatchesAdd()
1961 chand->per_rpc_retry_buffer_size())) { in PendingBatchesAdd()
1965 chand, this); in PendingBatchesAdd()
1978 chand, this); in PendingBatchesAdd()
2003 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in MaybeClearPendingBatch() local
2017 gpr_log(GPR_INFO, "chand=%p calld=%p: clearing pending batch", chand, in MaybeClearPendingBatch()
2086 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in PendingBatchesResume() local
2100 chand, this, num_batches, subchannel_call_.get()); in PendingBatchesResume()
2127 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in PendingBatchFind() local
2134 "chand=%p calld=%p: %s pending batch at index %" PRIuPTR, chand, in PendingBatchFind()
2149 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in RetryCommit() local
2153 gpr_log(GPR_INFO, "chand=%p calld=%p: committing retries", chand, this); in RetryCommit()
2163 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in DoRetry() local
2188 "chand=%p calld=%p: retrying failed call in %" PRId64 " ms", chand, in DoRetry()
2193 grpc_combiner_scheduler(chand->data_plane_combiner())); in DoRetry()
2203 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in MaybeRetry() local
2217 gpr_log(GPR_INFO, "chand=%p calld=%p: retry already dispatched", chand, in MaybeRetry()
2229 gpr_log(GPR_INFO, "chand=%p calld=%p: call succeeded", chand, this); in MaybeRetry()
2237 "chand=%p calld=%p: status %s not configured as retryable", chand, in MaybeRetry()
2252 gpr_log(GPR_INFO, "chand=%p calld=%p: retries throttled", chand, this); in MaybeRetry()
2259 gpr_log(GPR_INFO, "chand=%p calld=%p: retries already committed", chand, in MaybeRetry()
2268 gpr_log(GPR_INFO, "chand=%p calld=%p: exceeded %d retry attempts", chand, in MaybeRetry()
2278 chand, this); in MaybeRetry()
2291 chand, this); in MaybeRetry()
2297 chand, this, ms); in MaybeRetry()
2396 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in RecvInitialMetadataReady() local
2401 chand, calld, grpc_error_string(error)); in RecvInitialMetadataReady()
2426 chand, calld); in RecvInitialMetadataReady()
2486 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in RecvMessageReady() local
2490 chand, calld, grpc_error_string(error)); in RecvMessageReady()
2514 chand, calld); in RecvMessageReady()
2644 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in AddClosuresToFailUnstartedPendingBatches() local
2652 chand, this, i); in AddClosuresToFailUnstartedPendingBatches()
2692 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in RecvTrailingMetadataReady() local
2697 chand, calld, grpc_error_string(error)); in RecvTrailingMetadataReady()
2711 gpr_log(GPR_INFO, "chand=%p calld=%p: call finished, status=%s", chand, in RecvTrailingMetadataReady()
2770 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in AddClosuresForReplayOrPendingSendOps() local
2792 chand, this); in AddClosuresForReplayOrPendingSendOps()
2806 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in OnComplete() local
2811 chand, calld, grpc_error_string(error), batch_str); in OnComplete()
2880 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in AddClosureForSubchannelBatch() local
2886 gpr_log(GPR_INFO, "chand=%p calld=%p: starting subchannel batch: %s", chand, in AddClosureForSubchannelBatch()
2946 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in AddRetriableSendMessageOp() local
2950 chand, this, retry_state->started_send_message_count); in AddRetriableSendMessageOp()
3029 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in StartInternalRecvTrailingMetadata() local
3034 chand, this); in StartInternalRecvTrailingMetadata()
3056 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in MaybeCreateSubchannelBatchForReplay() local
3066 chand, this); in MaybeCreateSubchannelBatchForReplay()
3082 chand, this); in MaybeCreateSubchannelBatchForReplay()
3102 chand, this); in MaybeCreateSubchannelBatchForReplay()
3241 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in StartRetriableSubchannelBatches() local
3245 chand, calld); in StartRetriableSubchannelBatches()
3272 chand, calld, closures.size(), calld->subchannel_call_.get()); in StartRetriableSubchannelBatches()
3283 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in CreateSubchannelCall() local
3296 chand, this, subchannel_call_.get(), grpc_error_string(error)); in CreateSubchannelCall()
3311 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in PickDone() local
3316 "chand=%p calld=%p: failed to pick subchannel: error=%s", chand, in PickDone()
3331 auto* chand = static_cast<ChannelData*>(elem->channel_data); in QueuedPickCanceller() local
3334 grpc_combiner_scheduler(chand->data_plane_combiner())); in QueuedPickCanceller()
3341 auto* chand = static_cast<ChannelData*>(self->elem_->channel_data); in CancelLocked() local
3347 chand, calld, grpc_error_string(error), self, in CancelLocked()
3366 auto* chand = static_cast<ChannelData*>(elem->channel_data); in RemoveCallFromQueuedPicksLocked() local
3369 chand, this); in RemoveCallFromQueuedPicksLocked()
3371 chand->RemoveQueuedPick(&pick_, pollent_); in RemoveCallFromQueuedPicksLocked()
3378 auto* chand = static_cast<ChannelData*>(elem->channel_data); in AddCallToQueuedPicksLocked() local
3380 gpr_log(GPR_INFO, "chand=%p calld=%p: adding to queued picks list", chand, in AddCallToQueuedPicksLocked()
3385 chand->AddQueuedPick(&pick_, pollent_); in AddCallToQueuedPicksLocked()
3391 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in ApplyServiceConfigToCallLocked() local
3394 chand, this); in ApplyServiceConfigToCallLocked()
3400 ServiceConfig::CallData(chand->service_config(), path_); in ApplyServiceConfigToCallLocked()
3408 retry_throttle_data_ = chand->retry_throttle_data(); in ApplyServiceConfigToCallLocked()
3412 if (chand->deadline_checking_enabled() && method_params_->timeout() != 0) { in ApplyServiceConfigToCallLocked()
3444 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in MaybeApplyServiceConfigToCallLocked() local
3447 if (GPR_LIKELY(chand->received_service_config_data() && in MaybeApplyServiceConfigToCallLocked()
3470 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in StartPickLocked() local
3475 if (chand->picker() == nullptr) { in StartPickLocked()
3478 chand->CheckConnectivityState(true); in StartPickLocked()
3513 auto result = chand->picker()->Pick(pick_args); in StartPickLocked()
3518 chand, calld, PickResultTypeName(result.type), in StartPickLocked()
3524 grpc_error* disconnect_error = chand->disconnect_error(); in StartPickLocked()
3601 auto* chand = static_cast<ChannelData*>(elem->channel_data); in grpc_client_channel_check_connectivity_state() local
3602 return chand->CheckConnectivityState(try_to_connect); in grpc_client_channel_check_connectivity_state()
3607 auto* chand = static_cast<ChannelData*>(elem->channel_data); in grpc_client_channel_num_external_connectivity_watchers() local
3608 return chand->NumExternalConnectivityWatchers(); in grpc_client_channel_num_external_connectivity_watchers()
3615 auto* chand = static_cast<ChannelData*>(elem->channel_data); in grpc_client_channel_watch_connectivity_state() local
3616 return chand->AddExternalConnectivityWatcher(pollent, state, closure, in grpc_client_channel_watch_connectivity_state()