Home
last modified time | relevance | path

Searched refs:channel_data (Results 1 – 25 of 48) sorted by relevance

12

/external/grpc-grpc/src/core/lib/channel/
Dconnected_channel.cc39 } channel_data; typedef
103 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in con_start_transport_stream_op_batch()
142 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in con_start_transport_op()
150 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in init_call_elem()
163 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in set_pollset_or_pollset_set()
173 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in destroy_call_elem()
182 channel_data* cd = static_cast<channel_data*>(elem->channel_data); in init_channel_elem()
190 channel_data* cd = static_cast<channel_data*>(elem->channel_data); in destroy_channel_elem()
207 sizeof(channel_data),
216 channel_data* cd = static_cast<channel_data*>(elem->channel_data); in bind_transport()
/external/rust/crates/grpcio-sys/grpc/src/core/lib/channel/
Dconnected_channel.cc39 } channel_data; typedef
105 channel_data* chand = static_cast<channel_data*>(elem->channel_data); 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()
152 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in connected_channel_init_call_elem()
165 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in set_pollset_or_pollset_set()
175 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in connected_channel_destroy_call_elem()
184 channel_data* cd = static_cast<channel_data*>(elem->channel_data); in connected_channel_init_channel_elem()
192 channel_data* cd = static_cast<channel_data*>(elem->channel_data); in connected_channel_destroy_channel_elem()
210 sizeof(channel_data),
219 channel_data* cd = static_cast<channel_data*>(elem->channel_data); in bind_transport()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/max_age/
Dmax_age_filter.cc52 struct channel_data { struct
152 static void increase_call_count(channel_data* chand) { in increase_call_count()
178 static void decrease_call_count(channel_data* chand) { in decrease_call_count()
210 channel_data* chand = static_cast<channel_data*>(arg); in start_max_idle_timer_after_init()
223 explicit ConnectivityWatcher(channel_data* chand) : chand_(chand) { in ConnectivityWatcher()
256 channel_data* chand_;
262 channel_data* chand = static_cast<channel_data*>(arg); in start_max_age_timer_after_init()
280 channel_data* chand = static_cast<channel_data*>(arg); in start_max_age_grace_timer_after_goaway_op()
295 static void close_max_idle_channel(channel_data* chand) { in close_max_idle_channel()
308 channel_data* chand = static_cast<channel_data*>(arg); in max_idle_timer_cb()
[all …]
/external/grpc-grpc/src/core/ext/filters/max_age/
Dmax_age_filter.cc49 struct channel_data { struct
153 static void increase_call_count(channel_data* chand) { in increase_call_count()
179 static void decrease_call_count(channel_data* chand) { in decrease_call_count()
211 channel_data* chand = static_cast<channel_data*>(arg); in start_max_idle_timer_after_init()
221 channel_data* chand = static_cast<channel_data*>(arg); in start_max_age_timer_after_init()
239 channel_data* chand = static_cast<channel_data*>(arg); in start_max_age_grace_timer_after_goaway_op()
254 static void close_max_idle_channel(channel_data* chand) { in close_max_idle_channel()
267 channel_data* chand = static_cast<channel_data*>(arg); in max_idle_timer_cb()
311 channel_data* chand = static_cast<channel_data*>(arg); in close_max_age_channel()
333 channel_data* chand = static_cast<channel_data*>(arg); in force_close_max_age_channel()
[all …]
/external/grpc-grpc/src/core/ext/filters/http/
Dclient_authority_filter.cc46 struct channel_data { struct
52 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in authority_start_transport_stream_op_batch()
91 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in init_channel_elem()
113 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in destroy_channel_elem()
125 sizeof(channel_data),
/external/grpc-grpc/src/core/ext/filters/client_channel/
Dclient_channel.cc132 } channel_data; typedef
135 channel_data* chand;
146 channel_data* chand;
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()
202 static void watch_lb_policy_locked(channel_data* chand, in watch_lb_policy_locked()
216 static void start_resolving_locked(channel_data* chand) { in start_resolving_locked()
289 static void on_resolver_shutdown_locked(channel_data* chand, in on_resolver_shutdown_locked()
330 get_lb_policy_name_from_resolver_result_locked(channel_data* chand) { in get_lb_policy_name_from_resolver_result_locked()
362 channel_data* chand = args->chand; in request_reresolution_locked()
[all …]
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/http/
Dclient_authority_filter.cc46 struct channel_data { struct
53 channel_data* chand = static_cast<channel_data*>(elem->channel_data); 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()
114 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in client_authority_destroy_channel_elem()
127 sizeof(channel_data),
/external/grpc-grpc/test/core/channel/
Dchannel_stack_test.cc38 *static_cast<int*>(elem->channel_data) = 0; in channel_init_func()
44 ++*static_cast<int*>(elem->channel_data); in call_init_func()
54 ++*static_cast<int*>(elem->channel_data); in call_destroy_func()
63 ++*static_cast<int*>(elem->channel_data); in channel_func()
96 int* channel_data; in test_create_channel_stack() local
114 channel_data = static_cast<int*>(channel_elem->channel_data); in test_create_channel_stack()
115 GPR_ASSERT(*channel_data == 0); in test_create_channel_stack()
135 GPR_ASSERT(call_elem->channel_data == channel_elem->channel_data); in test_create_channel_stack()
138 GPR_ASSERT(*channel_data == 1); in test_create_channel_stack()
142 GPR_ASSERT(*channel_data == 2); in test_create_channel_stack()
/external/rust/crates/grpcio-sys/grpc/src/core/lib/security/transport/
Dclient_auth_filter.cc50 struct channel_data { struct
51 channel_data(grpc_channel_security_connector* security_connector, in channel_data() function
56 ~channel_data() { in ~channel_data() argument
69 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in call_data()
240 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in send_security_metadata()
354 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in cancel_check_call_host()
367 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in client_auth_start_transport_stream_op_batch()
445 new (elem->channel_data) channel_data( in client_auth_init_channel_elem()
452 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in client_auth_destroy_channel_elem()
453 chand->~channel_data(); in client_auth_destroy_channel_elem()
[all …]
Dserver_auth_filter.cc41 struct channel_data { struct
42 channel_data(grpc_auth_context* auth_context, grpc_server_credentials* creds) in channel_data() argument
44 ~channel_data() { auth_context.reset(DEBUG_LOCATION, "server_auth_filter"); } in ~channel_data() argument
63 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in call_data()
213 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in recv_initial_metadata_ready()
306 new (elem->channel_data) channel_data(auth_context, creds); in server_auth_init_channel_elem()
312 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in server_auth_destroy_channel_elem()
313 chand->~channel_data(); in server_auth_destroy_channel_elem()
323 sizeof(channel_data),
/external/grpc-grpc/src/core/lib/security/transport/
Dserver_auth_filter.cc54 struct channel_data { struct
167 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in recv_initial_metadata_ready()
222 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in init_call_elem()
259 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in init_channel_elem()
273 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in destroy_channel_elem()
285 sizeof(channel_data),
Dclient_auth_filter.cc65 struct channel_data { struct
175 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in send_security_metadata()
260 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in cancel_check_call_host()
274 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in auth_start_transport_stream_op_batch()
380 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in init_channel_elem()
399 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in destroy_channel_elem()
414 sizeof(channel_data),
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/message_size/
Dmessage_size_filter.cc139 struct channel_data { struct
144 call_data(grpc_call_element* elem, const channel_data& chand, in call_data()
296 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in message_size_init_call_elem()
321 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in message_size_init_channel_elem()
322 new (chand) channel_data(); in message_size_init_channel_elem()
329 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in message_size_destroy_channel_elem()
330 chand->~channel_data(); in message_size_destroy_channel_elem()
340 sizeof(channel_data),
/external/rust/crates/grpcio-sys/grpc/src/cpp/common/
Dchannel_filter.h294 ChannelDataType* channel_data = new (elem->channel_data) ChannelDataType(); in InitChannelElement() local
295 return channel_data->Init(elem, args); in InitChannelElement()
299 ChannelDataType* channel_data = in DestroyChannelElement() local
300 static_cast<ChannelDataType*>(elem->channel_data); in DestroyChannelElement()
301 channel_data->Destroy(elem); in DestroyChannelElement()
302 channel_data->~ChannelDataType(); in DestroyChannelElement()
307 ChannelDataType* channel_data = in StartTransportOp() local
308 static_cast<ChannelDataType*>(elem->channel_data); in StartTransportOp()
310 channel_data->StartTransportOp(elem, &op_wrapper); in StartTransportOp()
315 ChannelDataType* channel_data = in GetChannelInfo() local
[all …]
/external/grpc-grpc/src/cpp/common/
Dchannel_filter.h294 ChannelDataType* channel_data = new (elem->channel_data) ChannelDataType(); in InitChannelElement() local
295 return channel_data->Init(elem, args); in InitChannelElement()
299 ChannelDataType* channel_data = in DestroyChannelElement() local
300 static_cast<ChannelDataType*>(elem->channel_data); in DestroyChannelElement()
301 channel_data->Destroy(elem); in DestroyChannelElement()
302 channel_data->~ChannelDataType(); in DestroyChannelElement()
307 ChannelDataType* channel_data = in StartTransportOp() local
308 static_cast<ChannelDataType*>(elem->channel_data); in StartTransportOp()
310 channel_data->StartTransportOp(elem, &op_wrapper); in StartTransportOp()
315 ChannelDataType* channel_data = in GetChannelInfo() local
[all …]
/external/grpc-grpc/src/core/ext/filters/message_size/
Dmessage_size_filter.cc113 struct channel_data { struct
206 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in init_call_elem()
286 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in init_channel_elem()
305 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in destroy_channel_elem()
316 sizeof(channel_data),
/external/grpc-grpc/src/core/lib/surface/
Dserver.cc94 struct channel_data { struct
100 channel_data* next; argument
101 channel_data* prev; argument
217 channel_data root_channel_data;
230 (((channel_data*)(elem)->channel_data)->server)
245 channel_data* c; in channel_broadcaster_init()
404 static int is_channel_orphaned(channel_data* chand) { in is_channel_orphaned()
408 static void orphan_channel(channel_data* chand) { in orphan_channel()
415 channel_data* chand = static_cast<channel_data*>(cd); in finish_destroy_channel()
421 static void destroy_channel(channel_data* chand, grpc_error* error) { in destroy_channel()
[all …]
/external/grpc-grpc/src/core/ext/filters/http/message_compress/
Dmessage_compress_filter.cc73 struct channel_data { struct
88 channel_data* channeld = static_cast<channel_data*>(elem->channel_data); in skip_compression()
111 channel_data* channeld = static_cast<channel_data*>(elem->channel_data); in process_send_initial_metadata()
452 channel_data* channeld = static_cast<channel_data*>(elem->channel_data); in init_channel_elem()
495 sizeof(channel_data),
/external/rust/crates/grpcio-sys/grpc/src/core/lib/surface/
Dlame_client.cc58 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in lame_start_transport_stream_op_batch()
68 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in lame_start_transport_op()
110 new (elem->channel_data) ChannelData; in lame_init_channel_elem()
115 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in lame_destroy_channel_elem()
123 auto chand = static_cast<grpc_core::ChannelData*>(elem->channel_data); in SetLameFilterError()
/external/webrtc/modules/audio_processing/
Dhigh_pass_filter.cc72 rtc::ArrayView<float> channel_data = rtc::ArrayView<float>( in Process() local
74 filters_[k]->Process(channel_data); in Process()
78 rtc::ArrayView<float> channel_data = in Process() local
80 filters_[k]->Process(channel_data); in Process()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/http/client/
Dhttp_client_filter.cc104 struct channel_data { struct
356 channel_data* channeld = static_cast<channel_data*>(elem->channel_data); in http_client_start_transport_stream_op_batch()
566 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in http_client_init_channel_elem()
581 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in http_client_destroy_channel_elem()
592 sizeof(channel_data),
/external/grpc-grpc/src/core/ext/filters/http/client/
Dhttp_client_filter.cc72 struct channel_data { struct
306 channel_data* channeld = static_cast<channel_data*>(elem->channel_data); in hc_start_transport_stream_op_batch()
541 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in init_channel_elem()
556 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in destroy_channel_elem()
567 sizeof(channel_data),
/external/grpc-grpc/src/core/ext/filters/http/server/
Dhttp_server_filter.cc70 struct channel_data { struct
270 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in hs_filter_incoming_metadata()
443 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in hs_init_channel_elem()
462 sizeof(channel_data),
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/
Dservice_config_channel_arg_filter.cc64 static_cast<ServiceConfigChannelArgChannelData*>(elem->channel_data); in ServiceConfigChannelArgCallData()
95 static_cast<ServiceConfigChannelArgChannelData*>(elem->channel_data); in ServiceConfigChannelArgInitChannelElem()
102 static_cast<ServiceConfigChannelArgChannelData*>(elem->channel_data); in ServiceConfigChannelArgDestroyChannelElem()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_idle/
Dclient_idle_filter.cc176 new (elem->channel_data) ChannelData(elem, args, &error); in Init()
181 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in Destroy()
187 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in StartTransportOp()
393 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in Init()
401 ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); in Destroy()

12