Home
last modified time | relevance | path

Searched defs:calld (Results 1 – 19 of 19) sorted by relevance

/external/grpc-grpc/src/core/ext/filters/http/message_compress/
Dmessage_compress_filter.cc87 call_data* calld = static_cast<call_data*>(elem->call_data); in skip_compression() local
110 call_data* calld = static_cast<call_data*>(elem->call_data); in process_send_initial_metadata() local
202 call_data* calld = static_cast<call_data*>(elem->call_data); in send_message_on_complete() local
209 call_data* calld = static_cast<call_data*>(elem->call_data); in send_message_batch_continue() local
220 call_data* calld = static_cast<call_data*>(elem->call_data); in finish_send_message() local
269 call_data* calld = static_cast<call_data*>(arg); in fail_send_message_batch_in_call_combiner() local
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() local
315 call_data* calld = static_cast<call_data*>(elem->call_data); in on_send_message_next_done() local
338 call_data* calld = static_cast<call_data*>(elem->call_data); in start_send_message_batch() local
[all …]
/external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/
Dclient_load_reporting_filter.cc55 call_data* calld = static_cast<call_data*>(arg); in on_complete_for_send() local
63 call_data* calld = static_cast<call_data*>(arg); in recv_initial_metadata_ready() local
73 call_data* calld = static_cast<call_data*>(elem->call_data); in init_call_elem() local
89 call_data* calld = static_cast<call_data*>(elem->call_data); in destroy_call_elem() local
104 call_data* calld = static_cast<call_data*>(elem->call_data); in start_transport_stream_op_batch() local
/external/grpc-grpc/src/core/ext/filters/client_channel/
Dclient_channel.cc1011 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() local
1113 call_data* calld = static_cast<call_data*>(elem->call_data); in free_cached_send_op_data_for_completed_batch() local
1147 call_data* calld = static_cast<call_data*>(elem->call_data); in pending_batches_add() local
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() local
1235 call_data* calld = static_cast<call_data*>(elem->call_data); in pending_batches_fail() local
[all …]
/external/grpc-grpc/src/core/lib/channel/
Dconnected_channel.cc68 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()
94 #define TRANSPORT_STREAM_FROM_CALL_DATA(calld) ((grpc_stream*)((calld) + 1)) argument
102 call_data* calld = static_cast<call_data*>(elem->call_data); in con_start_transport_stream_op_batch() local
149 call_data* calld = static_cast<call_data*>(elem->call_data); in init_call_elem() local
162 call_data* calld = static_cast<call_data*>(elem->call_data); in set_pollset_or_pollset_set() local
172 call_data* calld = static_cast<call_data*>(elem->call_data); in destroy_call_elem() local
241 call_data* calld = static_cast<call_data*>(elem->call_data); in grpc_connected_channel_get_stream() local
/external/grpc-grpc/src/core/lib/security/transport/
Dserver_auth_filter.cc85 call_data* calld = static_cast<call_data*>(elem->call_data); in remove_consumed_md() local
102 call_data* calld = static_cast<call_data*>(elem->call_data); in on_md_processing_done_inner() local
127 call_data* calld = static_cast<call_data*>(elem->call_data); in on_md_processing_done() local
155 call_data* calld = static_cast<call_data*>(elem->call_data); in cancel_call() local
168 call_data* calld = static_cast<call_data*>(elem->call_data); in recv_initial_metadata_ready() local
193 call_data* calld = static_cast<call_data*>(elem->call_data); in recv_trailing_metadata_ready() local
200 call_data* calld = static_cast<call_data*>(elem->call_data); in auth_start_transport_stream_op_batch() local
221 call_data* calld = static_cast<call_data*>(elem->call_data); in init_call_elem() local
251 call_data* calld = static_cast<call_data*>(elem->call_data); in destroy_call_elem() local
Dclient_auth_filter.cc101 call_data* calld = static_cast<call_data*>(elem->call_data); in on_credentials_metadata() local
165 call_data* calld = static_cast<call_data*>(elem->call_data); in cancel_get_request_metadata() local
174 call_data* calld = static_cast<call_data*>(elem->call_data); in send_security_metadata() local
237 call_data* calld = static_cast<call_data*>(elem->call_data); in on_host_checked() local
259 call_data* calld = static_cast<call_data*>(elem->call_data); in cancel_check_call_host() local
273 call_data* calld = static_cast<call_data*>(elem->call_data); in auth_start_transport_stream_op_batch() local
336 call_data* calld = static_cast<call_data*>(elem->call_data); in init_call_elem() local
347 call_data* calld = static_cast<call_data*>(elem->call_data); in set_pollset_or_pollset_set() local
355 call_data* calld = static_cast<call_data*>(elem->call_data); in destroy_call_elem() local
/external/grpc-grpc/src/core/ext/filters/http/server/
Dhttp_server_filter.cc103 call_data* calld = static_cast<call_data*>(elem->call_data); in hs_filter_incoming_metadata() local
280 call_data* calld = static_cast<call_data*>(elem->call_data); in hs_recv_initial_metadata_ready() local
309 call_data* calld = static_cast<call_data*>(elem->call_data); in hs_recv_message_ready() local
333 call_data* calld = static_cast<call_data*>(elem->call_data); in hs_recv_trailing_metadata_ready() local
343 call_data* calld = static_cast<call_data*>(elem->call_data); in hs_mutate_op() local
403 call_data* calld = static_cast<call_data*>(elem->call_data); in hs_start_transport_stream_op_batch() local
416 call_data* calld = static_cast<call_data*>(elem->call_data); in hs_init_call_elem() local
433 call_data* calld = static_cast<call_data*>(elem->call_data); in hs_destroy_call_elem() local
/external/grpc-grpc/src/core/ext/filters/http/client/
Dhttp_client_filter.cc153 call_data* calld = static_cast<call_data*>(elem->call_data); in recv_initial_metadata_ready() local
165 call_data* calld = static_cast<call_data*>(elem->call_data); in recv_trailing_metadata_ready() local
179 call_data* calld = static_cast<call_data*>(elem->call_data); in send_message_on_complete() local
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() local
256 call_data* calld = static_cast<call_data*>(elem->call_data); in update_path_for_get() local
305 call_data* calld = static_cast<call_data*>(elem->call_data); in hc_start_transport_stream_op_batch() local
428 call_data* calld = static_cast<call_data*>(elem->call_data); in init_call_elem() local
447 call_data* calld = static_cast<call_data*>(elem->call_data); in destroy_call_elem() local
/external/grpc-grpc/src/core/ext/filters/message_size/
Dmessage_size_filter.cc127 call_data* calld = static_cast<call_data*>(elem->call_data); in recv_message_ready() local
157 call_data* calld = static_cast<call_data*>(elem->call_data); in recv_trailing_metadata_ready() local
167 call_data* calld = static_cast<call_data*>(elem->call_data); in start_transport_stream_op_batch() local
207 call_data* calld = static_cast<call_data*>(elem->call_data); in init_call_elem() local
246 call_data* calld = (call_data*)elem->call_data; in destroy_call_elem() local
/external/grpc-grpc/src/core/lib/surface/
Dlame_client.cc55 CallData* calld = static_cast<CallData*>(elem->call_data); in fill_metadata() local
81 CallData* calld = static_cast<CallData*>(elem->call_data); in lame_start_transport_stream_op_batch() local
122 CallData* calld = static_cast<CallData*>(elem->call_data); in init_call_elem() local
Dserver.cc337 call_data* calld = rm->pending_head; in request_matcher_zombify_all_pending_calls() local
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() local
549 call_data* calld = static_cast<call_data*>(elem->call_data); in finish_start_new_rpc() local
580 call_data* calld = static_cast<call_data*>(elem->call_data); in start_new_rpc() local
703 call_data* calld = static_cast<call_data*>(elem->call_data); in server_on_recv_initial_metadata() local
742 call_data* calld = static_cast<call_data*>(elem->call_data); in server_recv_trailing_metadata_ready() local
749 call_data* calld = static_cast<call_data*>(elem->call_data); in server_mutate_op() local
778 call_data* calld = static_cast<call_data*>(elem->call_data); in got_initial_metadata() local
812 call_data* calld = static_cast<call_data*>(elem->call_data); in accept_stream() local
[all …]
/external/grpc-grpc/src/core/ext/filters/workarounds/
Dworkaround_cronet_compression_filter.cc59 call_data* calld = static_cast<call_data*>(elem->call_data); in recv_initial_metadata_ready() local
80 call_data* calld = static_cast<call_data*>(elem->call_data); in start_transport_stream_op_batch() local
109 call_data* calld = static_cast<call_data*>(elem->call_data); in init_call_elem() local
/external/grpc-grpc/src/cpp/ext/filters/census/
Dclient_filter.cc53 CensusClientCallData* calld = in OnDoneRecvTrailingMetadataCb() local
68 CensusClientCallData* calld = in OnDoneRecvMessageCb() local
Dserver_filter.cc67 CensusServerCallData* calld = in OnDoneRecvMessageCb() local
83 CensusServerCallData* calld = in OnDoneRecvInitialMetadataCb() local
/external/grpc-grpc/src/core/ext/filters/load_reporting/
Dserver_load_reporting_filter.cc214 ServerLoadReportingCallData* calld = in RecvInitialMetadataFilter() local
242 ServerLoadReportingCallData* calld = in RecvInitialMetadataReady() local
281 ServerLoadReportingCallData* calld = in SendTrailingMetadataFilter() local
/external/grpc-grpc/src/core/ext/filters/http/
Dclient_authority_filter.cc53 call_data* calld = static_cast<call_data*>(elem->call_data); in authority_start_transport_stream_op_batch() local
78 call_data* calld = static_cast<call_data*>(elem->call_data); in init_call_elem() local
/external/grpc-grpc/test/core/end2end/tests/
Dfilter_causes_close.cc200 call_data* calld = static_cast<call_data*>(elem->call_data); in recv_im_ready() local
211 call_data* calld = static_cast<call_data*>(elem->call_data); in start_transport_stream_op_batch() local
/external/grpc-grpc/src/core/ext/filters/deadline/
Ddeadline_filter.cc295 server_call_data* calld = static_cast<server_call_data*>(elem->call_data); in recv_initial_metadata_ready() local
305 server_call_data* calld = static_cast<server_call_data*>(elem->call_data); in server_start_transport_stream_op_batch() local
/external/grpc-grpc/test/cpp/microbenchmarks/
Dbm_call_create.cc626 call_data* calld = static_cast<call_data*>(elem->call_data); in StartTransportStreamOp() local
659 call_data* calld = static_cast<call_data*>(elem->call_data); in InitCallElem() local