| /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 …]
|
| D | connected_channel.cc | 101 grpc_call_element* elem, grpc_transport_stream_op_batch* batch) { in con_start_transport_stream_op_batch()
147 static grpc_error* init_call_elem(grpc_call_element* elem, in init_call_elem()
160 static void set_pollset_or_pollset_set(grpc_call_element* elem, in set_pollset_or_pollset_set()
169 static void destroy_call_elem(grpc_call_element* elem, in destroy_call_elem()
240 grpc_stream* grpc_connected_channel_get_stream(grpc_call_element* elem) { in grpc_connected_channel_get_stream()
|
| /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/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/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()
|
| D | server_filter.h | 57 grpc_error* Init(grpc_call_element* elem,
60 void Destroy(grpc_call_element* elem, const grpc_call_final_info* final_info,
63 void StartTransportStreamOpBatch(grpc_call_element* elem,
|
| D | client_filter.h | 57 grpc_error* Init(grpc_call_element* elem,
60 void Destroy(grpc_call_element* elem, const grpc_call_final_info* final_info,
63 void StartTransportStreamOpBatch(grpc_call_element* elem,
|
| /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/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()
|
| D | server_load_reporting_filter.h | 46 grpc_error* Init(grpc_call_element* elem,
49 void Destroy(grpc_call_element* elem, const grpc_call_final_info* final_info,
52 void StartTransportStreamOpBatch(grpc_call_element* elem,
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/ |
| D | client_channel.cc | 834 grpc_call_element* elem;
996 static void retry_commit(grpc_call_element* elem,
998 static void start_internal_recv_trailing_metadata(grpc_call_element* elem);
1003 grpc_call_element* elem, grpc_transport_stream_op_batch* batch);
1093 grpc_call_element* elem, subchannel_call_retry_state* retry_state) { in free_cached_send_op_data_after_commit()
1110 grpc_call_element* elem, subchannel_batch_data* batch_data, in free_cached_send_op_data_for_completed_batch()
1144 static void pending_batches_add(grpc_call_element* elem, in pending_batches_add()
1232 static void pending_batches_fail(grpc_call_element* elem, grpc_error* error, in pending_batches_fail()
1279 static void pending_batches_resume(grpc_call_element* elem) { in pending_batches_resume()
1316 static void maybe_clear_pending_batch(grpc_call_element* elem, in maybe_clear_pending_batch()
[all …]
|
| /external/grpc-grpc/src/core/ext/filters/http/client/ |
| D | http_client_filter.cc | 79 static grpc_error* client_filter_incoming_metadata(grpc_call_element* elem, in client_filter_incoming_metadata()
152 grpc_call_element* elem = static_cast<grpc_call_element*>(user_data); in recv_initial_metadata_ready()
164 grpc_call_element* elem = static_cast<grpc_call_element*>(user_data); in recv_trailing_metadata_ready()
178 grpc_call_element* elem = static_cast<grpc_call_element*>(arg); in send_message_on_complete()
217 grpc_call_element* elem = static_cast<grpc_call_element*>(arg); in on_send_message_next_done()
254 static grpc_error* update_path_for_get(grpc_call_element* elem, in update_path_for_get()
304 grpc_call_element* elem, grpc_transport_stream_op_batch* batch) { in hc_start_transport_stream_op_batch()
426 static grpc_error* init_call_elem(grpc_call_element* elem, in init_call_elem()
444 static void destroy_call_elem(grpc_call_element* elem, in destroy_call_elem()
|
| /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/grpc-grpc/src/cpp/common/ |
| D | channel_filter.h | 262 virtual grpc_error* Init(grpc_call_element* elem, in Init()
268 virtual void Destroy(grpc_call_element* elem, in Destroy()
273 virtual void StartTransportStreamOpBatch(grpc_call_element* elem,
277 virtual void SetPollsetOrPollsetSet(grpc_call_element* elem,
322 static grpc_error* InitCallElement(grpc_call_element* elem, in InitCallElement()
329 static void DestroyCallElement(grpc_call_element* elem, in DestroyCallElement()
337 static void StartTransportStreamOpBatch(grpc_call_element* elem, in StartTransportStreamOpBatch()
344 static void SetPollsetOrPollsetSet(grpc_call_element* elem, in SetPollsetOrPollsetSet()
|
| /external/grpc-grpc/src/core/ext/filters/message_size/ |
| D | message_size_filter.cc | 126 grpc_call_element* elem = static_cast<grpc_call_element*>(user_data); in recv_message_ready()
156 grpc_call_element* elem = static_cast<grpc_call_element*>(user_data); in recv_trailing_metadata_ready()
166 grpc_call_element* elem, grpc_transport_stream_op_batch* op) { in start_transport_stream_op_batch()
204 static grpc_error* init_call_elem(grpc_call_element* elem, in init_call_elem()
243 static void destroy_call_elem(grpc_call_element* elem, in destroy_call_elem()
|
| /external/grpc-grpc/test/core/channel/ |
| D | channel_stack_test.cc | 42 static grpc_error* call_init_func(grpc_call_element* elem, in call_init_func()
51 static void call_destroy_func(grpc_call_element* elem, in call_destroy_func()
57 static void call_func(grpc_call_element* elem, in call_func()
93 grpc_call_element* call_elem; in test_create_channel_stack()
|
| D | channel_stack_builder_test.cc | 37 static grpc_error* call_init_func(grpc_call_element* elem, in call_init_func()
44 static void call_destroy_func(grpc_call_element* elem, in call_destroy_func()
48 static void call_func(grpc_call_element* elem, in call_func()
|
| /external/grpc-grpc/src/core/lib/surface/ |
| D | lame_client.cc | 54 static void fill_metadata(grpc_call_element* elem, grpc_metadata_batch* mdb) { in fill_metadata()
80 grpc_call_element* elem, grpc_transport_stream_op_batch* op) { in lame_start_transport_stream_op_batch()
120 static grpc_error* init_call_elem(grpc_call_element* elem, in init_call_elem()
127 static void destroy_call_elem(grpc_call_element* elem, in destroy_call_elem()
|
| /external/grpc-grpc/test/core/end2end/tests/ |
| D | filter_causes_close.cc | 199 grpc_call_element* elem = static_cast<grpc_call_element*>(arg); in recv_im_ready()
210 grpc_call_element* elem, grpc_transport_stream_op_batch* op) { in start_transport_stream_op_batch()
221 static grpc_error* init_call_elem(grpc_call_element* elem, in init_call_elem()
226 static void destroy_call_elem(grpc_call_element* elem, in destroy_call_elem()
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/ |
| D | client_load_reporting_filter.cc | 71 static grpc_error* init_call_elem(grpc_call_element* elem, in init_call_elem()
86 static void destroy_call_elem(grpc_call_element* elem, in destroy_call_elem()
103 grpc_call_element* elem, grpc_transport_stream_op_batch* batch) { in start_transport_stream_op_batch()
|