| /external/grpc-grpc/src/core/client_channel/ |
| D | retry_filter_legacy_call_data.cc | 94 RetryFilter::LegacyCallData* calld) { in MakeLbCallDestructionClosure()
118 RetryFilter::LegacyCallData* calld, bool is_transparent_retry) in CallAttempt()
679 auto* calld = call_attempt->calld_; in OnPerAttemptRecvTimerLocked() local
778 auto* calld = call_attempt_->calld_; in FreeCachedSendOpDataForCompletedBatch() local
837 RetryFilter::LegacyCallData* calld = call_attempt->calld_; in RecvInitialMetadataReady() local
936 RetryFilter::LegacyCallData* calld = call_attempt->calld_; in RecvMessageReady() local
1031 auto* calld = call_attempt_->calld_; in MaybeAddClosureForRecvTrailingMetadataReady() local
1098 auto* calld = call_attempt_->calld_; in AddClosuresToFailUnstartedPendingBatches() local
1130 RetryFilter::LegacyCallData* calld = call_attempt->calld_; in RecvTrailingMetadataReady() local
1233 auto* calld = call_attempt_->calld_; in AddClosuresForCompletedPendingBatch() local
[all …]
|
| D | client_channel_filter.cc | 510 auto* calld = static_cast<CallData*>(elem->call_data); in Destroy() local
526 auto* calld = static_cast<CallData*>(elem->call_data); in StartTransportStreamOpBatch() local
532 auto* calld = static_cast<CallData*>(elem->call_data); in SetPollent() local
1329 auto* calld = GetContext<Arena>()->ManagedNew<PromiseBasedCallData>(chand); in MakeCallPromise() local
2242 auto* calld = static_cast<FilterBasedCallData*>(elem->call_data); in Destroy() local
2256 auto* calld = static_cast<FilterBasedCallData*>(elem->call_data); in StartTransportStreamOpBatch() local
2364 auto* calld = static_cast<FilterBasedCallData*>(elem->call_data); in SetPollent() local
2400 auto* calld = in FailPendingBatchInCallCombiner() local
2446 auto* calld = in ResumePendingBatchInCallCombiner() local
2486 explicit ResolverQueuedCallCanceller(FilterBasedCallData* calld) in ResolverQueuedCallCanceller()
[all …]
|
| /external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/ |
| D | retry_filter.cc | 641 grpc_closure* MakeLbCallDestructionClosure(CallData* calld) { in MakeLbCallDestructionClosure()
664 RetryFilter::CallData::CallAttempt::CallAttempt(CallData* calld, in CallAttempt()
1224 auto* calld = call_attempt->calld_; in OnPerAttemptRecvTimerLocked() local
1322 auto* calld = call_attempt_->calld_; in FreeCachedSendOpDataForCompletedBatch() local
1381 CallData* calld = call_attempt->calld_; in RecvInitialMetadataReady() local
1480 CallData* calld = call_attempt->calld_; in RecvMessageReady() local
1575 auto* calld = call_attempt_->calld_; in MaybeAddClosureForRecvTrailingMetadataReady() local
1642 auto* calld = call_attempt_->calld_; in AddClosuresToFailUnstartedPendingBatches() local
1674 CallData* calld = call_attempt->calld_; in RecvTrailingMetadataReady() local
1777 auto* calld = call_attempt_->calld_; in AddClosuresForCompletedPendingBatch() local
[all …]
|
| D | client_channel.cc | 367 auto* calld = static_cast<CallData*>(elem->call_data); in Destroy() local
383 auto* calld = static_cast<CallData*>(elem->call_data); in StartTransportStreamOpBatch() local
389 auto* calld = static_cast<CallData*>(elem->call_data); in SetPollent() local
1973 auto* calld = static_cast<FilterBasedCallData*>(elem->call_data); in Destroy() local
1987 auto* calld = static_cast<FilterBasedCallData*>(elem->call_data); in StartTransportStreamOpBatch() local
2095 auto* calld = static_cast<FilterBasedCallData*>(elem->call_data); in SetPollent() local
2131 auto* calld = in FailPendingBatchInCallCombiner() local
2177 auto* calld = in ResumePendingBatchInCallCombiner() local
2216 explicit ResolverQueuedCallCanceller(FilterBasedCallData* calld) in ResolverQueuedCallCanceller()
2227 auto* calld = self->calld_; in CancelLocked() local
[all …]
|
| /external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/ext/filters/rbac/ |
| D | rbac_filter.cc | 59 auto* calld = static_cast<CallData*>(elem->call_data); in Destroy() local
65 CallData* calld = static_cast<CallData*>(elem->call_data); in StartTransportStreamOpBatch() local
88 CallData* calld = static_cast<CallData*>(elem->call_data); in RecvInitialMetadataReady() local
|
| /external/grpc-grpc/test/core/end2end/tests/ |
| D | retry_recv_trailing_metadata_error.cc | 60 auto* calld = static_cast<CallData*>(elem->call_data); in Destroy() local
66 auto* calld = static_cast<CallData*>(elem->call_data); in StartTransportStreamOpBatch() local
84 auto* calld = static_cast<CallData*>(arg); in RecvTrailingMetadataReady() local
|
| D | filter_context.cc | 53 call_data* calld = static_cast<call_data*>(elem->call_data); in init_call_elem() local
61 call_data* calld = static_cast<call_data*>(elem->call_data); in start_transport_stream_op_batch() local
|
| D | retry_recv_message_replay.cc | 63 auto* calld = static_cast<CallData*>(elem->call_data); in Destroy() local
70 auto* calld = static_cast<CallData*>(elem->call_data); in StartTransportStreamOpBatch() local
|
| D | retry_send_op_fails.cc | 64 auto* calld = static_cast<CallData*>(elem->call_data); in Destroy() local
71 auto* calld = static_cast<CallData*>(elem->call_data); in StartTransportStreamOpBatch() local
|
| D | retry_cancel_with_multiple_send_batches.cc | 124 auto* calld = static_cast<CallData*>(elem->call_data); in Destroy() local
130 auto* calld = static_cast<CallData*>(elem->call_data); in StartTransportStreamOpBatch() local
|
| D | retry_transparent_not_sent_on_wire.cc | 65 auto* calld = static_cast<CallData*>(elem->call_data); in Destroy() local
72 auto* calld = static_cast<CallData*>(elem->call_data); in StartTransportStreamOpBatch() local
|
| D | retry_transparent_goaway.cc | 63 auto* calld = static_cast<CallData*>(elem->call_data); in Destroy() local
70 auto* calld = static_cast<CallData*>(elem->call_data); in StartTransportStreamOpBatch() local
|
| D | filter_causes_close.cc | 61 call_data* calld = static_cast<call_data*>(elem->call_data); in recv_im_ready() local
72 call_data* calld = static_cast<call_data*>(elem->call_data); in start_transport_stream_op_batch() local
|
| /external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/lib/channel/ |
| D | connected_channel.cc | 116 static void intercept_callback(call_data* calld, callback_state* state, in intercept_callback()
129 call_data* calld, grpc_transport_stream_op_batch* batch) { in get_state_for_batch()
142 #define TRANSPORT_STREAM_FROM_CALL_DATA(calld) \ argument
153 call_data* calld = static_cast<call_data*>(elem->call_data); in connected_channel_start_transport_stream_op_batch() local
200 call_data* calld = static_cast<call_data*>(elem->call_data); in connected_channel_init_call_elem() local
212 call_data* calld = static_cast<call_data*>(elem->call_data); in set_pollset_or_pollset_set() local
222 call_data* calld = static_cast<call_data*>(elem->call_data); in connected_channel_destroy_call_elem() local
|
| /external/grpc-grpc/src/core/lib/channel/ |
| D | connected_channel.cc | 113 static void intercept_callback(call_data* calld, callback_state* state, in intercept_callback()
126 call_data* calld, grpc_transport_stream_op_batch* batch) { in get_state_for_batch()
139 #define TRANSPORT_STREAM_FROM_CALL_DATA(calld) \ argument
150 call_data* calld = static_cast<call_data*>(elem->call_data); in connected_channel_start_transport_stream_op_batch() local
197 call_data* calld = static_cast<call_data*>(elem->call_data); in connected_channel_init_call_elem() local
208 call_data* calld = static_cast<call_data*>(elem->call_data); in set_pollset_or_pollset_set() local
218 call_data* calld = static_cast<call_data*>(elem->call_data); in connected_channel_destroy_call_elem() local
|
| /external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/lib/surface/ |
| D | server.cc | 272 [](CallData* calld) { in ZombifyPending()
327 [&mr](CallData* calld) { in RequestCallWithPossiblePublish()
343 CallData* calld) override { in MatchOrQueue()
501 CallData* calld) override { in MatchOrQueue()
555 CallData* calld) override { in MatchOrQueue()
1280 auto* calld = static_cast<Server::CallData*>(elem->call_data); in AcceptStream() local
1524 auto* calld = static_cast<Server::CallData*>(call_elem->call_data); in PublishNewRpc() local
1592 auto* calld = static_cast<Server::CallData*>(elem->call_data); in RecvInitialMetadataBatchComplete() local
1624 CallData* calld = static_cast<CallData*>(elem->call_data); in RecvInitialMetadataReady() local
1656 CallData* calld = static_cast<CallData*>(elem->call_data); in RecvTrailingMetadataReady() local
[all …]
|
| /external/grpc-grpc/test/core/transport/chttp2/ |
| D | streams_not_seen_test.cc | 123 auto* calld = static_cast<CallData*>(elem->call_data); in Destroy() local
129 auto* calld = static_cast<CallData*>(elem->call_data); in StartTransportStreamOpBatch() local
158 auto* calld = static_cast<CallData*>(arg); in RecvInitialMetadataReady() local
166 auto* calld = static_cast<CallData*>(arg); in RecvTrailingMetadataReady() local
|
| /external/grpc-grpc/src/core/lib/surface/ |
| D | server.cc | 366 CallData* calld) override { in MatchOrQueue()
414 CallData* calld; member
643 CallData* calld) override { in MatchOrQueue()
690 CallData* calld) override { in MatchOrQueue()
1410 auto* calld = static_cast<Server::CallData*>(elem->call_data); in AcceptStream() local
1726 auto* calld = static_cast<Server::CallData*>(call_elem->call_data); in PublishNewRpc() local
1793 auto* calld = static_cast<Server::CallData*>(elem->call_data); in RecvInitialMetadataBatchComplete() local
1825 CallData* calld = static_cast<CallData*>(elem->call_data); in RecvInitialMetadataReady() local
1857 CallData* calld = static_cast<CallData*>(elem->call_data); in RecvTrailingMetadataReady() local
1884 auto* calld = static_cast<CallData*>(elem->call_data); in DestroyCallElement() local
[all …]
|
| /external/grpc-grpc/src/core/ext/filters/deadline/ |
| D | deadline_filter.cc | 296 server_call_data* calld = static_cast<server_call_data*>(elem->call_data); in recv_initial_metadata_ready() local
309 server_call_data* calld = static_cast<server_call_data*>(elem->call_data); in deadline_server_start_transport_stream_op_batch() local
|
| /external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/ext/filters/deadline/ |
| D | deadline_filter.cc | 299 server_call_data* calld = static_cast<server_call_data*>(elem->call_data); in recv_initial_metadata_ready() local
312 server_call_data* calld = static_cast<server_call_data*>(elem->call_data); in deadline_server_start_transport_stream_op_batch() local
|
| /external/grpc-grpc/src/core/ext/filters/logging/ |
| D | logging_filter.cc | 365 CallData* calld = GetContext<Arena>()->ManagedNew<CallData>( in MakeCallPromise() local
456 CallData* calld = GetContext<Arena>()->ManagedNew<CallData>( in MakeCallPromise() local
|
| /external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/ext/filters/logging/ |
| D | logging_filter.cc | 367 CallData* calld = GetContext<Arena>()->ManagedNew<CallData>( in MakeCallPromise() local
466 CallData* calld = GetContext<Arena>()->ManagedNew<CallData>( in MakeCallPromise() local
|
| /external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/ext/xds/ |
| D | xds_client.cc | 82 T* calld() const { return calld_.get(); } in calld() function in grpc_core::XdsClient::ChannelState::RetryableCall
536 auto* calld = ads_calld_->calld(); in UnsubscribeLocked() local
|