| /external/grpc-grpc/src/core/ext/filters/http/message_compress/ |
| D | message_compress_filter.cc | 52 struct call_data { struct
87 call_data* calld = static_cast<call_data*>(elem->call_data); in skip_compression()
110 call_data* calld = static_cast<call_data*>(elem->call_data); in process_send_initial_metadata()
202 call_data* calld = static_cast<call_data*>(elem->call_data); in send_message_on_complete()
209 call_data* calld = static_cast<call_data*>(elem->call_data); in send_message_batch_continue()
220 call_data* calld = static_cast<call_data*>(elem->call_data); in finish_send_message()
269 call_data* calld = static_cast<call_data*>(arg); in fail_send_message_batch_in_call_combiner()
278 static grpc_error* pull_slice_from_send_message(call_data* calld) { in pull_slice_from_send_message()
294 call_data* calld = static_cast<call_data*>(elem->call_data); in continue_reading_send_message()
315 call_data* calld = static_cast<call_data*>(elem->call_data); in on_send_message_next_done()
[all …]
|
| /external/grpc-grpc/src/core/lib/security/transport/ |
| D | server_auth_filter.cc | 38 struct call_data { struct
85 call_data* calld = static_cast<call_data*>(elem->call_data); in remove_consumed_md()
102 call_data* calld = static_cast<call_data*>(elem->call_data); in on_md_processing_done_inner()
127 call_data* calld = static_cast<call_data*>(elem->call_data); in on_md_processing_done()
155 call_data* calld = static_cast<call_data*>(elem->call_data); in cancel_call()
168 call_data* calld = static_cast<call_data*>(elem->call_data); in recv_initial_metadata_ready()
193 call_data* calld = static_cast<call_data*>(elem->call_data); in recv_trailing_metadata_ready()
200 call_data* calld = static_cast<call_data*>(elem->call_data); in auth_start_transport_stream_op_batch()
221 call_data* calld = static_cast<call_data*>(elem->call_data); in init_call_elem()
251 call_data* calld = static_cast<call_data*>(elem->call_data); in destroy_call_elem()
[all …]
|
| D | client_auth_filter.cc | 44 struct call_data { struct
101 call_data* calld = static_cast<call_data*>(elem->call_data); in on_credentials_metadata()
165 call_data* calld = static_cast<call_data*>(elem->call_data); in cancel_get_request_metadata()
174 call_data* calld = static_cast<call_data*>(elem->call_data); in send_security_metadata()
237 call_data* calld = static_cast<call_data*>(elem->call_data); in on_host_checked()
259 call_data* calld = static_cast<call_data*>(elem->call_data); in cancel_check_call_host()
273 call_data* calld = static_cast<call_data*>(elem->call_data); in auth_start_transport_stream_op_batch()
336 call_data* calld = static_cast<call_data*>(elem->call_data); in init_call_elem()
347 call_data* calld = static_cast<call_data*>(elem->call_data); in set_pollset_or_pollset_set()
355 call_data* calld = static_cast<call_data*>(elem->call_data); in destroy_call_elem()
[all …]
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/ |
| D | client_load_reporting_filter.cc | 39 struct call_data { struct
55 call_data* calld = static_cast<call_data*>(arg); in on_complete_for_send()
63 call_data* calld = static_cast<call_data*>(arg); in recv_initial_metadata_ready()
73 call_data* calld = static_cast<call_data*>(elem->call_data); in init_call_elem()
89 call_data* calld = static_cast<call_data*>(elem->call_data); in destroy_call_elem()
104 call_data* calld = static_cast<call_data*>(elem->call_data); in start_transport_stream_op_batch()
132 sizeof(call_data),
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/security/transport/ |
| D | server_auth_filter.cc | 50 struct call_data { struct
51 call_data(grpc_call_element* elem, const grpc_call_element_args& args) in call_data() function
75 ~call_data() { GRPC_ERROR_UNREF(recv_initial_metadata_error); } in ~call_data() argument
121 call_data* calld = static_cast<call_data*>(elem->call_data); in remove_consumed_md()
139 call_data* calld = static_cast<call_data*>(elem->call_data); in on_md_processing_done_inner()
172 call_data* calld = static_cast<call_data*>(elem->call_data); in on_md_processing_done()
201 call_data* calld = static_cast<call_data*>(elem->call_data); in cancel_call()
214 call_data* calld = static_cast<call_data*>(elem->call_data); in recv_initial_metadata_ready()
247 call_data* calld = static_cast<call_data*>(elem->call_data); in recv_trailing_metadata_ready()
264 call_data* calld = static_cast<call_data*>(elem->call_data); in server_auth_start_transport_stream_op_batch()
[all …]
|
| D | client_auth_filter.cc | 66 struct call_data { struct
67 call_data(grpc_call_element* elem, const grpc_call_element_args& args) in call_data() argument
163 call_data* calld = static_cast<call_data*>(elem->call_data); in on_credentials_metadata()
230 call_data* calld = static_cast<call_data*>(elem->call_data); in cancel_get_request_metadata()
239 call_data* calld = static_cast<call_data*>(elem->call_data); in send_security_metadata()
334 call_data* calld = static_cast<call_data*>(elem->call_data); in on_host_checked()
353 call_data* calld = static_cast<call_data*>(elem->call_data); in cancel_check_call_host()
366 call_data* calld = static_cast<call_data*>(elem->call_data); in client_auth_start_transport_stream_op_batch()
408 new (elem->call_data) call_data(elem, *args); in client_auth_init_call_elem()
414 call_data* calld = static_cast<call_data*>(elem->call_data); in client_auth_set_pollset_or_pollset_set()
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/channel/ |
| D | connected_channel.cc | 54 } call_data; typedef
67 static void intercept_callback(call_data* calld, callback_state* state, in intercept_callback()
80 call_data* calld, grpc_transport_stream_op_batch* batch) { in get_state_for_batch()
95 GPR_ROUND_UP_TO_ALIGNMENT_SIZE(sizeof(call_data))))
97 ((call_data*)(((char*)(transport_stream)) - \
98 GPR_ROUND_UP_TO_ALIGNMENT_SIZE(sizeof(call_data))))
104 call_data* calld = static_cast<call_data*>(elem->call_data); in connected_channel_start_transport_stream_op_batch()
151 call_data* calld = static_cast<call_data*>(elem->call_data); in connected_channel_init_call_elem()
164 call_data* calld = static_cast<call_data*>(elem->call_data); in set_pollset_or_pollset_set()
174 call_data* calld = static_cast<call_data*>(elem->call_data); in connected_channel_destroy_call_elem()
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/ |
| D | client_load_reporting_filter.cc | 42 struct call_data { struct
58 call_data* calld = static_cast<call_data*>(arg); in on_complete_for_send()
67 call_data* calld = static_cast<call_data*>(arg); in recv_initial_metadata_ready()
79 new (elem->call_data) call_data(); in clr_init_call_elem()
86 call_data* calld = static_cast<call_data*>(elem->call_data); in clr_destroy_call_elem()
94 calld->~call_data(); in clr_destroy_call_elem()
99 call_data* calld = static_cast<call_data*>(elem->call_data); in clr_start_transport_stream_op_batch()
149 sizeof(call_data),
|
| /external/grpc-grpc/src/core/lib/channel/ |
| D | connected_channel.cc | 55 } call_data; typedef
68 static void intercept_callback(call_data* calld, callback_state* state, in intercept_callback()
81 call_data* calld, grpc_transport_stream_op_batch* batch) { in get_state_for_batch()
96 (((call_data*)(transport_stream)) - 1)
102 call_data* calld = static_cast<call_data*>(elem->call_data); in con_start_transport_stream_op_batch()
149 call_data* calld = static_cast<call_data*>(elem->call_data); in init_call_elem()
162 call_data* calld = static_cast<call_data*>(elem->call_data); in set_pollset_or_pollset_set()
172 call_data* calld = static_cast<call_data*>(elem->call_data); in destroy_call_elem()
203 sizeof(call_data),
241 call_data* calld = static_cast<call_data*>(elem->call_data); in grpc_connected_channel_get_stream()
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/ |
| D | client_channel.cc | 993 } call_data; typedef
1011 static void maybe_cache_send_ops_for_batch(call_data* calld, in maybe_cache_send_ops_for_batch()
1059 call_data* calld) { in free_cached_send_initial_metadata()
1069 static void free_cached_send_message(channel_data* chand, call_data* calld, in free_cached_send_message()
1081 call_data* calld) { in free_cached_send_trailing_metadata()
1095 call_data* calld = static_cast<call_data*>(elem->call_data); in free_cached_send_op_data_after_commit()
1113 call_data* calld = static_cast<call_data*>(elem->call_data); in free_cached_send_op_data_for_completed_batch()
1147 call_data* calld = static_cast<call_data*>(elem->call_data); in pending_batches_add()
1204 static void pending_batch_clear(call_data* calld, pending_batch* pending) { in pending_batch_clear()
1223 call_data* calld = static_cast<call_data*>(batch->handler_private.extra_arg); in fail_pending_batch_in_call_combiner()
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/http/server/ |
| D | http_server_filter.cc | 44 struct call_data { struct
45 call_data(grpc_call_element* elem, const grpc_call_element_args& args) in call_data() function
57 ~call_data() { in ~call_data() argument
154 call_data* calld = static_cast<call_data*>(elem->call_data); in hs_filter_incoming_metadata()
335 call_data* calld = static_cast<call_data*>(elem->call_data); in hs_recv_initial_metadata_ready()
372 call_data* calld = static_cast<call_data*>(elem->call_data); in hs_recv_message_ready()
397 call_data* calld = static_cast<call_data*>(elem->call_data); in hs_recv_trailing_metadata_ready()
416 call_data* calld = static_cast<call_data*>(elem->call_data); in hs_mutate_op()
477 call_data* calld = static_cast<call_data*>(elem->call_data); in hs_start_transport_stream_op_batch()
490 new (elem->call_data) call_data(elem, *args); in hs_init_call_elem()
[all …]
|
| /external/grpc-grpc/src/core/ext/filters/http/server/ |
| D | http_server_filter.cc | 40 struct call_data { struct
103 call_data* calld = static_cast<call_data*>(elem->call_data); in hs_filter_incoming_metadata()
280 call_data* calld = static_cast<call_data*>(elem->call_data); in hs_recv_initial_metadata_ready()
309 call_data* calld = static_cast<call_data*>(elem->call_data); in hs_recv_message_ready()
333 call_data* calld = static_cast<call_data*>(elem->call_data); in hs_recv_trailing_metadata_ready()
343 call_data* calld = static_cast<call_data*>(elem->call_data); in hs_mutate_op()
403 call_data* calld = static_cast<call_data*>(elem->call_data); in hs_start_transport_stream_op_batch()
416 call_data* calld = static_cast<call_data*>(elem->call_data); in hs_init_call_elem()
433 call_data* calld = static_cast<call_data*>(elem->call_data); in hs_destroy_call_elem()
458 sizeof(call_data),
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/http/client/ |
| D | http_client_filter.cc | 57 struct call_data { struct
58 call_data(grpc_call_element* elem, const grpc_call_element_args& args) in call_data() argument
72 ~call_data() { GRPC_ERROR_UNREF(recv_initial_metadata_error); } in ~call_data() argument
187 call_data* calld = static_cast<call_data*>(elem->call_data); in recv_initial_metadata_ready()
206 call_data* calld = static_cast<call_data*>(elem->call_data); in recv_trailing_metadata_ready()
228 call_data* calld = static_cast<call_data*>(elem->call_data); in send_message_on_complete()
237 static grpc_error* pull_slice_from_send_message(call_data* calld) { in pull_slice_from_send_message()
252 static grpc_error* read_all_available_send_message_data(call_data* calld) { in read_all_available_send_message_data()
268 call_data* calld = static_cast<call_data*>(elem->call_data); in on_send_message_next_done()
306 call_data* calld = static_cast<call_data*>(elem->call_data); in update_path_for_get()
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/message_size/ |
| D | message_size_filter.cc | 143 struct call_data { struct
144 call_data(grpc_call_element* elem, const channel_data& chand, in call_data() function
172 ~call_data() { GRPC_ERROR_UNREF(error); } in ~call_data() argument
199 call_data* calld = static_cast<call_data*>(elem->call_data); in recv_message_ready()
238 call_data* calld = static_cast<call_data*>(elem->call_data); in recv_trailing_metadata_ready()
257 call_data* calld = static_cast<call_data*>(elem->call_data); in message_size_start_transport_stream_op_batch()
297 new (elem->call_data) call_data(elem, *chand, *args); in message_size_init_call_elem()
305 call_data* calld = static_cast<call_data*>(elem->call_data); in message_size_destroy_call_elem()
306 calld->~call_data(); in message_size_destroy_call_elem()
336 sizeof(call_data),
|
| /external/grpc-grpc/src/core/ext/filters/workarounds/ |
| D | workaround_cronet_compression_filter.cc | 31 struct call_data { struct
59 call_data* calld = static_cast<call_data*>(elem->call_data); in recv_initial_metadata_ready()
80 call_data* calld = static_cast<call_data*>(elem->call_data); in start_transport_stream_op_batch()
109 call_data* calld = static_cast<call_data*>(elem->call_data); in init_call_elem()
174 sizeof(call_data),
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/workarounds/ |
| D | workaround_cronet_compression_filter.cc | 31 struct call_data { struct
59 call_data* calld = static_cast<call_data*>(elem->call_data); in recv_initial_metadata_ready()
81 call_data* calld = static_cast<call_data*>(elem->call_data); in cronet_compression_start_transport_stream_op_batch()
110 call_data* calld = static_cast<call_data*>(elem->call_data); in cronet_compression_init_call_elem()
176 sizeof(call_data),
|
| /external/grpc-grpc/src/core/ext/filters/http/client/ |
| D | http_client_filter.cc | 43 struct call_data { struct
153 call_data* calld = static_cast<call_data*>(elem->call_data); in recv_initial_metadata_ready()
165 call_data* calld = static_cast<call_data*>(elem->call_data); in recv_trailing_metadata_ready()
179 call_data* calld = static_cast<call_data*>(elem->call_data); in send_message_on_complete()
187 static grpc_error* pull_slice_from_send_message(call_data* calld) { in pull_slice_from_send_message()
202 static grpc_error* read_all_available_send_message_data(call_data* calld) { in read_all_available_send_message_data()
218 call_data* calld = static_cast<call_data*>(elem->call_data); in on_send_message_next_done()
256 call_data* calld = static_cast<call_data*>(elem->call_data); in update_path_for_get()
305 call_data* calld = static_cast<call_data*>(elem->call_data); in hc_start_transport_stream_op_batch()
428 call_data* calld = static_cast<call_data*>(elem->call_data); in init_call_elem()
[all …]
|
| /external/grpc-grpc/src/core/ext/filters/message_size/ |
| D | message_size_filter.cc | 95 struct call_data { struct
127 call_data* calld = static_cast<call_data*>(elem->call_data); in recv_message_ready()
157 call_data* calld = static_cast<call_data*>(elem->call_data); in recv_trailing_metadata_ready()
167 call_data* calld = static_cast<call_data*>(elem->call_data); in start_transport_stream_op_batch()
207 call_data* calld = static_cast<call_data*>(elem->call_data); in init_call_elem()
246 call_data* calld = (call_data*)elem->call_data; in destroy_call_elem()
312 sizeof(call_data),
|
| /external/grpc-grpc/src/core/ext/filters/http/ |
| D | client_authority_filter.cc | 41 struct call_data { struct
53 call_data* calld = static_cast<call_data*>(elem->call_data); in authority_start_transport_stream_op_batch()
78 call_data* calld = static_cast<call_data*>(elem->call_data); in init_call_elem()
121 sizeof(call_data),
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/http/ |
| D | client_authority_filter.cc | 41 struct call_data { struct
54 call_data* calld = static_cast<call_data*>(elem->call_data); in client_authority_start_transport_stream_op_batch()
77 call_data* calld = static_cast<call_data*>(elem->call_data); in client_authority_init_call_elem()
123 sizeof(call_data),
|
| /external/rust/crates/grpcio-sys/grpc/src/cpp/common/ |
| D | channel_filter.h | 325 CallDataType* call_data = new (elem->call_data) CallDataType(); in InitCallElement() local
326 return call_data->Init(elem, args); in InitCallElement()
332 CallDataType* call_data = static_cast<CallDataType*>(elem->call_data); in DestroyCallElement() local
333 call_data->Destroy(elem, final_info, then_call_closure); in DestroyCallElement()
334 call_data->~CallDataType(); in DestroyCallElement()
339 CallDataType* call_data = static_cast<CallDataType*>(elem->call_data); in StartTransportStreamOpBatch() local
341 call_data->StartTransportStreamOpBatch(elem, &op_wrapper); in StartTransportStreamOpBatch()
346 CallDataType* call_data = static_cast<CallDataType*>(elem->call_data); in SetPollsetOrPollsetSet() local
347 call_data->SetPollsetOrPollsetSet(elem, pollent); in SetPollsetOrPollsetSet()
|
| /external/grpc-grpc/src/cpp/common/ |
| D | channel_filter.h | 325 CallDataType* call_data = new (elem->call_data) CallDataType(); in InitCallElement() local
326 return call_data->Init(elem, args); in InitCallElement()
332 CallDataType* call_data = static_cast<CallDataType*>(elem->call_data); in DestroyCallElement() local
333 call_data->Destroy(elem, final_info, then_call_closure); in DestroyCallElement()
334 call_data->~CallDataType(); in DestroyCallElement()
339 CallDataType* call_data = static_cast<CallDataType*>(elem->call_data); in StartTransportStreamOpBatch() local
341 call_data->StartTransportStreamOpBatch(elem, &op_wrapper); in StartTransportStreamOpBatch()
346 CallDataType* call_data = static_cast<CallDataType*>(elem->call_data); in SetPollsetOrPollsetSet() local
347 call_data->SetPollsetOrPollsetSet(elem, pollent); in SetPollsetOrPollsetSet()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/deadline/ |
| D | deadline_filter.cc | 43 static_cast<grpc_deadline_state*>(elem_->call_data); in TimerState()
57 static_cast<grpc_deadline_state*>(self->elem_->call_data); in YieldCallCombiner()
78 static_cast<grpc_deadline_state*>(self->elem_->call_data); in TimerCallback()
121 static_cast<grpc_deadline_state*>(elem->call_data); in start_timer_if_needed()
175 static_cast<grpc_deadline_state*>(state->elem->call_data); in start_timer_after_init()
219 static_cast<grpc_deadline_state*>(elem->call_data); in grpc_deadline_state_reset()
227 static_cast<grpc_deadline_state*>(elem->call_data); in grpc_deadline_state_client_start_transport_stream_op_batch()
273 new (elem->call_data) grpc_deadline_state(elem, *args, args->deadline); in deadline_init_call_elem()
282 static_cast<grpc_deadline_state*>(elem->call_data); in deadline_destroy_call_elem()
297 server_call_data* calld = static_cast<server_call_data*>(elem->call_data); in recv_initial_metadata_ready()
[all …]
|
| /external/grpc-grpc/src/core/ext/filters/deadline/ |
| D | deadline_filter.cc | 52 static_cast<grpc_deadline_state*>(elem->call_data); in send_cancel_op_in_call_combiner()
65 static_cast<grpc_deadline_state*>(elem->call_data); in timer_callback()
92 static_cast<grpc_deadline_state*>(elem->call_data); in start_timer_if_needed()
164 static_cast<grpc_deadline_state*>(state->elem->call_data); in start_timer_after_init()
185 static_cast<grpc_deadline_state*>(elem->call_data); in grpc_deadline_state_init()
211 static_cast<grpc_deadline_state*>(elem->call_data); in grpc_deadline_state_destroy()
218 static_cast<grpc_deadline_state*>(elem->call_data); in grpc_deadline_state_reset()
226 static_cast<grpc_deadline_state*>(elem->call_data); in grpc_deadline_state_client_start_transport_stream_op_batch()
295 server_call_data* calld = static_cast<server_call_data*>(elem->call_data); in recv_initial_metadata_ready()
305 server_call_data* calld = static_cast<server_call_data*>(elem->call_data); in server_start_transport_stream_op_batch()
|
| /external/grpc-grpc/src/core/lib/surface/ |
| D | server.cc | 128 struct call_data { struct
158 call_data* pending_next; argument
163 call_data* pending_head;
164 call_data* pending_tail;
337 call_data* calld = rm->pending_head; in request_matcher_zombify_all_pending_calls()
448 static void publish_call(grpc_server* server, call_data* calld, size_t cq_idx, in publish_call()
483 call_data* calld = static_cast<call_data*>(call_elem->call_data); in publish_new_rpc()
549 call_data* calld = static_cast<call_data*>(elem->call_data); in finish_start_new_rpc()
580 call_data* calld = static_cast<call_data*>(elem->call_data); in start_new_rpc()
703 call_data* calld = static_cast<call_data*>(elem->call_data); in server_on_recv_initial_metadata()
[all …]
|