| /external/grpc-grpc/src/core/ext/filters/max_age/ |
| D | max_age_filter.cc | 153 static void increase_call_count(channel_data* chand) { in increase_call_count() argument
155 if (gpr_atm_full_fetch_add(&chand->call_count, 1) == 0) { in increase_call_count()
157 gpr_atm idle_state = gpr_atm_acq_load(&chand->idle_state); in increase_call_count()
163 gpr_atm_rel_cas(&chand->idle_state, MAX_IDLE_STATE_TIMER_SET, in increase_call_count()
167 gpr_atm_rel_store(&chand->idle_state, MAX_IDLE_STATE_SEEN_EXIT_IDLE); in increase_call_count()
179 static void decrease_call_count(channel_data* chand) { in decrease_call_count() argument
181 if (gpr_atm_full_fetch_add(&chand->call_count, -1) == 1) { in decrease_call_count()
182 gpr_atm_no_barrier_store(&chand->last_enter_idle_time_millis, in decrease_call_count()
185 gpr_atm idle_state = gpr_atm_acq_load(&chand->idle_state); in decrease_call_count()
188 GRPC_CHANNEL_STACK_REF(chand->channel_stack, in decrease_call_count()
[all …]
|
| /external/rust/crates/grpcio-sys/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 …]
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/ |
| D | client_channel.cc | 135 channel_data* chand; member
146 channel_data* chand; member
152 static void watch_lb_policy_locked(channel_data* chand,
156 static void set_channel_connectivity_state_locked(channel_data* chand, in set_channel_connectivity_state_locked() argument
164 if (chand->lb_policy != nullptr) { in set_channel_connectivity_state_locked()
167 chand->lb_policy->CancelMatchingPicksLocked( in set_channel_connectivity_state_locked()
172 chand->lb_policy->CancelMatchingPicksLocked(/* mask= */ 0, /* check= */ 0, in set_channel_connectivity_state_locked()
177 gpr_log(GPR_INFO, "chand=%p: setting connectivity state to %s", chand, in set_channel_connectivity_state_locked()
180 grpc_connectivity_state_set(&chand->state_tracker, state, error, reason); in set_channel_connectivity_state_locked()
187 if (w->lb_policy == w->chand->lb_policy.get()) { in on_lb_policy_state_changed_locked()
[all …]
|
| /external/rust/crates/grpcio-sys/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 …]
|
| /external/grpc-grpc/src/core/lib/surface/ |
| D | server.cc | 404 static int is_channel_orphaned(channel_data* chand) { in is_channel_orphaned() argument
405 return chand->next == chand; in is_channel_orphaned()
408 static void orphan_channel(channel_data* chand) { in orphan_channel() argument
409 chand->next->prev = chand->prev; in orphan_channel()
410 chand->prev->next = chand->next; in orphan_channel()
411 chand->next = chand->prev = chand; in orphan_channel()
415 channel_data* chand = static_cast<channel_data*>(cd); in finish_destroy_channel() local
416 grpc_server* server = chand->server; in finish_destroy_channel()
417 GRPC_CHANNEL_INTERNAL_UNREF(chand->channel, "server"); in finish_destroy_channel()
421 static void destroy_channel(channel_data* chand, grpc_error* error) { in destroy_channel() argument
[all …]
|
| D | lame_client.cc | 62 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in fill_metadata() local
64 gpr_ltoa(chand->error_code, tmp); in fill_metadata()
69 grpc_slice_from_copied_string(chand->error_message)); in fill_metadata()
175 auto chand = static_cast<grpc_core::ChannelData*>(elem->channel_data); in grpc_lame_client_channel_create() local
176 chand->error_code = error_code; in grpc_lame_client_channel_create()
177 chand->error_message = error_message; in grpc_lame_client_channel_create()
|
| /external/rust/crates/grpcio-sys/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()
|
| /external/rust/crates/grpcio-sys/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 …]
|
| /external/grpc-grpc/src/core/lib/security/transport/ |
| D | server_auth_filter.cc | 167 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in recv_initial_metadata_ready() local
171 if (chand->creds != nullptr && chand->creds->processor.process != nullptr) { in recv_initial_metadata_ready()
181 chand->creds->processor.process( in recv_initial_metadata_ready()
182 chand->creds->processor.state, chand->auth_context, in recv_initial_metadata_ready()
222 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in init_call_elem() local
236 GRPC_AUTH_CONTEXT_REF(chand->auth_context, "server_auth_filter"); in init_call_elem()
259 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in init_channel_elem() local
263 chand->auth_context = in init_channel_elem()
267 chand->creds = grpc_server_credentials_ref(creds); in init_channel_elem()
273 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in destroy_channel_elem() local
[all …]
|
| D | client_auth_filter.cc | 175 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in send_security_metadata() local
180 chand->security_connector->request_metadata_creds; in send_security_metadata()
208 chand->security_connector->base.url_scheme, calld->host, calld->method, in send_security_metadata()
209 chand->auth_context, &calld->auth_md_context); in send_security_metadata()
260 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in cancel_check_call_host() local
263 chand->security_connector, &calld->async_result_closure, in cancel_check_call_host()
274 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in auth_start_transport_stream_op_batch() local
291 GRPC_AUTH_CONTEXT_REF(chand->auth_context, "client_auth_filter"); in auth_start_transport_stream_op_batch()
311 chand->security_connector, call_host, chand->auth_context, in auth_start_transport_stream_op_batch()
380 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in init_channel_elem() local
[all …]
|
| /external/grpc-grpc/src/core/lib/channel/ |
| D | connected_channel.cc | 103 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in con_start_transport_stream_op_batch() local
136 chand->transport, TRANSPORT_STREAM_FROM_CALL_DATA(calld), batch); in con_start_transport_stream_op_batch()
142 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in con_start_transport_op() local
143 grpc_transport_perform_op(chand->transport, op); in con_start_transport_op()
150 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in init_call_elem() local
153 chand->transport, TRANSPORT_STREAM_FROM_CALL_DATA(calld), in init_call_elem()
163 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in set_pollset_or_pollset_set() local
164 grpc_transport_set_pops(chand->transport, in set_pollset_or_pollset_set()
173 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in destroy_call_elem() local
174 grpc_transport_destroy_stream(chand->transport, in destroy_call_elem()
|
| /external/rust/crates/grpcio-sys/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()
|
| /external/grpc-grpc/src/core/ext/filters/http/ |
| D | client_authority_filter.cc | 52 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in authority_start_transport_stream_op_batch() local
64 grpc_slice_ref_internal(chand->default_authority))); in authority_start_transport_stream_op_batch()
91 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in init_channel_elem() local
105 chand->default_authority = in init_channel_elem()
113 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in destroy_channel_elem() local
114 grpc_slice_unref_internal(chand->default_authority); in destroy_channel_elem()
|
| /external/rust/crates/grpcio-sys/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::__anon5e2240680111::DynamicTerminationFilterChannelData
[all …]
|
| /external/rust/crates/grpcio-sys/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()
|
| /external/grpc-grpc/src/core/ext/filters/message_size/ |
| D | message_size_filter.cc | 206 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in init_call_elem() local
221 calld->limits = chand->limits; in init_call_elem()
222 if (chand->method_limit_table != nullptr) { in init_call_elem()
225 *chand->method_limit_table, args->path); in init_call_elem()
286 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in init_channel_elem() local
287 chand->limits = get_message_size_limits(args->channel_args); in init_channel_elem()
296 chand->method_limit_table = service_config->CreateMethodConfigTable( in init_channel_elem()
305 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in destroy_channel_elem() local
306 chand->method_limit_table.reset(); in destroy_channel_elem()
|
| /external/grpc-grpc/src/core/ext/filters/load_reporting/ |
| D | server_load_reporting_filter.cc | 70 ServerLoadReportingChannelData* chand = in Destroy() local
91 {chand->peer_identity(), chand->peer_identity_len()}}, in Destroy()
244 ServerLoadReportingChannelData* chand = in RecvInitialMetadataReady() local
264 {chand->peer_identity(), chand->peer_identity_len()}}}); in RecvInitialMetadataReady()
283 ServerLoadReportingChannelData* chand = in SendTrailingMetadataFilter() local
307 {chand->peer_identity(), chand->peer_identity_len()}}, in SendTrailingMetadataFilter()
|
| /external/rust/crates/grpcio-sys/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()
|
| /external/rust/crates/grpcio-sys/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()
|
| /external/rust/crates/grpcio-sys/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()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/xds/ |
| D | xds_client.cc | 88 explicit RetryableCall(RefCountedPtr<ChannelState> chand);
95 ChannelState* chand() const { return chand_.get(); } in chand() function in grpc_core::XdsClient::ChannelState::RetryableCall
131 ChannelState* chand() const { return parent_->chand(); } in chand() function in grpc_core::XdsClient::ChannelState::AdsCallState
132 XdsClient* xds_client() const { return chand()->xds_client(); } in xds_client()
316 ChannelState* chand() const { return parent_->chand(); } in chand() function in grpc_core::XdsClient::ChannelState::LrsCallState
317 XdsClient* xds_client() const { return chand()->xds_client(); } in xds_client()
569 RefCountedPtr<ChannelState> chand) in RetryableCall() argument
570 : chand_(std::move(chand)), in RetryableCall()
616 chand()->xds_client(), chand(), this); in StartNewCallLocked()
631 chand()->xds_client(), chand(), timeout); in StartRetryTimerLocked()
[all …]
|
| /external/rust/crates/grpcio-sys/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()
|