| /aosp_15_r20/external/grpc-grpc/test/cpp/util/ |
| H A D | cli_call.cc | 42 IncomingMetadataContainer* server_trailing_metadata) { in Call() argument
48 return Finish(server_trailing_metadata); in Call()
211 Status CliCall::Finish(IncomingMetadataContainer* server_trailing_metadata) { in Finish() argument
219 if (server_trailing_metadata) { in Finish()
220 *server_trailing_metadata = ctx_.GetServerTrailingMetadata(); in Finish()
|
| H A D | grpc_tool.cc | 653 std::multimap<grpc::string_ref, grpc::string_ref> server_trailing_metadata; in CallMethod() local
654 Status status = call.Finish(&server_trailing_metadata); in CallMethod()
655 PrintMetadata(server_trailing_metadata, in CallMethod()
719 server_initial_metadata, server_trailing_metadata; in CallMethod() local
733 Status status = call.Finish(&server_trailing_metadata); in CallMethod()
740 PrintMetadata(server_trailing_metadata, in CallMethod()
822 server_trailing_metadata; in CallMethod() local
856 Status status = call.Finish(&server_trailing_metadata); in CallMethod()
857 PrintMetadata(server_trailing_metadata, in CallMethod()
|
| H A D | cli_call_test.cc | 107 server_trailing_metadata; in TEST_F() local
111 &server_trailing_metadata); in TEST_F()
116 EXPECT_EQ(context.GetServerTrailingMetadata(), server_trailing_metadata); in TEST_F()
|
| H A D | cli_call.h | 61 IncomingMetadataContainer* server_trailing_metadata);
89 Status Finish(IncomingMetadataContainer* server_trailing_metadata);
|
| /aosp_15_r20/external/grpc-grpc/src/core/lib/transport/ |
| H A D | call_spine.h | 50 virtual Pipe<ServerMetadataHandle>& server_trailing_metadata() = 0;
90 server_trailing_metadata().sender.CloseWithError(); in Cancel()
169 Pipe<ServerMetadataHandle>& server_trailing_metadata() override { in server_trailing_metadata() function
255 Seq(spine_->server_trailing_metadata().receiver.Next(), in PullServerTrailingMetadata()
263 spine->server_trailing_metadata().sender.Close(); in PullServerTrailingMetadata()
269 spine->server_trailing_metadata().sender.CloseWithError(); in PullServerTrailingMetadata()
361 return Map(spine_->server_trailing_metadata().sender.Push(std::move(md)), in PushServerTrailingMetadata()
|
| H A D | call_filters.h | 850 Layout<InfallibleOperator<ServerMetadataHandle>> server_trailing_metadata;
982 channel_data, call_offset, server_trailing_metadata);
1702 return executor_.Start(&filters_->stack_->data_.server_trailing_metadata,
|
| H A D | call_filters.cc | 279 data_.server_trailing_metadata.Reverse(); in Build()
|
| /aosp_15_r20/external/grpc-grpc/test/core/transport/ |
| H A D | call_filters_test.cc | 930 ASSERT_EQ(d.server_trailing_metadata.ops.size(), 1u); in TEST()
931 EXPECT_EQ(d.server_trailing_metadata.ops[0].call_offset, call_offset); in TEST()
932 EXPECT_EQ(d.server_trailing_metadata.ops[0].channel_data, &f1); in TEST()
934 EXPECT_EQ(d.server_trailing_metadata.ops[0].poll, nullptr); in TEST()
935 EXPECT_EQ(d.server_trailing_metadata.ops[0].early_destroy, nullptr); in TEST()
943 auto r = d.server_trailing_metadata.ops[0].promise_init( in TEST()
944 nullptr, &call_data, d.server_trailing_metadata.ops[0].channel_data, in TEST()
970 ASSERT_EQ(d.server_trailing_metadata.ops.size(), 1u); in TEST()
971 EXPECT_EQ(d.server_trailing_metadata.ops[0].call_offset, call_offset); in TEST()
972 EXPECT_EQ(d.server_trailing_metadata.ops[0].channel_data, &f1); in TEST()
[all …]
|
| /aosp_15_r20/external/grpc-grpc/src/core/lib/channel/ |
| H A D | connected_channel.cc | 505 auto server_trailing_metadata = in MakeClientCallPromise() local
512 auto server_trailing_metadata = in MakeClientCallPromise() local
518 server_trailing_metadata->Set(GrpcStatusMetadata(), status_code); in MakeClientCallPromise()
519 server_trailing_metadata->Set(GrpcMessageMetadata(), in MakeClientCallPromise()
521 return server_trailing_metadata; in MakeClientCallPromise()
712 server_trailing_metadata) { in MakeServerCallPromise() argument
714 server_trailing_metadata->get(GrpcCallWasCancelled()).value_or(false); in MakeServerCallPromise()
716 stream->batch_target(), std::move(server_trailing_metadata), in MakeServerCallPromise()
892 return Map(spine->server_trailing_metadata().receiver.Next(), in MakeClientTransportCallPromise()
|
| H A D | server_call_tracer_filter.cc | 75 void OnServerTrailingMetadata(ServerMetadata& server_trailing_metadata) { in OnServerTrailingMetadata() argument
78 call_tracer->RecordSendTrailingMetadata(&server_trailing_metadata); in OnServerTrailingMetadata()
|
| H A D | channel_stack_builder_impl.cc | 129 call->server_trailing_metadata().sender.InterceptAndMap( in PromiseTracingFilterFor()
|
| H A D | promise_based_filter.h | 939 call_spine->server_trailing_metadata().sender.InterceptAndMap(
952 call_spine->server_trailing_metadata().sender.InterceptAndMap(
964 call_spine->server_trailing_metadata().sender.InterceptAndMap(
|
| /aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/lib/channel/ |
| D | connected_channel.cc | 507 auto server_trailing_metadata = in MakeClientCallPromise() local
514 auto server_trailing_metadata = in MakeClientCallPromise() local
521 server_trailing_metadata->Set(GrpcStatusMetadata(), status_code); in MakeClientCallPromise()
522 server_trailing_metadata->Set(GrpcMessageMetadata(), in MakeClientCallPromise()
524 return server_trailing_metadata; in MakeClientCallPromise()
715 server_trailing_metadata) { in MakeServerCallPromise() argument
717 server_trailing_metadata->get(GrpcCallWasCancelled()).value_or(false); in MakeServerCallPromise()
719 stream->batch_target(), std::move(server_trailing_metadata), in MakeServerCallPromise()
|
| /aosp_15_r20/external/grpc-grpc/test/core/transport/test_suite/ |
| H A D | call_content.cc | 69 const auto server_trailing_metadata = RandomMetadata(); in TRANSPORT_TEST() local
109 UnorderedElementsAreArray(server_trailing_metadata)); in TRANSPORT_TEST()
141 FillMetadata(server_trailing_metadata, *md); in TRANSPORT_TEST()
|
| /aosp_15_r20/external/grpc-grpc/src/python/grpcio_tests/tests/unit/_cython/ |
| H A D | cygrpc_test.py | 301 server_trailing_metadata = (
315 server_trailing_metadata,
352 server_trailing_metadata,
|
| /aosp_15_r20/external/grpc-grpc/test/cpp/interop/ |
| H A D | interop_client.cc | 1128 const auto& server_trailing_metadata = context.GetServerTrailingMetadata(); in DoCustomMetadata() local
1129 iter = server_trailing_metadata.find(kEchoTrailingBinMetadataKey); in DoCustomMetadata()
1130 GPR_ASSERT(iter != server_trailing_metadata.end()); in DoCustomMetadata()
1179 const auto& server_trailing_metadata = context.GetServerTrailingMetadata(); in DoCustomMetadata() local
1180 iter = server_trailing_metadata.find(kEchoTrailingBinMetadataKey); in DoCustomMetadata()
1181 GPR_ASSERT(iter != server_trailing_metadata.end()); in DoCustomMetadata()
|
| /aosp_15_r20/external/grpc-grpc/test/cpp/end2end/ |
| H A D | async_end2end_test.cc | 1183 const auto& server_trailing_metadata = cli_ctx.GetServerTrailingMetadata(); in TEST_P() local
1185 ToString(server_trailing_metadata.find(meta1.first)->second)); in TEST_P()
1187 ToString(server_trailing_metadata.find(meta2.first)->second)); in TEST_P()
1188 EXPECT_EQ(2, server_trailing_metadata.size()); in TEST_P()
1259 const auto& server_trailing_metadata = cli_ctx.GetServerTrailingMetadata(); in TEST_P() local
1261 ToString(server_trailing_metadata.find(meta5.first)->second)); in TEST_P()
1263 ToString(server_trailing_metadata.find(meta6.first)->second)); in TEST_P()
1264 EXPECT_GE(server_trailing_metadata.size(), 2); in TEST_P()
|
| /aosp_15_r20/external/grpc-grpc/test/core/filters/ |
| H A D | filter_test.h | 199 (Call * call, const ServerMetadata& server_trailing_metadata));
|
| /aosp_15_r20/external/grpc-grpc/src/core/lib/surface/ |
| H A D | call.cc | 2842 auto server_trailing_metadata = std::move(server_trailing_metadata_); in MakeCallSpine() local
2863 Pipe<ServerMetadataHandle>& server_trailing_metadata() override { in MakeCallSpine() function in grpc_core::ClientPromiseBasedCall::MakeCallSpine::WrappingCallSpine
3723 Pipe<ServerMetadataHandle>& server_trailing_metadata() override { in server_trailing_metadata() function in grpc_core::ServerCallSpine
|