Home
last modified time | relevance | path

Searched refs:call_data (Results 1 – 25 of 38) sorted by relevance

12

/external/grpc-grpc/src/core/ext/filters/http/message_compress/
Dmessage_compress_filter.cc52 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/
Dserver_auth_filter.cc38 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 …]
Dclient_auth_filter.cc44 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/
Dclient_load_reporting_filter.cc39 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/grpc-grpc/src/core/lib/channel/
Dconnected_channel.cc55 } 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/
Dclient_channel.cc993 } 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/grpc-grpc/src/core/ext/filters/http/server/
Dhttp_server_filter.cc40 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/grpc-grpc/src/core/ext/filters/http/client/
Dhttp_client_filter.cc43 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/
Dmessage_size_filter.cc95 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/workarounds/
Dworkaround_cronet_compression_filter.cc31 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/grpc-grpc/src/core/ext/filters/http/
Dclient_authority_filter.cc41 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/grpc-grpc/src/cpp/common/
Dchannel_filter.h325 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/core/ext/filters/deadline/
Ddeadline_filter.cc52 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/
Dserver.cc128 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 …]
Dlame_client.cc55 CallData* calld = static_cast<CallData*>(elem->call_data); in fill_metadata()
81 CallData* calld = static_cast<CallData*>(elem->call_data); in lame_start_transport_stream_op_batch()
122 CallData* calld = static_cast<CallData*>(elem->call_data); in init_call_elem()
/external/grpc-grpc/test/core/channel/
Dchannel_stack_test.cc45 *static_cast<int*>(elem->call_data) = 0; in call_init_func()
59 ++*static_cast<int*>(elem->call_data); in call_func()
97 int* call_data; in test_create_channel_stack() local
136 call_data = static_cast<int*>(call_elem->call_data); in test_create_channel_stack()
137 GPR_ASSERT(*call_data == 0); in test_create_channel_stack()
/external/grpc-grpc/test/core/end2end/tests/
Dfilter_causes_close.cc192 } call_data; typedef
200 call_data* calld = static_cast<call_data*>(elem->call_data); in recv_im_ready()
211 call_data* calld = static_cast<call_data*>(elem->call_data); in start_transport_stream_op_batch()
240 sizeof(call_data),
Dfilter_status_code.cc262 auto* data = static_cast<final_status_data*>(elem->call_data); in server_start_transport_stream_op_batch()
278 final_status_data* data = static_cast<final_status_data*>(elem->call_data); in init_call_elem()
286 final_status_data* data = static_cast<final_status_data*>(elem->call_data); in client_destroy_call_elem()
301 final_status_data* data = static_cast<final_status_data*>(elem->call_data); in server_destroy_call_elem()
/external/v8/src/builtins/
Dbuiltins-api.cc102 CallHandlerInfo* call_data = CallHandlerInfo::cast(raw_call_data); in HandleApiCallHelper() local
103 Object* data_obj = call_data->data(); in HandleApiCallHelper()
109 Handle<Object> result = custom.Call(call_data); in HandleApiCallHelper()
276 CallHandlerInfo* call_data = CallHandlerInfo::cast(handler); in HandleApiCallAsFunctionOrConstructor() local
283 FunctionCallbackArguments custom(isolate, call_data->data(), constructor, in HandleApiCallAsFunctionOrConstructor()
286 Handle<Object> result_handle = custom.Call(call_data); in HandleApiCallAsFunctionOrConstructor()
/external/u-boot/tools/
Dproftool.c210 struct trace_call *call_data; in read_calls() local
214 call_list = (struct trace_call *)calloc(count, sizeof(*call_data)); in read_calls()
221 call_data = call_list; in read_calls()
222 for (i = 0; i < count; i++, call_data++) { in read_calls()
223 if (read_data(fin, call_data, sizeof(*call_data))) in read_calls()
/external/grpc-grpc/test/cpp/microbenchmarks/
Dbm_call_create.cc622 } call_data; typedef
626 call_data* calld = static_cast<call_data*>(elem->call_data); in StartTransportStreamOp()
659 call_data* calld = static_cast<call_data*>(elem->call_data); in InitCallElem()
686 sizeof(call_data),
/external/grpc-grpc/src/core/ext/filters/load_reporting/
Dserver_load_reporting_filter.cc215 reinterpret_cast<ServerLoadReportingCallData*>(elem->call_data); in RecvInitialMetadataFilter()
243 reinterpret_cast<ServerLoadReportingCallData*>(elem->call_data); in RecvInitialMetadataReady()
282 reinterpret_cast<ServerLoadReportingCallData*>(elem->call_data); in SendTrailingMetadataFilter()
/external/grpc-grpc/src/cpp/ext/filters/census/
Dclient_filter.cc54 reinterpret_cast<CensusClientCallData*>(elem->call_data); in OnDoneRecvTrailingMetadataCb()
69 reinterpret_cast<CensusClientCallData*>(elem->call_data); in OnDoneRecvMessageCb()
Dserver_filter.cc68 reinterpret_cast<CensusServerCallData*>(elem->call_data); in OnDoneRecvMessageCb()
84 reinterpret_cast<CensusServerCallData*>(elem->call_data); in OnDoneRecvInitialMetadataCb()
/external/v8/src/ia32/
Dcode-stubs-ia32.cc355 Register call_data = ebx; in Generate() local
376 __ push(call_data); in Generate()
387 Register scratch = call_data; in Generate()

12