Home
last modified time | relevance | path

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

12

/third_party/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 …]
Dmessage_compress_filter.cc285 CallData* calld = static_cast<CallData*>(calld_arg); in SendMessageOnComplete() local
286 grpc_slice_buffer_reset_and_unref_internal(&calld->slices_); in SendMessageOnComplete()
288 calld->original_send_message_on_complete_, in SendMessageOnComplete()
352 CallData* calld = static_cast<CallData*>(calld_arg); in FailSendMessageBatchInCallCombiner() local
353 if (calld->send_message_batch_ != nullptr) { in FailSendMessageBatchInCallCombiner()
355 calld->send_message_batch_, GRPC_ERROR_REF(error), in FailSendMessageBatchInCallCombiner()
356 calld->call_combiner_); in FailSendMessageBatchInCallCombiner()
357 calld->send_message_batch_ = nullptr; in FailSendMessageBatchInCallCombiner()
403 CallData* calld = static_cast<CallData*>(elem->call_data); in OnSendMessageNextDone() local
406 FailSendMessageBatchInCallCombiner(calld, error); in OnSendMessageNextDone()
[all …]
/third_party/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 …]
/third_party/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 …]
/third_party/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 …]
/third_party/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 …]
/third_party/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 …]
/third_party/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 …]
/third_party/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 …]
Dclient_filter.cc59 CensusClientCallData* calld = in OnDoneRecvTrailingMetadataCb() local
61 GPR_ASSERT(calld != nullptr); in OnDoneRecvTrailingMetadataCb()
63 GPR_ASSERT(calld->recv_trailing_metadata_ != nullptr); in OnDoneRecvTrailingMetadataCb()
64 FilterTrailingMetadata(calld->recv_trailing_metadata_, in OnDoneRecvTrailingMetadataCb()
65 &calld->elapsed_time_); in OnDoneRecvTrailingMetadataCb()
68 calld->initial_on_done_recv_trailing_metadata_, in OnDoneRecvTrailingMetadataCb()
75 CensusClientCallData* calld = in OnDoneRecvMessageCb() local
79 GPR_ASSERT(calld != nullptr); in OnDoneRecvMessageCb()
82 if ((*calld->recv_message_) != nullptr) { in OnDoneRecvMessageCb()
83 calld->recv_message_count_++; in OnDoneRecvMessageCb()
[all …]
/third_party/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 …]
/third_party/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 …]
/third_party/grpc/src/core/lib/surface/
Dserver.cc183 CallData* calld) = 0;
207 CallData* calld = pending_.front(); in ZombifyPending() local
208 calld->SetState(CallData::CallState::ZOMBIED); in ZombifyPending()
209 calld->KillZombie(); in ZombifyPending()
236 CallData* calld; in RequestCallWithPossiblePublish() member
246 pending_call.calld = pending_.front(); in RequestCallWithPossiblePublish()
256 if (!next_pending.calld->MaybeActivate()) { in RequestCallWithPossiblePublish()
258 next_pending.calld->KillZombie(); in RequestCallWithPossiblePublish()
260 next_pending.calld->Publish(request_queue_index, next_pending.rc); in RequestCallWithPossiblePublish()
267 CallData* calld) override { in MatchOrQueue() argument
[all …]
Dlame_client.cc57 CallData* calld = static_cast<CallData*>(elem->call_data); in lame_start_transport_stream_op_batch() local
60 op, GRPC_ERROR_REF(chand->error), calld->call_combiner); in lame_start_transport_stream_op_batch()
95 CallData* calld = static_cast<CallData*>(elem->call_data); in lame_init_call_elem() local
96 calld->call_combiner = args->call_combiner; in lame_init_call_elem()
/third_party/grpc/src/core/ext/filters/deadline/
Ddeadline_filter.cc297 server_call_data* calld = static_cast<server_call_data*>(elem->call_data); in recv_initial_metadata_ready() local
298 start_timer_if_needed(elem, calld->recv_initial_metadata->deadline); in recv_initial_metadata_ready()
301 calld->next_recv_initial_metadata_ready, in recv_initial_metadata_ready()
308 server_call_data* calld = static_cast<server_call_data*>(elem->call_data); in deadline_server_start_transport_stream_op_batch() local
310 cancel_timer_if_needed(&calld->base.deadline_state); in deadline_server_start_transport_stream_op_batch()
316 calld->next_recv_initial_metadata_ready = in deadline_server_start_transport_stream_op_batch()
318 calld->recv_initial_metadata = in deadline_server_start_transport_stream_op_batch()
320 GRPC_CLOSURE_INIT(&calld->recv_initial_metadata_ready, in deadline_server_start_transport_stream_op_batch()
324 &calld->recv_initial_metadata_ready; in deadline_server_start_transport_stream_op_batch()
332 inject_recv_trailing_metadata_ready(&calld->base.deadline_state, op); in deadline_server_start_transport_stream_op_batch()
/third_party/grpc/src/core/ext/filters/http/
Dclient_authority_filter.cc54 call_data* calld = static_cast<call_data*>(elem->call_data); in client_authority_start_transport_stream_op_batch() local
62 &calld->authority_storage, in client_authority_start_transport_stream_op_batch()
66 calld->call_combiner); in client_authority_start_transport_stream_op_batch()
77 call_data* calld = static_cast<call_data*>(elem->call_data); in client_authority_init_call_elem() local
78 calld->call_combiner = args->call_combiner; in client_authority_init_call_elem()
/third_party/grpc/src/core/ext/filters/client_channel/
Dservice_config_channel_arg_filter.cc78 ServiceConfigChannelArgCallData* calld = in ServiceConfigChannelArgInitCallElem() local
80 new (calld) ServiceConfigChannelArgCallData(elem, args); in ServiceConfigChannelArgInitCallElem()
87 ServiceConfigChannelArgCallData* calld = in ServiceConfigChannelArgDestroyCallElem() local
89 calld->~ServiceConfigChannelArgCallData(); in ServiceConfigChannelArgDestroyCallElem()
Dclient_channel.cc1122 auto* calld = in Destroy() local
1128 if (GPR_LIKELY(calld->retrying_call_ != nullptr)) { in Destroy()
1129 subchannel_call = calld->retrying_call_->subchannel_call(); in Destroy()
1130 calld->retrying_call_->~RetryingCall(); in Destroy()
1133 if (GPR_LIKELY(calld->lb_call_ != nullptr)) { in Destroy()
1134 subchannel_call = calld->lb_call_->subchannel_call(); in Destroy()
1137 calld->~DynamicTerminationFilterCallData(); in Destroy()
1148 auto* calld = in StartTransportStreamOpBatch() local
1153 calld->retrying_call_->StartTransportStreamOpBatch(batch); in StartTransportStreamOpBatch()
1155 calld->lb_call_->StartTransportStreamOpBatch(batch); in StartTransportStreamOpBatch()
[all …]
/third_party/grpc/test/core/end2end/tests/
Dfilter_causes_close.cc200 call_data* calld = static_cast<call_data*>(elem->call_data); in recv_im_ready() local
202 DEBUG_LOCATION, 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()
Dfilter_context.cc230 call_data* calld = static_cast<call_data*>(elem->call_data); in init_call_elem() local
231 calld->context = args->context; in init_call_elem()
238 call_data* calld = static_cast<call_data*>(elem->call_data); in start_transport_stream_op_batch() local
245 GPR_ASSERT(calld->context == batch->payload->context); in start_transport_stream_op_batch()
/third_party/grpc/src/core/ext/xds/
Dxds_client.cc95 T* calld() const { return calld_.get(); } in calld() function in grpc_core::XdsClient::ChannelState::RetryableCall
497 return ads_calld_->calld(); in ads_calld()
502 return lrs_calld_->calld(); in lrs_calld()
506 return ads_calld_->calld() != nullptr; in HasActiveAdsCall()
556 auto* calld = ads_calld_->calld(); in Unsubscribe() local
557 if (calld != nullptr) { in Unsubscribe()
558 calld->Unsubscribe(type_url, name, delay_unsubscription); in Unsubscribe()
559 if (!calld->HasSubscribedResources()) ads_calld_.reset(); in Unsubscribe()
642 RetryableCall* calld = static_cast<RetryableCall*>(arg); in OnRetryTimer() local
644 MutexLock lock(&calld->chand_->xds_client()->mu_); in OnRetryTimer()
[all …]
/third_party/grpc/src/core/ext/filters/client_channel/xds/
Dxds_client.cc91 T* calld() const { return calld_.get(); } in calld() function in grpc_core::XdsClient::ChannelState::RetryableCall
507 return ads_calld_->calld(); in ads_calld()
512 return lrs_calld_->calld(); in lrs_calld()
516 return ads_calld_->calld() != nullptr; in HasActiveAdsCall()
566 ads_calld_->calld()->Unsubscribe(type_url, name, delay_unsubscription); in Unsubscribe()
567 if (!ads_calld_->calld()->HasSubscribedResources()) ads_calld_.reset(); in Unsubscribe()
649 RetryableCall* calld = static_cast<RetryableCall*>(arg); in OnRetryTimer() local
651 calld->chand_->xds_client()->work_serializer_->Run( in OnRetryTimer()
652 [calld, error]() { calld->OnRetryTimerLocked(error); }, DEBUG_LOCATION); in OnRetryTimer()
1262 LrsCallState* lrs_calld = lrs_call->calld(); in OnResponseReceivedLocked()
[all …]
/third_party/grpc/test/cpp/microbenchmarks/
Dbm_call_create.cc613 call_data* calld = static_cast<call_data*>(elem->call_data); in StartTransportStreamOp() local
633 closures.RunClosures(calld->call_combiner); in StartTransportStreamOp()
646 call_data* calld = static_cast<call_data*>(elem->call_data); in InitCallElem() local
647 calld->call_combiner = args->call_combiner; in InitCallElem()
/third_party/gstreamer/gstreamer/
DChangeLog6079 Also, the _get_latency_unlocked() method required being calld

12