| /external/rust/crates/grpcio-sys/grpc/src/core/lib/channel/ |
| D | channel_stack.h | 63 typedef struct grpc_call_element grpc_call_element; typedef
110 void (*start_transport_stream_op_batch)(grpc_call_element* elem,
128 grpc_error* (*init_call_elem)(grpc_call_element* elem,
130 void (*set_pollset_or_pollset_set)(grpc_call_element* elem,
138 void (*destroy_call_elem)(grpc_call_element* elem,
174 struct grpc_call_element { struct
208 grpc_call_element* grpc_call_stack_element(grpc_call_stack* stack, size_t i);
274 grpc_call_element* elem, grpc_polling_entity* pollent);
276 void grpc_call_next_op(grpc_call_element* elem,
289 grpc_call_stack* grpc_call_stack_from_top_element(grpc_call_element* elem);
[all …]
|
| D | channel_stack.cc | 71 ((grpc_call_element*)((char*)(stk) + GPR_ROUND_UP_TO_ALIGNMENT_SIZE( \
84 grpc_call_element* grpc_call_stack_element(grpc_call_stack* call_stack, in grpc_call_stack_element()
96 GPR_ROUND_UP_TO_ALIGNMENT_SIZE(filter_count * sizeof(grpc_call_element)); in grpc_channel_stack_init()
158 grpc_call_element* call_elems; in grpc_call_stack_init()
166 GPR_ROUND_UP_TO_ALIGNMENT_SIZE(count * sizeof(grpc_call_element)); in grpc_call_stack_init()
194 grpc_call_element* call_elems; in grpc_call_stack_set_pollset_or_pollset_set()
206 grpc_call_element* /*elem*/, grpc_polling_entity* /*pollent*/) {} in grpc_call_stack_ignore_set_pollset_or_pollset_set() argument
211 grpc_call_element* elems = CALL_ELEMS_FROM_STACK(stack); in grpc_call_stack_destroy()
223 void grpc_call_next_op(grpc_call_element* elem, in grpc_call_next_op()
225 grpc_call_element* next_elem = elem + 1; in grpc_call_next_op()
[all …]
|
| /external/grpc-grpc/src/core/lib/channel/ |
| D | channel_stack.h | 51 typedef struct grpc_call_element grpc_call_element; typedef
101 void (*start_transport_stream_op_batch)(grpc_call_element* elem,
119 grpc_error* (*init_call_elem)(grpc_call_element* elem,
121 void (*set_pollset_or_pollset_set)(grpc_call_element* elem,
129 void (*destroy_call_elem)(grpc_call_element* elem,
166 struct grpc_call_element { struct
200 grpc_call_element* grpc_call_stack_element(grpc_call_stack* stack, size_t i);
254 grpc_call_element* elem, grpc_polling_entity* pollent);
256 void grpc_call_next_op(grpc_call_element* elem,
269 grpc_call_stack* grpc_call_stack_from_top_element(grpc_call_element* elem);
[all …]
|
| D | channel_stack.cc | 71 ((grpc_call_element*)((char*)(stk) + GPR_ROUND_UP_TO_ALIGNMENT_SIZE( \
84 grpc_call_element* grpc_call_stack_element(grpc_call_stack* call_stack, in grpc_call_stack_element()
96 GPR_ROUND_UP_TO_ALIGNMENT_SIZE(filter_count * sizeof(grpc_call_element)); in grpc_channel_stack_init()
158 grpc_call_element* call_elems; in grpc_call_stack_init()
167 GPR_ROUND_UP_TO_ALIGNMENT_SIZE(count * sizeof(grpc_call_element)); in grpc_call_stack_init()
193 grpc_call_element* call_elems; in grpc_call_stack_set_pollset_or_pollset_set()
205 grpc_call_element* elem, grpc_polling_entity* pollent) {} in grpc_call_stack_ignore_set_pollset_or_pollset_set()
210 grpc_call_element* elems = CALL_ELEMS_FROM_STACK(stack); in grpc_call_stack_destroy()
222 void grpc_call_next_op(grpc_call_element* elem, in grpc_call_next_op()
224 grpc_call_element* next_elem = elem + 1; in grpc_call_next_op()
[all …]
|
| /external/grpc-grpc/src/core/ext/filters/deadline/ |
| D | deadline_filter.cc | 50 grpc_call_element* elem = static_cast<grpc_call_element*>(arg); in send_cancel_op_in_call_combiner()
63 grpc_call_element* elem = static_cast<grpc_call_element*>(arg); in timer_callback()
86 static void start_timer_if_needed(grpc_call_element* elem, in start_timer_if_needed()
156 grpc_call_element* elem;
180 void grpc_deadline_state_init(grpc_call_element* elem, in grpc_deadline_state_init()
209 void grpc_deadline_state_destroy(grpc_call_element* elem) { in grpc_deadline_state_destroy()
215 void grpc_deadline_state_reset(grpc_call_element* elem, in grpc_deadline_state_reset()
224 grpc_call_element* elem, grpc_transport_stream_op_batch* op) { in grpc_deadline_state_client_start_transport_stream_op_batch()
270 static grpc_error* init_call_elem(grpc_call_element* elem, in init_call_elem()
278 static void destroy_call_elem(grpc_call_element* elem, in destroy_call_elem()
[all …]
|
| D | deadline_filter.h | 54 void grpc_deadline_state_init(grpc_call_element* elem,
59 void grpc_deadline_state_destroy(grpc_call_element* elem);
70 void grpc_deadline_state_reset(grpc_call_element* elem,
82 grpc_call_element* elem, grpc_transport_stream_op_batch* op);
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/http/message_compress/ |
| D | message_compress_filter.cc | 105 CallData(grpc_call_element* elem, const grpc_call_element_args& args) in CallData()
128 grpc_call_element* elem, grpc_transport_stream_op_batch* batch);
132 void InitializeState(grpc_call_element* elem);
134 grpc_error* ProcessSendInitialMetadata(grpc_call_element* elem,
141 void ContinueReadingSendMessage(grpc_call_element* elem);
142 void FinishSendMessage(grpc_call_element* elem);
143 void SendMessageBatchContinue(grpc_call_element* elem);
225 void CallData::InitializeState(grpc_call_element* elem) { in InitializeState()
236 grpc_call_element* elem, grpc_metadata_batch* initial_metadata) { in ProcessSendInitialMetadata()
292 void CallData::SendMessageBatchContinue(grpc_call_element* elem) { in SendMessageBatchContinue()
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/deadline/ |
| D | deadline_filter.cc | 41 TimerState(grpc_call_element* elem, grpc_millis deadline) : elem_(elem) { in TimerState()
101 grpc_call_element* elem_;
115 static void start_timer_if_needed(grpc_call_element* elem, in start_timer_if_needed()
162 start_timer_after_init_state(grpc_call_element* elem, grpc_millis deadline) in start_timer_after_init_state()
167 grpc_call_element* elem;
190 grpc_deadline_state::grpc_deadline_state(grpc_call_element* elem, in grpc_deadline_state()
216 void grpc_deadline_state_reset(grpc_call_element* elem, in grpc_deadline_state_reset()
225 grpc_call_element* elem, grpc_transport_stream_op_batch* op) { in grpc_deadline_state_client_start_transport_stream_op_batch()
271 static grpc_error* deadline_init_call_elem(grpc_call_element* elem, in deadline_init_call_elem()
279 grpc_call_element* elem, const grpc_call_final_info* /*final_info*/, in deadline_destroy_call_elem()
[all …]
|
| D | deadline_filter.h | 32 grpc_deadline_state(grpc_call_element* elem,
63 void grpc_deadline_state_reset(grpc_call_element* elem,
75 grpc_call_element* elem, grpc_transport_stream_op_batch* op);
|
| /external/grpc-grpc/src/core/lib/security/transport/ |
| D | server_auth_filter.cc | 84 grpc_call_element* elem = static_cast<grpc_call_element*>(user_data); in remove_consumed_md()
96 static void on_md_processing_done_inner(grpc_call_element* elem, in on_md_processing_done_inner()
126 grpc_call_element* elem = static_cast<grpc_call_element*>(user_data); in on_md_processing_done()
154 grpc_call_element* elem = static_cast<grpc_call_element*>(arg); in cancel_call()
166 grpc_call_element* elem = static_cast<grpc_call_element*>(arg); in recv_initial_metadata_ready()
192 grpc_call_element* elem = static_cast<grpc_call_element*>(user_data); in recv_trailing_metadata_ready()
199 grpc_call_element* elem, grpc_transport_stream_op_batch* batch) { in auth_start_transport_stream_op_batch()
219 static grpc_error* init_call_elem(grpc_call_element* elem, in init_call_elem()
248 static void destroy_call_elem(grpc_call_element* elem, in destroy_call_elem()
|
| D | client_auth_filter.cc | 99 grpc_call_element* elem = in on_credentials_metadata()
100 static_cast<grpc_call_element*>(batch->handler_private.extra_arg); in on_credentials_metadata()
164 grpc_call_element* elem = static_cast<grpc_call_element*>(arg); in cancel_get_request_metadata()
172 static void send_security_metadata(grpc_call_element* elem, in send_security_metadata()
235 grpc_call_element* elem = in on_host_checked()
236 static_cast<grpc_call_element*>(batch->handler_private.extra_arg); in on_host_checked()
258 grpc_call_element* elem = static_cast<grpc_call_element*>(arg); in cancel_check_call_host()
269 grpc_call_element* elem, grpc_transport_stream_op_batch* batch) { in auth_start_transport_stream_op_batch()
334 static grpc_error* init_call_elem(grpc_call_element* elem, in init_call_elem()
345 static void set_pollset_or_pollset_set(grpc_call_element* elem, in set_pollset_or_pollset_set()
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/security/transport/ |
| D | server_auth_filter.cc | 51 call_data(grpc_call_element* elem, const grpc_call_element_args& args) in call_data()
120 grpc_call_element* elem = static_cast<grpc_call_element*>(user_data); in remove_consumed_md()
133 static void on_md_processing_done_inner(grpc_call_element* elem, in on_md_processing_done_inner()
171 grpc_call_element* elem = static_cast<grpc_call_element*>(user_data); in on_md_processing_done()
200 grpc_call_element* elem = static_cast<grpc_call_element*>(arg); in cancel_call()
212 grpc_call_element* elem = static_cast<grpc_call_element*>(arg); in recv_initial_metadata_ready()
246 grpc_call_element* elem = static_cast<grpc_call_element*>(user_data); in recv_trailing_metadata_ready()
263 grpc_call_element* elem, grpc_transport_stream_op_batch* batch) { in server_auth_start_transport_stream_op_batch()
284 grpc_call_element* elem, const grpc_call_element_args* args) { in server_auth_init_call_elem()
291 grpc_call_element* elem, const grpc_call_final_info* /*final_info*/, in server_auth_destroy_call_elem()
|
| D | client_auth_filter.cc | 67 call_data(grpc_call_element* elem, const grpc_call_element_args& args) in call_data()
161 grpc_call_element* elem = in on_credentials_metadata()
162 static_cast<grpc_call_element*>(batch->handler_private.extra_arg); in on_credentials_metadata()
229 grpc_call_element* elem = static_cast<grpc_call_element*>(arg); in cancel_get_request_metadata()
237 static void send_security_metadata(grpc_call_element* elem, in send_security_metadata()
332 grpc_call_element* elem = in on_host_checked()
333 static_cast<grpc_call_element*>(batch->handler_private.extra_arg); in on_host_checked()
352 grpc_call_element* elem = static_cast<grpc_call_element*>(arg); in cancel_check_call_host()
362 grpc_call_element* elem, grpc_transport_stream_op_batch* batch) { in client_auth_start_transport_stream_op_batch()
407 grpc_call_element* elem, const grpc_call_element_args* args) { in client_auth_init_call_elem()
[all …]
|
| /external/grpc-grpc/src/core/ext/filters/http/message_compress/ |
| D | message_compress_filter.cc | 85 static bool skip_compression(grpc_call_element* elem, uint32_t flags, in skip_compression()
105 grpc_call_element* elem, grpc_metadata_batch* initial_metadata,
108 grpc_call_element* elem, grpc_metadata_batch* initial_metadata, in process_send_initial_metadata()
201 grpc_call_element* elem = static_cast<grpc_call_element*>(arg); in send_message_on_complete()
208 static void send_message_batch_continue(grpc_call_element* elem) { in send_message_batch_continue()
219 static void finish_send_message(grpc_call_element* elem) { in finish_send_message()
293 static void continue_reading_send_message(grpc_call_element* elem) { in continue_reading_send_message()
314 grpc_call_element* elem = static_cast<grpc_call_element*>(arg); in on_send_message_next_done()
337 grpc_call_element* elem = static_cast<grpc_call_element*>(arg); in start_send_message_batch()
351 grpc_call_element* elem, grpc_transport_stream_op_batch* batch) { in compress_start_transport_stream_op_batch()
[all …]
|
| /external/grpc-grpc/src/cpp/ext/filters/census/ |
| D | client_filter.cc | 52 grpc_call_element* elem = reinterpret_cast<grpc_call_element*>(user_data); in OnDoneRecvTrailingMetadataCb()
67 grpc_call_element* elem = reinterpret_cast<grpc_call_element*>(user_data); in OnDoneRecvMessageCb()
82 grpc_call_element* elem, TransportStreamOpBatch* op) { in StartTransportStreamOpBatch()
131 grpc_error* CensusClientCallData::Init(grpc_call_element* elem, in Init()
145 void CensusClientCallData::Destroy(grpc_call_element* elem, in Destroy()
|
| D | server_filter.cc | 66 grpc_call_element* elem = reinterpret_cast<grpc_call_element*>(user_data); in OnDoneRecvMessageCb()
82 grpc_call_element* elem = reinterpret_cast<grpc_call_element*>(user_data); in OnDoneRecvInitialMetadataCb()
129 grpc_call_element* elem, TransportStreamOpBatch* op) { in StartTransportStreamOpBatch()
165 grpc_error* CensusServerCallData::Init(grpc_call_element* elem, in Init()
179 void CensusServerCallData::Destroy(grpc_call_element* elem, in Destroy()
|
| /external/rust/crates/grpcio-sys/grpc/src/cpp/ext/filters/census/ |
| D | client_filter.cc | 58 grpc_call_element* elem = reinterpret_cast<grpc_call_element*>(user_data); in OnDoneRecvTrailingMetadataCb()
74 grpc_call_element* elem = reinterpret_cast<grpc_call_element*>(user_data); in OnDoneRecvMessageCb()
90 grpc_call_element* elem, TransportStreamOpBatch* op) { in StartTransportStreamOpBatch()
141 grpc_error* CensusClientCallData::Init(grpc_call_element* elem, in Init()
155 void CensusClientCallData::Destroy(grpc_call_element* elem, in Destroy()
|
| D | server_filter.cc | 66 grpc_call_element* elem = reinterpret_cast<grpc_call_element*>(user_data); in OnDoneRecvMessageCb()
83 grpc_call_element* elem = reinterpret_cast<grpc_call_element*>(user_data); in OnDoneRecvInitialMetadataCb()
131 grpc_call_element* elem, TransportStreamOpBatch* op) { in StartTransportStreamOpBatch()
168 grpc_error* CensusServerCallData::Init(grpc_call_element* elem, in Init()
182 void CensusServerCallData::Destroy(grpc_call_element* elem, in Destroy()
|
| /external/grpc-grpc/src/core/ext/filters/load_reporting/ |
| D | server_load_reporting_filter.cc | 68 grpc_call_element* elem, const grpc_call_final_info* final_info, in Destroy()
101 grpc_call_element* elem, TransportStreamOpBatch* op) { in StartTransportStreamOpBatch()
213 grpc_call_element* elem = reinterpret_cast<grpc_call_element*>(user_data); in RecvInitialMetadataFilter()
241 grpc_call_element* elem = reinterpret_cast<grpc_call_element*>(arg); in RecvInitialMetadataReady()
271 grpc_call_element* elem, const grpc_call_element_args* args) { in Init()
280 grpc_call_element* elem = reinterpret_cast<grpc_call_element*>(user_data); in SendTrailingMetadataFilter()
|
| /external/grpc-grpc/src/core/ext/filters/http/server/ |
| D | http_server_filter.cc | 76 static grpc_error* hs_filter_outgoing_metadata(grpc_call_element* elem, in hs_filter_outgoing_metadata()
101 static grpc_error* hs_filter_incoming_metadata(grpc_call_element* elem, in hs_filter_incoming_metadata()
279 grpc_call_element* elem = static_cast<grpc_call_element*>(user_data); in hs_recv_initial_metadata_ready()
308 grpc_call_element* elem = static_cast<grpc_call_element*>(user_data); in hs_recv_message_ready()
332 grpc_call_element* elem = static_cast<grpc_call_element*>(user_data); in hs_recv_trailing_metadata_ready()
340 static grpc_error* hs_mutate_op(grpc_call_element* elem, in hs_mutate_op()
401 grpc_call_element* elem, grpc_transport_stream_op_batch* op) { in hs_start_transport_stream_op_batch()
414 static grpc_error* hs_init_call_elem(grpc_call_element* elem, in hs_init_call_elem()
430 static void hs_destroy_call_elem(grpc_call_element* elem, in hs_destroy_call_elem()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/http/server/ |
| D | http_server_filter.cc | 45 call_data(grpc_call_element* elem, const grpc_call_element_args& args) in call_data()
152 static grpc_error* hs_filter_incoming_metadata(grpc_call_element* elem, in hs_filter_incoming_metadata()
334 grpc_call_element* elem = static_cast<grpc_call_element*>(user_data); in hs_recv_initial_metadata_ready()
371 grpc_call_element* elem = static_cast<grpc_call_element*>(user_data); in hs_recv_message_ready()
396 grpc_call_element* elem = static_cast<grpc_call_element*>(user_data); in hs_recv_trailing_metadata_ready()
413 static grpc_error* hs_mutate_op(grpc_call_element* elem, in hs_mutate_op()
475 grpc_call_element* elem, grpc_transport_stream_op_batch* op) { in hs_start_transport_stream_op_batch()
488 static grpc_error* hs_init_call_elem(grpc_call_element* elem, in hs_init_call_elem()
495 static void hs_destroy_call_elem(grpc_call_element* elem, in hs_destroy_call_elem()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/load_reporting/ |
| D | server_load_reporting_filter.cc | 74 grpc_call_element* elem, const grpc_call_final_info* final_info, in Destroy()
107 grpc_call_element* elem, TransportStreamOpBatch* op) { in StartTransportStreamOpBatch()
208 grpc_call_element* elem = reinterpret_cast<grpc_call_element*>(user_data); in RecvInitialMetadataFilter()
237 grpc_call_element* elem = reinterpret_cast<grpc_call_element*>(arg); in RecvInitialMetadataReady()
268 grpc_call_element* elem, const grpc_call_element_args* args) { in Init()
277 grpc_call_element* elem = reinterpret_cast<grpc_call_element*>(user_data); in SendTrailingMetadataFilter()
|
| /external/grpc-grpc/src/core/ext/filters/workarounds/ |
| D | workaround_cronet_compression_filter.cc | 58 grpc_call_element* elem = static_cast<grpc_call_element*>(user_data); in recv_initial_metadata_ready()
79 grpc_call_element* elem, grpc_transport_stream_op_batch* op) { in start_transport_stream_op_batch()
107 static grpc_error* init_call_elem(grpc_call_element* elem, in init_call_elem()
119 static void destroy_call_elem(grpc_call_element* elem, in destroy_call_elem()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/workarounds/ |
| D | workaround_cronet_compression_filter.cc | 58 grpc_call_element* elem = static_cast<grpc_call_element*>(user_data); in recv_initial_metadata_ready()
80 grpc_call_element* elem, grpc_transport_stream_op_batch* op) { in cronet_compression_start_transport_stream_op_batch()
109 grpc_call_element* elem, const grpc_call_element_args* /*args*/) { in cronet_compression_init_call_elem()
121 grpc_call_element* /*elem*/, const grpc_call_final_info* /*final_info*/, in cronet_compression_destroy_call_elem() argument
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/http/client/ |
| D | http_client_filter.cc | 58 call_data(grpc_call_element* elem, const grpc_call_element_args& args) in call_data()
186 grpc_call_element* elem = static_cast<grpc_call_element*>(user_data); in recv_initial_metadata_ready()
205 grpc_call_element* elem = static_cast<grpc_call_element*>(user_data); in recv_trailing_metadata_ready()
227 grpc_call_element* elem = static_cast<grpc_call_element*>(arg); in send_message_on_complete()
267 grpc_call_element* elem = static_cast<grpc_call_element*>(arg); in on_send_message_next_done()
304 static grpc_error* update_path_for_get(grpc_call_element* elem, in update_path_for_get()
354 grpc_call_element* elem, grpc_transport_stream_op_batch* batch) { in http_client_start_transport_stream_op_batch()
479 grpc_call_element* elem, const grpc_call_element_args* args) { in http_client_init_call_elem()
486 grpc_call_element* elem, const grpc_call_final_info* /*final_info*/, in http_client_destroy_call_elem()
|