Home
last modified time | relevance | path

Searched refs:recv_trailing_metadata_ (Results 1 – 25 of 29) sorted by relevance

12

/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/cpp/common/
Dchannel_filter.h117 recv_trailing_metadata_( in TransportStreamOpBatch()
137 return op_->recv_trailing_metadata ? &recv_trailing_metadata_ : nullptr; in recv_trailing_metadata()
178 MetadataBatch recv_trailing_metadata_; variable
/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/
Dsubchannel_stream_client.cc180 recv_trailing_metadata_(arena_.get()) {} in CallState()
280 &recv_trailing_metadata_; in StartCallLocked()
417 self->recv_trailing_metadata_.get(GrpcStatusMetadata()) in RecvTrailingMetadataReady()
432 self->recv_trailing_metadata_.Clear(); in RecvTrailingMetadataReady()
Dsubchannel.cc246 GPR_ASSERT(recv_trailing_metadata_ == nullptr); in MaybeInterceptRecvTrailingMetadata()
247 recv_trailing_metadata_ = in MaybeInterceptRecvTrailingMetadata()
272 GPR_ASSERT(call->recv_trailing_metadata_ != nullptr); in RecvTrailingMetadataReady()
274 GetCallStatus(&status, call->deadline_, call->recv_trailing_metadata_, error); in RecvTrailingMetadataReady()
Dsubchannel_stream_client.h187 grpc_metadata_batch recv_trailing_metadata_; variable
Dclient_channel.cc2447 : lb_call_(lb_call), recv_trailing_metadata_(recv_trailing_metadata) {} in BackendMetricAccessor()
2451 recv_trailing_metadata_ != nullptr) { in GetBackendMetricData()
2452 if (const auto* md = recv_trailing_metadata_->get_pointer( in GetBackendMetricData()
2480 grpc_metadata_batch* recv_trailing_metadata_; member in grpc_core::ClientChannel::LoadBalancedCall::BackendMetricAccessor
2772 if (recv_trailing_metadata_ == nullptr) { in Orphan()
2934 recv_trailing_metadata_ = in StartTransportStreamOpBatch()
3053 const auto& md = *self->recv_trailing_metadata_; in RecvTrailingMetadataReady()
3068 self->RecordCallCompletion(status, self->recv_trailing_metadata_, in RecvTrailingMetadataReady()
Dsubchannel.h155 grpc_metadata_batch* recv_trailing_metadata_ = nullptr; variable
Dclient_channel.h580 grpc_metadata_batch* recv_trailing_metadata_ = nullptr; variable
Dretry_filter.cc449 grpc_metadata_batch recv_trailing_metadata_{calld_->arena_}; member in grpc_core::__anon3571f5bf0111::RetryFilter::CallData::CallAttempt
1597 std::move(call_attempt_->recv_trailing_metadata_); in MaybeAddClosureForRecvTrailingMetadataReady()
2020 call_attempt_->recv_trailing_metadata_.Clear(); in AddRetriableRecvTrailingMetadataOp()
2022 &call_attempt_->recv_trailing_metadata_; in AddRetriableRecvTrailingMetadataOp()
/external/grpc-grpc/src/core/lib/channel/
Dpromise_based_filter.cc1134 if (self_->recv_trailing_metadata_ != md.get()) { in Run()
1135 *self_->recv_trailing_metadata_ = std::move(*md); in Run()
1670 recv_trailing_metadata_ = in HookRecvTrailingMetadata()
1774 return WrapMetadata(recv_trailing_metadata_); in PollTrailingMetadata()
1778 recv_trailing_metadata_->Clear(); in PollTrailingMetadata()
1779 SetStatusFromError(recv_trailing_metadata_, cancelled_error_); in PollTrailingMetadata()
1780 return WrapMetadata(recv_trailing_metadata_); in PollTrailingMetadata()
1804 recv_trailing_metadata_->DebugString().c_str()); in RecvTrailingMetadataReady()
1810 *recv_trailing_metadata_ = std::move(*cancelling_metadata_); in RecvTrailingMetadataReady()
1821 SetStatusFromError(recv_trailing_metadata_, error); in RecvTrailingMetadataReady()
[all …]
/external/rust/android-crates-io/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/impl/
Dinterceptor_common.h139 return recv_trailing_metadata_->map(); in GetRecvTrailingMetadata()
180 recv_trailing_metadata_ = map; in SetRecvTrailingMetadata()
405 MetadataMap* recv_trailing_metadata_ = nullptr; variable
/external/rust/android-crates-io/crates/grpcio-sys/grpc/include/grpcpp/impl/
Dinterceptor_common.h139 return recv_trailing_metadata_->map(); in GetRecvTrailingMetadata()
180 recv_trailing_metadata_ = map; in SetRecvTrailingMetadata()
405 MetadataMap* recv_trailing_metadata_ = nullptr; variable
/external/grpc-grpc/include/grpcpp/impl/
Dinterceptor_common.h139 return recv_trailing_metadata_->map(); in GetRecvTrailingMetadata()
180 recv_trailing_metadata_ = map; in SetRecvTrailingMetadata()
405 MetadataMap* recv_trailing_metadata_ = nullptr; variable
/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/lib/channel/
Dpromise_based_filter.cc1130 if (self_->recv_trailing_metadata_ != md.get()) { in Run()
1131 *self_->recv_trailing_metadata_ = std::move(*md); in Run()
1663 recv_trailing_metadata_ = in HookRecvTrailingMetadata()
1767 return WrapMetadata(recv_trailing_metadata_); in PollTrailingMetadata()
1771 recv_trailing_metadata_->Clear(); in PollTrailingMetadata()
1772 SetStatusFromError(recv_trailing_metadata_, cancelled_error_); in PollTrailingMetadata()
1773 return WrapMetadata(recv_trailing_metadata_); in PollTrailingMetadata()
1797 recv_trailing_metadata_->DebugString().c_str()); in RecvTrailingMetadataReady()
1803 *recv_trailing_metadata_ = std::move(*cancelling_metadata_); in RecvTrailingMetadataReady()
1814 SetStatusFromError(recv_trailing_metadata_, error); in RecvTrailingMetadataReady()
[all …]
Dpromise_based_filter.h661 grpc_metadata_batch* recv_trailing_metadata_ = nullptr; variable
766 grpc_metadata_batch* recv_trailing_metadata_ = nullptr; variable
/external/grpc-grpc/src/core/client_channel/
Dsubchannel_stream_client.cc275 &recv_trailing_metadata_; in StartCallLocked()
412 self->recv_trailing_metadata_.get(GrpcStatusMetadata()) in RecvTrailingMetadataReady()
427 self->recv_trailing_metadata_.Clear(); in RecvTrailingMetadataReady()
Dsubchannel.cc278 GPR_ASSERT(recv_trailing_metadata_ == nullptr); in MaybeInterceptRecvTrailingMetadata()
279 recv_trailing_metadata_ = in MaybeInterceptRecvTrailingMetadata()
304 GPR_ASSERT(call->recv_trailing_metadata_ != nullptr); in RecvTrailingMetadataReady()
306 GetCallStatus(&status, call->deadline_, call->recv_trailing_metadata_, error); in RecvTrailingMetadataReady()
Dsubchannel_stream_client.h187 grpc_metadata_batch recv_trailing_metadata_; variable
Dsubchannel.h158 grpc_metadata_batch* recv_trailing_metadata_ = nullptr; variable
Dretry_filter_legacy_call_data.h281 grpc_metadata_batch recv_trailing_metadata_; variable
Dclient_channel_filter.cc2725 : lb_call_(lb_call), recv_trailing_metadata_(recv_trailing_metadata) {} in BackendMetricAccessor()
2729 recv_trailing_metadata_ != nullptr) { in GetBackendMetricData()
2730 if (const auto* md = recv_trailing_metadata_->get_pointer( in GetBackendMetricData()
2758 grpc_metadata_batch* recv_trailing_metadata_; member in grpc_core::ClientChannelFilter::LoadBalancedCall::BackendMetricAccessor
3080 if (recv_trailing_metadata_ == nullptr) { in Orphan()
3243 recv_trailing_metadata_ = in StartTransportStreamOpBatch()
3362 const auto& md = *self->recv_trailing_metadata_; in RecvTrailingMetadataReady()
3377 self->RecordCallCompletion(status, self->recv_trailing_metadata_, in RecvTrailingMetadataReady()
Dclient_channel_filter.h586 grpc_metadata_batch* recv_trailing_metadata_ = nullptr; variable
Dretry_filter_legacy_call_data.cc1053 std::move(call_attempt_->recv_trailing_metadata_); in MaybeAddClosureForRecvTrailingMetadataReady()
1476 call_attempt_->recv_trailing_metadata_.Clear(); in AddRetriableRecvTrailingMetadataOp()
1478 &call_attempt_->recv_trailing_metadata_; in AddRetriableRecvTrailingMetadataOp()
/external/grpc-grpc/test/core/end2end/fuzzers/
Dfuzzing_common.cc71 grpc_metadata_array_init(&recv_trailing_metadata_); in Call()
234 &recv_trailing_metadata_; in ReadOp()
293 grpc_metadata_array recv_trailing_metadata_{0, 0, nullptr}; member in grpc_core::testing::Call
330 grpc_metadata_array_destroy(&recv_trailing_metadata_); in ~Call()
/external/grpc-grpc/test/core/transport/chttp2/
Dstreams_not_seen_test.cc139 calld->recv_trailing_metadata_ = in StartTransportStreamOpBatch()
168 calld->recv_trailing_metadata_->get(GrpcStreamNetworkState()); in RecvTrailingMetadataReady()
176 grpc_metadata_batch* recv_trailing_metadata_ = nullptr; member in grpc_core::__anon9c528e6e0111::TrailingMetadataRecordingFilter::CallData
/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/lib/surface/
Dcall.cc735 grpc_metadata_batch recv_trailing_metadata_{arena()}; member in grpc_core::FilterStackCall
941 c->recv_trailing_metadata_.Clear(); in DestroyCall()
1468 grpc_metadata_batch* md = &call_->recv_trailing_metadata_; in ReceivingTrailingMetadataReady()
1807 &recv_trailing_metadata_; in StartBatch()
1840 &recv_trailing_metadata_; in StartBatch()
2769 ServerMetadataHandle recv_trailing_metadata_; member in grpc_core::ClientPromiseBasedCall
3032 recv_trailing_metadata_ = std::move(trailing_metadata); in StartRecvStatusOnClient()

12