Home
last modified time | relevance | path

Searched refs:calld (Results 1 – 25 of 39) sorted by relevance

12

/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
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/
Dclient_channel.cc1011 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/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
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/lib/security/transport/
Dclient_auth_filter.cc101 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 …]
Dserver_auth_filter.cc85 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/rust/crates/grpcio-sys/grpc/src/core/ext/filters/http/message_compress/
Dmessage_decompress_filter.cc153 CallData* calld = static_cast<CallData*>(arg); in OnRecvInitialMetadataReady() local
156 calld->recv_initial_metadata_->idx.named.grpc_encoding; in OnRecvInitialMetadataReady()
158 calld->algorithm_ = DecodeMessageCompressionAlgorithm(grpc_encoding->md); in OnRecvInitialMetadataReady()
161 calld->MaybeResumeOnRecvMessageReady(); in OnRecvInitialMetadataReady()
162 calld->MaybeResumeOnRecvTrailingMetadataReady(); in OnRecvInitialMetadataReady()
163 grpc_closure* closure = calld->original_recv_initial_metadata_ready_; in OnRecvInitialMetadataReady()
164 calld->original_recv_initial_metadata_ready_ = nullptr; in OnRecvInitialMetadataReady()
178 CallData* calld = static_cast<CallData*>(arg); in OnRecvMessageReady() local
180 if (calld->original_recv_initial_metadata_ready_ != nullptr) { in OnRecvMessageReady()
181 calld->seen_recv_message_ready_ = true; in OnRecvMessageReady()
[all …]
/external/rust/crates/grpcio-sys/grpc/src/core/lib/security/transport/
Dserver_auth_filter.cc121 call_data* calld = static_cast<call_data*>(elem->call_data); in remove_consumed_md() local
123 for (i = 0; i < calld->num_consumed_md; i++) { in remove_consumed_md()
124 const grpc_metadata* consumed_md = &calld->consumed_md[i]; in remove_consumed_md()
139 call_data* calld = static_cast<call_data*>(elem->call_data); in on_md_processing_done_inner() local
140 grpc_transport_stream_op_batch* batch = calld->recv_initial_metadata_batch; in on_md_processing_done_inner()
148 calld->consumed_md = consumed_md; in on_md_processing_done_inner()
149 calld->num_consumed_md = num_consumed_md; in on_md_processing_done_inner()
154 calld->recv_initial_metadata_error = GRPC_ERROR_REF(error); in on_md_processing_done_inner()
155 grpc_closure* closure = calld->original_recv_initial_metadata_ready; in on_md_processing_done_inner()
156 calld->original_recv_initial_metadata_ready = nullptr; in on_md_processing_done_inner()
[all …]
Dclient_auth_filter.cc163 call_data* calld = static_cast<call_data*>(elem->call_data); in on_credentials_metadata() local
164 grpc_auth_metadata_context_reset(&calld->auth_md_context); in on_credentials_metadata()
167 GPR_ASSERT(calld->md_array.size <= MAX_CREDENTIALS_METADATA_COUNT); in on_credentials_metadata()
171 for (size_t i = 0; i < calld->md_array.size; ++i) { in on_credentials_metadata()
173 mdb, &calld->md_links[i], in on_credentials_metadata()
174 GRPC_MDELEM_REF(calld->md_array.md[i]))); in on_credentials_metadata()
183 calld->call_combiner); in on_credentials_metadata()
185 GRPC_CALL_STACK_UNREF(calld->owning_call, "get_request_metadata"); in on_credentials_metadata()
230 call_data* calld = static_cast<call_data*>(elem->call_data); in cancel_get_request_metadata() local
232 calld->creds->cancel_get_request_metadata(&calld->md_array, in cancel_get_request_metadata()
[all …]
/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
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/
Dconnected_channel.cc68 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/rust/crates/grpcio-sys/grpc/src/core/ext/filters/http/server/
Dhttp_server_filter.cc154 call_data* calld = static_cast<call_data*>(elem->call_data); in hs_filter_incoming_metadata() local
160 *calld->recv_initial_metadata_flags &= in hs_filter_incoming_metadata()
165 *calld->recv_initial_metadata_flags &= in hs_filter_incoming_metadata()
167 *calld->recv_initial_metadata_flags |= in hs_filter_incoming_metadata()
171 *calld->recv_initial_metadata_flags |= in hs_filter_incoming_metadata()
173 *calld->recv_initial_metadata_flags &= in hs_filter_incoming_metadata()
261 } else if (*calld->recv_initial_metadata_flags & in hs_filter_incoming_metadata()
294 calld->read_stream.Init(&read_slice_buffer, 0); in hs_filter_incoming_metadata()
296 calld->have_read_stream = true; in hs_filter_incoming_metadata()
335 call_data* calld = static_cast<call_data*>(elem->call_data); in hs_recv_initial_metadata_ready() local
[all …]
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/http/client/
Dhttp_client_filter.cc187 call_data* calld = static_cast<call_data*>(elem->call_data); in recv_initial_metadata_ready() local
189 error = client_filter_incoming_metadata(calld->recv_initial_metadata); in recv_initial_metadata_ready()
190 calld->recv_initial_metadata_error = GRPC_ERROR_REF(error); in recv_initial_metadata_ready()
194 grpc_closure* closure = calld->original_recv_initial_metadata_ready; in recv_initial_metadata_ready()
195 calld->original_recv_initial_metadata_ready = nullptr; in recv_initial_metadata_ready()
196 if (calld->seen_recv_trailing_metadata_ready) { in recv_initial_metadata_ready()
198 calld->call_combiner, &calld->recv_trailing_metadata_ready, in recv_initial_metadata_ready()
199 calld->recv_trailing_metadata_error, "continue recv_trailing_metadata"); in recv_initial_metadata_ready()
206 call_data* calld = static_cast<call_data*>(elem->call_data); in recv_trailing_metadata_ready() local
207 if (calld->original_recv_initial_metadata_ready != nullptr) { in recv_trailing_metadata_ready()
[all …]
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/
Dclient_load_reporting_filter.cc58 call_data* calld = static_cast<call_data*>(arg); in on_complete_for_send() local
60 calld->send_initial_metadata_succeeded = true; in on_complete_for_send()
62 grpc_core::Closure::Run(DEBUG_LOCATION, calld->original_on_complete_for_send, in on_complete_for_send()
67 call_data* calld = static_cast<call_data*>(arg); in recv_initial_metadata_ready() local
69 calld->recv_initial_metadata_succeeded = true; in recv_initial_metadata_ready()
72 calld->original_recv_initial_metadata_ready, in recv_initial_metadata_ready()
86 call_data* calld = static_cast<call_data*>(elem->call_data); in clr_destroy_call_elem() local
87 if (calld->client_stats != nullptr) { in clr_destroy_call_elem()
90 calld->client_stats->AddCallFinished( in clr_destroy_call_elem()
91 !calld->send_initial_metadata_succeeded /* client_failed_to_send */, in clr_destroy_call_elem()
[all …]
/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
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/rust/crates/grpcio-sys/grpc/src/core/lib/channel/
Dconnected_channel.cc67 static void intercept_callback(call_data* calld, callback_state* state, in intercept_callback() argument
71 state->call_combiner = calld->call_combiner; in intercept_callback()
80 call_data* calld, grpc_transport_stream_op_batch* batch) { in get_state_for_batch() argument
81 if (batch->send_initial_metadata) return &calld->on_complete[0]; in get_state_for_batch()
82 if (batch->send_message) return &calld->on_complete[1]; in get_state_for_batch()
83 if (batch->send_trailing_metadata) return &calld->on_complete[2]; in get_state_for_batch()
84 if (batch->recv_initial_metadata) return &calld->on_complete[3]; in get_state_for_batch()
85 if (batch->recv_message) return &calld->on_complete[4]; in get_state_for_batch()
86 if (batch->recv_trailing_metadata) return &calld->on_complete[5]; in get_state_for_batch()
93 #define TRANSPORT_STREAM_FROM_CALL_DATA(calld) \ argument
[all …]
/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
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/rust/crates/grpcio-sys/grpc/src/core/ext/filters/message_size/
Dmessage_size_filter.cc199 call_data* calld = static_cast<call_data*>(elem->call_data); in recv_message_ready() local
200 if (*calld->recv_message != nullptr && calld->limits.max_recv_size >= 0 && in recv_message_ready()
201 (*calld->recv_message)->length() > in recv_message_ready()
202 static_cast<size_t>(calld->limits.max_recv_size)) { in recv_message_ready()
206 (*calld->recv_message)->length(), in recv_message_ready()
207 calld->limits.max_recv_size) in recv_message_ready()
211 GRPC_ERROR_UNREF(calld->error); in recv_message_ready()
212 calld->error = GRPC_ERROR_REF(error); in recv_message_ready()
217 grpc_closure* closure = calld->next_recv_message_ready; in recv_message_ready()
218 calld->next_recv_message_ready = nullptr; in recv_message_ready()
[all …]
/external/grpc-grpc/src/core/lib/surface/
Dserver.cc232 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 …]
Dlame_client.cc55 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/cpp/ext/filters/census/
Dserver_filter.cc67 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 …]
/external/grpc-grpc/src/core/ext/filters/load_reporting/
Dserver_load_reporting_filter.cc214 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/rust/crates/grpcio-sys/grpc/src/cpp/ext/filters/census/
Dserver_filter.cc67 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_core::Closure::Run(DEBUG_LOCATION, calld->initial_on_done_recv_message_, in OnDoneRecvMessageCb()
84 CensusServerCallData* calld = in OnDoneRecvInitialMetadataCb() local
86 GPR_ASSERT(calld != nullptr); in OnDoneRecvInitialMetadataCb()
88 grpc_metadata_batch* initial_metadata = calld->recv_initial_metadata_; in OnDoneRecvInitialMetadataCb()
95 calld->path_ = grpc_slice_ref_internal(sml.path); in OnDoneRecvInitialMetadataCb()
96 calld->method_ = GetMethod(&calld->path_); in OnDoneRecvInitialMetadataCb()
[all …]
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/load_reporting/
Dserver_load_reporting_filter.cc209 ServerLoadReportingCallData* calld = in RecvInitialMetadataFilter() local
212 calld->service_method_ = grpc_slice_ref_internal(GRPC_MDVALUE(md)); in RecvInitialMetadataFilter()
213 } else if (calld->target_host_ == nullptr && in RecvInitialMetadataFilter()
216 calld->target_host_len_ = GRPC_SLICE_LENGTH(target_host_slice); in RecvInitialMetadataFilter()
217 calld->target_host_ = in RecvInitialMetadataFilter()
218 reinterpret_cast<char*>(gpr_zalloc(calld->target_host_len_)); in RecvInitialMetadataFilter()
219 for (size_t i = 0; i < calld->target_host_len_; ++i) { in RecvInitialMetadataFilter()
220 calld->target_host_[i] = static_cast<char>( in RecvInitialMetadataFilter()
225 if (calld->client_ip_and_lr_token_ == nullptr) { in RecvInitialMetadataFilter()
226 calld->StoreClientIpAndLrToken( in RecvInitialMetadataFilter()
[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
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/rust/crates/grpcio-sys/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
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()
74 calld->next_recv_initial_metadata_ready, in recv_initial_metadata_ready()
81 call_data* calld = static_cast<call_data*>(elem->call_data); in cronet_compression_start_transport_stream_op_batch() local
85 calld->next_recv_initial_metadata_ready = in cronet_compression_start_transport_stream_op_batch()
88 &calld->recv_initial_metadata_ready; in cronet_compression_start_transport_stream_op_batch()
89 calld->recv_initial_metadata = in cronet_compression_start_transport_stream_op_batch()
96 if (calld->workaround_active) { in cronet_compression_start_transport_stream_op_batch()
110 call_data* calld = static_cast<call_data*>(elem->call_data); in cronet_compression_init_call_elem() local
[all …]

12