| /third_party/grpc/src/core/ext/filters/max_age/ |
| D | max_age_filter.cc | 152 static void increase_call_count(channel_data* chand) { in increase_call_count() argument
154 if (gpr_atm_full_fetch_add(&chand->call_count, 1) == 0) { in increase_call_count()
156 gpr_atm idle_state = gpr_atm_acq_load(&chand->idle_state); in increase_call_count()
162 gpr_atm_rel_cas(&chand->idle_state, MAX_IDLE_STATE_TIMER_SET, in increase_call_count()
166 gpr_atm_rel_store(&chand->idle_state, MAX_IDLE_STATE_SEEN_EXIT_IDLE); in increase_call_count()
178 static void decrease_call_count(channel_data* chand) { in decrease_call_count() argument
180 if (gpr_atm_full_fetch_add(&chand->call_count, -1) == 1) { in decrease_call_count()
181 gpr_atm_no_barrier_store(&chand->last_enter_idle_time_millis, in decrease_call_count()
184 gpr_atm idle_state = gpr_atm_acq_load(&chand->idle_state); in decrease_call_count()
187 GRPC_CHANNEL_STACK_REF(chand->channel_stack, in decrease_call_count()
[all …]
|
| /third_party/grpc/src/core/ext/filters/client_idle/ |
| D | client_idle_filter.cc | 181 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in Destroy() local
182 chand->~ChannelData(); in Destroy()
187 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in StartTransportOp() local
192 chand->IncreaseCallCount(); in StartTransportOp()
196 grpc_timer_cancel(&chand->idle_timer_); in StartTransportOp()
308 ChannelData* chand = static_cast<ChannelData*>(arg); in IdleTimerCallback() local
311 GRPC_CHANNEL_STACK_UNREF(chand->channel_stack_, "max idle timer callback"); in IdleTimerCallback()
315 ChannelState state = chand->state_.Load(MemoryOrder::RELAXED); in IdleTimerCallback()
322 finished = chand->state_.CompareExchangeWeak( in IdleTimerCallback()
325 chand->EnterIdle(); in IdleTimerCallback()
[all …]
|
| /third_party/grpc/src/core/ext/filters/http/ |
| D | client_authority_filter.cc | 53 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in client_authority_start_transport_stream_op_batch() local
63 GRPC_MDELEM_REF(chand->default_authority_mdelem), GRPC_BATCH_AUTHORITY); in client_authority_start_transport_stream_op_batch()
90 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in client_authority_init_channel_elem() local
104 chand->default_authority = in client_authority_init_channel_elem()
106 chand->default_authority_mdelem = grpc_mdelem_create( in client_authority_init_channel_elem()
107 GRPC_MDSTR_AUTHORITY, chand->default_authority, nullptr); in client_authority_init_channel_elem()
114 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in client_authority_destroy_channel_elem() local
115 grpc_slice_unref_internal(chand->default_authority); in client_authority_destroy_channel_elem()
116 GRPC_MDELEM_UNREF(chand->default_authority_mdelem); in client_authority_destroy_channel_elem()
|
| /third_party/grpc/src/core/lib/surface/ |
| D | lame_client.cc | 58 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in lame_start_transport_stream_op_batch() local
60 op, GRPC_ERROR_REF(chand->error), calld->call_combiner); in lame_start_transport_stream_op_batch()
68 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in lame_start_transport_op() local
70 MutexLock lock(&chand->mu); in lame_start_transport_op()
72 chand->state_tracker.AddWatcher(op->start_connectivity_watch_state, in lame_start_transport_op()
76 chand->state_tracker.RemoveWatcher(op->stop_connectivity_watch); in lame_start_transport_op()
115 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in lame_destroy_channel_elem() local
116 chand->~ChannelData(); in lame_destroy_channel_elem()
123 auto chand = static_cast<grpc_core::ChannelData*>(elem->channel_data); in SetLameFilterError() local
124 chand->error = error; in SetLameFilterError()
|
| D | server.cc | 612 ChannelData* chand = static_cast<ChannelData*>( in SetupTransport() local
631 chand->InitTransport(Ref(), channel, cq_idx, transport, channelz_socket_uuid); in SetupTransport()
758 for (const ChannelData* chand : channels_) { in GetChannelsLocked() local
759 channels.push_back(chand->channel()); in GetChannelsLocked()
760 GRPC_CHANNEL_INTERNAL_REF(chand->channel(), "broadcast"); in GetChannelsLocked()
959 explicit ConnectivityWatcher(ChannelData* chand) : chand_(chand) { in ConnectivityWatcher() argument
1115 auto* chand = static_cast<Server::ChannelData*>(arg); in AcceptStream() local
1118 args.channel = chand->channel_; in AcceptStream()
1119 args.server = chand->server_.get(); in AcceptStream()
1142 auto* chand = static_cast<Server::ChannelData*>(arg); in FinishDestroy() local
[all …]
|
| /third_party/grpc/src/core/lib/channel/ |
| D | connected_channel.cc | 105 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in connected_channel_start_transport_stream_op_batch() local
138 chand->transport, TRANSPORT_STREAM_FROM_CALL_DATA(calld), batch); in connected_channel_start_transport_stream_op_batch()
144 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in connected_channel_start_transport_op() local
145 grpc_transport_perform_op(chand->transport, op); in connected_channel_start_transport_op()
152 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in connected_channel_init_call_elem() local
155 chand->transport, TRANSPORT_STREAM_FROM_CALL_DATA(calld), in connected_channel_init_call_elem()
165 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in set_pollset_or_pollset_set() local
166 grpc_transport_set_pops(chand->transport, in set_pollset_or_pollset_set()
175 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in connected_channel_destroy_call_elem() local
176 grpc_transport_destroy_stream(chand->transport, in connected_channel_destroy_call_elem()
|
| /third_party/grpc/src/core/ext/filters/client_channel/ |
| D | service_config_channel_arg_filter.cc | 63 ServiceConfigChannelArgChannelData* chand = in ServiceConfigChannelArgCallData() local
65 RefCountedPtr<ServiceConfig> service_config = chand->service_config(); in ServiceConfigChannelArgCallData()
94 ServiceConfigChannelArgChannelData* chand = in ServiceConfigChannelArgInitChannelElem() local
96 new (chand) ServiceConfigChannelArgChannelData(args); in ServiceConfigChannelArgInitChannelElem()
101 ServiceConfigChannelArgChannelData* chand = in ServiceConfigChannelArgDestroyChannelElem() local
103 chand->~ServiceConfigChannelArgChannelData(); in ServiceConfigChannelArgDestroyChannelElem()
|
| D | client_channel.cc | 227 ExternalConnectivityWatcher(ChannelData* chand, grpc_polling_entity pollent,
235 static void RemoveWatcherFromExternalWatchersMap(ChannelData* chand,
261 explicit ResolverResultHandler(ChannelData* chand) : chand_(chand) { in ResolverResultHandler() argument
436 CallData(grpc_call_element* elem, const ChannelData& chand,
543 ChannelData* chand, const grpc_call_element_args& args,
910 ChannelData* chand, const grpc_call_element_args& args,
913 LoadBalancedCall(ChannelData* chand, const grpc_call_element_args& args,
1076 auto* chand = in Destroy() local
1078 chand->~DynamicTerminationFilterChannelData(); in Destroy()
1087 ChannelData* chand() const { return chand_; } in chand() function in grpc_core::__anonee6b702a0111::DynamicTerminationFilterChannelData
[all …]
|
| /third_party/grpc/src/core/lib/security/transport/ |
| D | client_auth_filter.cc | 69 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in call_data() local
82 chand->auth_context->Ref(DEBUG_LOCATION, "client_auth_filter"); in call_data()
240 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in send_security_metadata() local
245 chand->security_connector->mutable_request_metadata_creds(); in send_security_metadata()
276 chand->auth_context.get(), GRPC_TRANSPORT_SECURITY_LEVEL_PROPERTY_NAME); in send_security_metadata()
307 chand->security_connector->url_scheme(), calld->host, calld->method, in send_security_metadata()
308 chand->auth_context.get(), &calld->auth_md_context); in send_security_metadata()
354 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in cancel_check_call_host() local
356 chand->security_connector->cancel_check_call_host( in cancel_check_call_host()
367 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in client_auth_start_transport_stream_op_batch() local
[all …]
|
| D | server_auth_filter.cc | 63 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in call_data() local
65 chand->auth_context->Ref(DEBUG_LOCATION, "server_auth_filter"); in call_data()
213 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in recv_initial_metadata_ready() local
217 if (chand->creds != nullptr && in recv_initial_metadata_ready()
218 chand->creds->auth_metadata_processor().process != nullptr) { in recv_initial_metadata_ready()
227 chand->creds->auth_metadata_processor().process( in recv_initial_metadata_ready()
228 chand->creds->auth_metadata_processor().state, in recv_initial_metadata_ready()
229 chand->auth_context.get(), calld->md.metadata, calld->md.count, in recv_initial_metadata_ready()
312 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in server_auth_destroy_channel_elem() local
313 chand->~channel_data(); in server_auth_destroy_channel_elem()
|
| /third_party/grpc/src/core/ext/filters/load_reporting/ |
| D | server_load_reporting_filter.cc | 76 ServerLoadReportingChannelData* chand = in Destroy() local
97 {chand->peer_identity(), chand->peer_identity_len()}}, in Destroy()
240 ServerLoadReportingChannelData* chand = in RecvInitialMetadataReady() local
260 {chand->peer_identity(), chand->peer_identity_len()}}}); in RecvInitialMetadataReady()
280 ServerLoadReportingChannelData* chand = in SendTrailingMetadataFilter() local
304 {chand->peer_identity(), chand->peer_identity_len()}}, in SendTrailingMetadataFilter()
|
| /third_party/grpc/src/core/ext/filters/message_size/ |
| D | message_size_filter.cc | 144 call_data(grpc_call_element* elem, const channel_data& chand, in call_data()
146 : call_combiner(args.call_combiner), limits(chand.limits) { in call_data()
296 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in message_size_init_call_elem() local
297 new (elem->call_data) call_data(elem, *chand, *args); in message_size_init_call_elem()
321 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in message_size_init_channel_elem() local
322 new (chand) channel_data(); in message_size_init_channel_elem()
323 chand->limits = get_message_size_limits(args->channel_args); in message_size_init_channel_elem()
329 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in message_size_destroy_channel_elem() local
330 chand->~channel_data(); in message_size_destroy_channel_elem()
|
| /third_party/grpc/src/core/ext/filters/http/message_compress/ |
| D | message_decompress_filter.cc | 60 CallData(const grpc_call_element_args& args, const ChannelData* chand) in CallData() argument
62 max_recv_message_length_(chand->max_recv_size()) { in CallData()
361 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in DecompressInitCallElem() local
362 new (elem->call_data) CallData(*args, chand); in DecompressInitCallElem()
375 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in DecompressInitChannelElem() local
376 new (chand) ChannelData(args); in DecompressInitChannelElem()
381 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in DecompressDestroyChannelElem() local
382 chand->~ChannelData(); in DecompressDestroyChannelElem()
|
| /third_party/grpc/src/core/ext/xds/ |
| D | xds_client.cc | 89 explicit RetryableCall(RefCountedPtr<ChannelState> chand);
96 ChannelState* chand() const { return chand_.get(); } in chand() function in grpc_core::XdsClient::ChannelState::RetryableCall
132 ChannelState* chand() const { return parent_->chand(); } in chand() function in grpc_core::XdsClient::ChannelState::AdsCallState
133 XdsClient* xds_client() const { return chand()->xds_client(); } in xds_client()
317 ChannelState* chand() const { return parent_->chand(); } in chand() function in grpc_core::XdsClient::ChannelState::LrsCallState
318 XdsClient* xds_client() const { return chand()->xds_client(); } in xds_client()
570 RefCountedPtr<ChannelState> chand) in RetryableCall() argument
571 : chand_(std::move(chand)), in RetryableCall()
617 chand()->xds_client(), chand(), this); in StartNewCallLocked()
632 chand()->xds_client(), chand(), timeout); in StartRetryTimerLocked()
[all …]
|
| /third_party/grpc/src/core/ext/filters/client_channel/xds/ |
| D | xds_client.cc | 85 explicit RetryableCall(RefCountedPtr<ChannelState> chand);
92 ChannelState* chand() const { return chand_.get(); } in chand() function in grpc_core::XdsClient::ChannelState::RetryableCall
128 ChannelState* chand() const { return parent_->chand(); } in chand() function in grpc_core::XdsClient::ChannelState::AdsCallState
129 XdsClient* xds_client() const { return chand()->xds_client(); } in xds_client()
304 ChannelState* chand() const { return parent_->chand(); } in chand() function in grpc_core::XdsClient::ChannelState::LrsCallState
305 XdsClient* xds_client() const { return chand()->xds_client(); } in xds_client()
577 RefCountedPtr<ChannelState> chand) in RetryableCall() argument
578 : chand_(std::move(chand)), in RetryableCall()
624 chand()->xds_client(), chand(), this); in StartNewCallLocked()
639 chand()->xds_client(), chand(), timeout); in StartRetryTimerLocked()
[all …]
|
| /third_party/grpc/src/core/ext/filters/http/client/ |
| D | http_client_filter.cc | 566 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in http_client_init_channel_elem() local
569 chand->static_scheme = scheme_from_args(args->channel_args); in http_client_init_channel_elem()
570 chand->max_payload_size_for_get = in http_client_init_channel_elem()
572 chand->user_agent = grpc_mdelem_from_slices( in http_client_init_channel_elem()
581 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in http_client_destroy_channel_elem() local
582 GRPC_MDELEM_UNREF(chand->user_agent); in http_client_destroy_channel_elem()
|
| /third_party/grpc/src/core/ext/filters/http/server/ |
| D | http_server_filter.cc | 325 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in hs_filter_incoming_metadata() local
326 if (!chand->surface_user_agent && b->idx.named.user_agent != nullptr) { in hs_filter_incoming_metadata()
505 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in hs_init_channel_elem() local
507 chand->surface_user_agent = grpc_channel_arg_get_bool( in hs_init_channel_elem()
|