| /external/grpc-grpc/src/core/ext/filters/http/message_compress/ |
| D | message_compress_filter.cc | 87 call_data* calld = static_cast<call_data*>(elem->call_data); in skip_compression() local
94 if (calld->message_compression_algorithm == GRPC_MESSAGE_COMPRESS_NONE) { in skip_compression()
110 call_data* calld = static_cast<call_data*>(elem->call_data); in process_send_initial_metadata() local
125 calld->message_compression_algorithm = GRPC_MESSAGE_COMPRESS_NONE; in process_send_initial_metadata()
136 calld->message_compression_algorithm = GRPC_MESSAGE_COMPRESS_NONE; in process_send_initial_metadata()
143 calld->message_compression_algorithm = in process_send_initial_metadata()
154 calld->message_compression_algorithm = in process_send_initial_metadata()
168 initial_metadata, &calld->stream_compression_algorithm_storage, in process_send_initial_metadata()
170 } else if (calld->message_compression_algorithm != in process_send_initial_metadata()
173 initial_metadata, &calld->compression_algorithm_storage, in process_send_initial_metadata()
[all …]
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/ |
| D | client_channel.cc | 1011 static void maybe_cache_send_ops_for_batch(call_data* calld, in maybe_cache_send_ops_for_batch() argument
1018 calld->seen_send_initial_metadata = true; in maybe_cache_send_ops_for_batch()
1019 GPR_ASSERT(calld->send_initial_metadata_storage == nullptr); in maybe_cache_send_ops_for_batch()
1022 calld->send_initial_metadata_storage = (grpc_linked_mdelem*)gpr_arena_alloc( in maybe_cache_send_ops_for_batch()
1023 calld->arena, in maybe_cache_send_ops_for_batch()
1026 &calld->send_initial_metadata, in maybe_cache_send_ops_for_batch()
1027 calld->send_initial_metadata_storage); in maybe_cache_send_ops_for_batch()
1028 calld->send_initial_metadata_flags = in maybe_cache_send_ops_for_batch()
1030 calld->peer_string = batch->payload->send_initial_metadata.peer_string; in maybe_cache_send_ops_for_batch()
1036 gpr_arena_alloc(calld->arena, sizeof(grpc_core::ByteStreamCache))); in maybe_cache_send_ops_for_batch()
[all …]
|
| /external/grpc-grpc/src/core/lib/security/transport/ |
| D | client_auth_filter.cc | 101 call_data* calld = static_cast<call_data*>(elem->call_data); in on_credentials_metadata() local
102 grpc_auth_metadata_context_reset(&calld->auth_md_context); in on_credentials_metadata()
105 GPR_ASSERT(calld->md_array.size <= MAX_CREDENTIALS_METADATA_COUNT); in on_credentials_metadata()
109 for (size_t i = 0; i < calld->md_array.size; ++i) { in on_credentials_metadata()
111 mdb, &calld->md_links[i], in on_credentials_metadata()
112 GRPC_MDELEM_REF(calld->md_array.md[i]))); in on_credentials_metadata()
121 calld->call_combiner); in on_credentials_metadata()
123 GRPC_CALL_STACK_UNREF(calld->owning_call, "get_request_metadata"); in on_credentials_metadata()
165 call_data* calld = static_cast<call_data*>(elem->call_data); in cancel_get_request_metadata() local
168 calld->creds, &calld->md_array, GRPC_ERROR_REF(error)); in cancel_get_request_metadata()
[all …]
|
| D | server_auth_filter.cc | 85 call_data* calld = static_cast<call_data*>(elem->call_data); in remove_consumed_md() local
87 for (i = 0; i < calld->num_consumed_md; i++) { in remove_consumed_md()
88 const grpc_metadata* consumed_md = &calld->consumed_md[i]; in remove_consumed_md()
102 call_data* calld = static_cast<call_data*>(elem->call_data); in on_md_processing_done_inner() local
103 grpc_transport_stream_op_batch* batch = calld->recv_initial_metadata_batch; in on_md_processing_done_inner()
111 calld->consumed_md = consumed_md; in on_md_processing_done_inner()
112 calld->num_consumed_md = num_consumed_md; in on_md_processing_done_inner()
117 calld->error = GRPC_ERROR_REF(error); in on_md_processing_done_inner()
118 GRPC_CLOSURE_SCHED(calld->original_recv_initial_metadata_ready, error); in on_md_processing_done_inner()
127 call_data* calld = static_cast<call_data*>(elem->call_data); in on_md_processing_done() local
[all …]
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/ |
| D | client_load_reporting_filter.cc | 55 call_data* calld = static_cast<call_data*>(arg); in on_complete_for_send() local
57 calld->send_initial_metadata_succeeded = true; in on_complete_for_send()
59 GRPC_CLOSURE_RUN(calld->original_on_complete_for_send, GRPC_ERROR_REF(error)); in on_complete_for_send()
63 call_data* calld = static_cast<call_data*>(arg); in recv_initial_metadata_ready() local
65 calld->recv_initial_metadata_succeeded = true; in recv_initial_metadata_ready()
67 GRPC_CLOSURE_RUN(calld->original_recv_initial_metadata_ready, in recv_initial_metadata_ready()
73 call_data* calld = static_cast<call_data*>(elem->call_data); in init_call_elem() local
77 calld->client_stats = static_cast<grpc_core::GrpcLbClientStats*>( in init_call_elem()
81 calld->client_stats->AddCallStarted(); in init_call_elem()
89 call_data* calld = static_cast<call_data*>(elem->call_data); in destroy_call_elem() local
[all …]
|
| /external/grpc-grpc/src/core/ext/filters/http/server/ |
| D | http_server_filter.cc | 103 call_data* calld = static_cast<call_data*>(elem->call_data); in hs_filter_incoming_metadata() local
109 *calld->recv_initial_metadata_flags &= in hs_filter_incoming_metadata()
114 *calld->recv_initial_metadata_flags &= in hs_filter_incoming_metadata()
116 *calld->recv_initial_metadata_flags |= in hs_filter_incoming_metadata()
120 *calld->recv_initial_metadata_flags |= in hs_filter_incoming_metadata()
122 *calld->recv_initial_metadata_flags &= in hs_filter_incoming_metadata()
207 } else if (*calld->recv_initial_metadata_flags & in hs_filter_incoming_metadata()
240 calld->read_stream.Init(&read_slice_buffer, 0); in hs_filter_incoming_metadata()
242 calld->have_read_stream = true; in hs_filter_incoming_metadata()
280 call_data* calld = static_cast<call_data*>(elem->call_data); in hs_recv_initial_metadata_ready() local
[all …]
|
| /external/grpc-grpc/src/core/lib/channel/ |
| D | connected_channel.cc | 68 static void intercept_callback(call_data* calld, callback_state* state, in intercept_callback() argument
72 state->call_combiner = calld->call_combiner; in intercept_callback()
81 call_data* calld, grpc_transport_stream_op_batch* batch) { in get_state_for_batch() argument
82 if (batch->send_initial_metadata) return &calld->on_complete[0]; in get_state_for_batch()
83 if (batch->send_message) return &calld->on_complete[1]; in get_state_for_batch()
84 if (batch->send_trailing_metadata) return &calld->on_complete[2]; in get_state_for_batch()
85 if (batch->recv_initial_metadata) return &calld->on_complete[3]; in get_state_for_batch()
86 if (batch->recv_message) return &calld->on_complete[4]; in get_state_for_batch()
87 if (batch->recv_trailing_metadata) return &calld->on_complete[5]; in get_state_for_batch()
94 #define TRANSPORT_STREAM_FROM_CALL_DATA(calld) ((grpc_stream*)((calld) + 1)) argument
[all …]
|
| /external/grpc-grpc/src/core/ext/filters/http/client/ |
| D | http_client_filter.cc | 153 call_data* calld = static_cast<call_data*>(elem->call_data); in recv_initial_metadata_ready() local
155 error = client_filter_incoming_metadata(elem, calld->recv_initial_metadata); in recv_initial_metadata_ready()
156 calld->recv_initial_metadata_error = GRPC_ERROR_REF(error); in recv_initial_metadata_ready()
160 GRPC_CLOSURE_RUN(calld->original_recv_initial_metadata_ready, error); in recv_initial_metadata_ready()
165 call_data* calld = static_cast<call_data*>(elem->call_data); in recv_trailing_metadata_ready() local
168 client_filter_incoming_metadata(elem, calld->recv_trailing_metadata); in recv_trailing_metadata_ready()
173 error, GRPC_ERROR_REF(calld->recv_initial_metadata_error)); in recv_trailing_metadata_ready()
174 GRPC_CLOSURE_RUN(calld->original_recv_trailing_metadata_ready, error); in recv_trailing_metadata_ready()
179 call_data* calld = static_cast<call_data*>(elem->call_data); in send_message_on_complete() local
180 calld->send_message_cache.Destroy(); in send_message_on_complete()
[all …]
|
| /external/grpc-grpc/src/core/ext/filters/message_size/ |
| D | message_size_filter.cc | 127 call_data* calld = static_cast<call_data*>(elem->call_data); in recv_message_ready() local
128 if (*calld->recv_message != nullptr && calld->limits.max_recv_size >= 0 && in recv_message_ready()
129 (*calld->recv_message)->length() > in recv_message_ready()
130 static_cast<size_t>(calld->limits.max_recv_size)) { in recv_message_ready()
134 (*calld->recv_message)->length(), calld->limits.max_recv_size); in recv_message_ready()
138 GRPC_ERROR_UNREF(calld->error); in recv_message_ready()
144 calld->error = GRPC_ERROR_REF(error); in recv_message_ready()
150 GRPC_CLOSURE_RUN(calld->next_recv_message_ready, error); in recv_message_ready()
157 call_data* calld = static_cast<call_data*>(elem->call_data); in recv_trailing_metadata_ready() local
159 grpc_error_add_child(GRPC_ERROR_REF(error), GRPC_ERROR_REF(calld->error)); in recv_trailing_metadata_ready()
[all …]
|
| /external/grpc-grpc/src/core/lib/surface/ |
| D | server.cc | 232 static void publish_new_rpc(void* calld, grpc_error* error);
337 call_data* calld = rm->pending_head; in request_matcher_zombify_all_pending_calls() local
338 rm->pending_head = calld->pending_next; in request_matcher_zombify_all_pending_calls()
339 gpr_atm_no_barrier_store(&calld->state, ZOMBIED); in request_matcher_zombify_all_pending_calls()
341 &calld->kill_zombie_closure, kill_zombie, in request_matcher_zombify_all_pending_calls()
342 grpc_call_stack_element(grpc_call_get_call_stack(calld->call), 0), in request_matcher_zombify_all_pending_calls()
344 GRPC_CLOSURE_SCHED(&calld->kill_zombie_closure, GRPC_ERROR_NONE); 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() argument
450 grpc_call_set_completion_queue(calld->call, rc->cq_bound_to_call); in publish_call()
451 grpc_call* call = calld->call; in publish_call()
[all …]
|
| D | lame_client.cc | 55 CallData* calld = static_cast<CallData*>(elem->call_data); in fill_metadata() local
57 if (!calld->filled_metadata.compare_exchange_strong( in fill_metadata()
65 calld->status.md = grpc_mdelem_from_slices( in fill_metadata()
67 calld->details.md = grpc_mdelem_from_slices( in fill_metadata()
70 calld->status.prev = calld->details.next = nullptr; in fill_metadata()
71 calld->status.next = &calld->details; in fill_metadata()
72 calld->details.prev = &calld->status; in fill_metadata()
73 mdb->list.head = &calld->status; in fill_metadata()
74 mdb->list.tail = &calld->details; in fill_metadata()
81 CallData* calld = static_cast<CallData*>(elem->call_data); in lame_start_transport_stream_op_batch() local
[all …]
|
| /external/grpc-grpc/src/core/ext/filters/load_reporting/ |
| D | server_load_reporting_filter.cc | 214 ServerLoadReportingCallData* calld = in RecvInitialMetadataFilter() local
217 calld->service_method_ = grpc_slice_ref_internal(GRPC_MDVALUE(md)); in RecvInitialMetadataFilter()
218 } else if (calld->target_host_ == nullptr && in RecvInitialMetadataFilter()
221 calld->target_host_len_ = GRPC_SLICE_LENGTH(target_host_slice); in RecvInitialMetadataFilter()
222 calld->target_host_ = in RecvInitialMetadataFilter()
223 reinterpret_cast<char*>(gpr_zalloc(calld->target_host_len_)); in RecvInitialMetadataFilter()
224 for (size_t i = 0; i < calld->target_host_len_; ++i) { in RecvInitialMetadataFilter()
225 calld->target_host_[i] = static_cast<char>( in RecvInitialMetadataFilter()
229 if (calld->client_ip_and_lr_token_ == nullptr) { in RecvInitialMetadataFilter()
230 calld->StoreClientIpAndLrToken( in RecvInitialMetadataFilter()
[all …]
|
| /external/grpc-grpc/src/cpp/ext/filters/census/ |
| D | server_filter.cc | 67 CensusServerCallData* calld = in OnDoneRecvMessageCb() local
71 GPR_ASSERT(calld != nullptr); in OnDoneRecvMessageCb()
74 if ((*calld->recv_message_) != nullptr) { in OnDoneRecvMessageCb()
75 ++calld->recv_message_count_; in OnDoneRecvMessageCb()
77 GRPC_CLOSURE_RUN(calld->initial_on_done_recv_message_, GRPC_ERROR_REF(error)); in OnDoneRecvMessageCb()
83 CensusServerCallData* calld = in OnDoneRecvInitialMetadataCb() local
85 GPR_ASSERT(calld != nullptr); in OnDoneRecvInitialMetadataCb()
87 grpc_metadata_batch* initial_metadata = calld->recv_initial_metadata_; in OnDoneRecvInitialMetadataCb()
94 calld->path_ = grpc_slice_ref_internal(sml.path); in OnDoneRecvInitialMetadataCb()
95 calld->method_ = GetMethod(&calld->path_); in OnDoneRecvInitialMetadataCb()
[all …]
|
| D | client_filter.cc | 53 CensusClientCallData* calld = in OnDoneRecvTrailingMetadataCb() local
55 GPR_ASSERT(calld != nullptr); in OnDoneRecvTrailingMetadataCb()
57 GPR_ASSERT(calld->recv_trailing_metadata_ != nullptr); in OnDoneRecvTrailingMetadataCb()
58 FilterTrailingMetadata(calld->recv_trailing_metadata_, in OnDoneRecvTrailingMetadataCb()
59 &calld->elapsed_time_); in OnDoneRecvTrailingMetadataCb()
61 GRPC_CLOSURE_RUN(calld->initial_on_done_recv_trailing_metadata_, in OnDoneRecvTrailingMetadataCb()
68 CensusClientCallData* calld = in OnDoneRecvMessageCb() local
72 GPR_ASSERT(calld != nullptr); in OnDoneRecvMessageCb()
75 if ((*calld->recv_message_) != nullptr) { in OnDoneRecvMessageCb()
76 calld->recv_message_count_++; in OnDoneRecvMessageCb()
[all …]
|
| /external/grpc-grpc/src/core/ext/filters/workarounds/ |
| D | workaround_cronet_compression_filter.cc | 59 call_data* calld = static_cast<call_data*>(elem->call_data); in recv_initial_metadata_ready() local
63 if (get_user_agent_mdelem(calld->recv_initial_metadata, &md)) { in recv_initial_metadata_ready()
67 calld->workaround_active = true; in recv_initial_metadata_ready()
73 GRPC_CLOSURE_RUN(calld->next_recv_initial_metadata_ready, in recv_initial_metadata_ready()
80 call_data* calld = static_cast<call_data*>(elem->call_data); in start_transport_stream_op_batch() local
84 calld->next_recv_initial_metadata_ready = in start_transport_stream_op_batch()
87 &calld->recv_initial_metadata_ready; in start_transport_stream_op_batch()
88 calld->recv_initial_metadata = in start_transport_stream_op_batch()
95 if (calld->workaround_active) { in start_transport_stream_op_batch()
109 call_data* calld = static_cast<call_data*>(elem->call_data); in init_call_elem() local
[all …]
|
| /external/grpc-grpc/src/core/ext/filters/deadline/ |
| D | deadline_filter.cc | 295 server_call_data* calld = static_cast<server_call_data*>(elem->call_data); in recv_initial_metadata_ready() local
296 start_timer_if_needed(elem, calld->recv_initial_metadata->deadline); in recv_initial_metadata_ready()
298 GRPC_CLOSURE_RUN(calld->next_recv_initial_metadata_ready, 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() local
307 cancel_timer_if_needed(&calld->base.deadline_state); in server_start_transport_stream_op_batch()
313 calld->next_recv_initial_metadata_ready = in server_start_transport_stream_op_batch()
315 calld->recv_initial_metadata = in server_start_transport_stream_op_batch()
317 GRPC_CLOSURE_INIT(&calld->recv_initial_metadata_ready, in server_start_transport_stream_op_batch()
321 &calld->recv_initial_metadata_ready; in server_start_transport_stream_op_batch()
329 inject_recv_trailing_metadata_ready(&calld->base.deadline_state, op); in server_start_transport_stream_op_batch()
|
| /external/grpc-grpc/src/core/ext/filters/http/ |
| D | client_authority_filter.cc | 53 call_data* calld = static_cast<call_data*>(elem->call_data); in authority_start_transport_stream_op_batch() local
61 initial_metadata, &calld->authority_storage, in authority_start_transport_stream_op_batch()
67 calld->call_combiner); in authority_start_transport_stream_op_batch()
78 call_data* calld = static_cast<call_data*>(elem->call_data); in init_call_elem() local
79 calld->call_combiner = args->call_combiner; in init_call_elem()
|
| /external/grpc-grpc/test/core/end2end/tests/ |
| D | filter_causes_close.cc | 200 call_data* calld = static_cast<call_data*>(elem->call_data); in recv_im_ready() local
202 calld->recv_im_ready, in recv_im_ready()
211 call_data* calld = static_cast<call_data*>(elem->call_data); in start_transport_stream_op_batch() local
213 calld->recv_im_ready = in start_transport_stream_op_batch()
|
| /external/grpc-grpc/test/cpp/microbenchmarks/ |
| D | bm_call_create.cc | 626 call_data* calld = static_cast<call_data*>(elem->call_data); in StartTransportStreamOp() local
646 closures.RunClosures(calld->call_combiner); in StartTransportStreamOp()
659 call_data* calld = static_cast<call_data*>(elem->call_data); in InitCallElem() local
660 calld->call_combiner = args->call_combiner; in InitCallElem()
|