diff options
| author | Krzysztof Kosiński <krzysio@google.com> | 2024-02-23 02:35:29 +0000 |
|---|---|---|
| committer | Automerger Merge Worker <android-build-automerger-merge-worker@system.gserviceaccount.com> | 2024-02-23 02:35:29 +0000 |
| commit | d53c80d78835e4465edd59e8ea19c259d05ec54b (patch) | |
| tree | a0da8416687a507faab2c3de09a7791d4255189e /src/core/lib/surface/lame_client.cc | |
| parent | 7f52fa8c3060b403b3ce1181d4e636f720f891f9 (diff) | |
| parent | d0ea8b5e8030562cfe6a6be629b9149f8700523b (diff) | |
| download | grpc-grpc-d53c80d78835e4465edd59e8ea19c259d05ec54b.tar.gz | |
Upgrade gRPC to version 1.61.1. am: d0ea8b5e80
Original change: https://android-review.googlesource.com/c/platform/external/grpc-grpc/+/2972751
Change-Id: I0e12d02c8be49fdf7d73f148c15531b144eff74e
Signed-off-by: Automerger Merge Worker <android-build-automerger-merge-worker@system.gserviceaccount.com>
Diffstat (limited to 'src/core/lib/surface/lame_client.cc')
| -rw-r--r-- | src/core/lib/surface/lame_client.cc | 9 |
1 files changed, 8 insertions, 1 deletions
diff --git a/src/core/lib/surface/lame_client.cc b/src/core/lib/surface/lame_client.cc index 7fbdf8e64b..723ec6b703 100644 --- a/src/core/lib/surface/lame_client.cc +++ b/src/core/lib/surface/lame_client.cc @@ -47,6 +47,7 @@ #include "src/core/lib/surface/channel.h" #include "src/core/lib/surface/channel_stack_type.h" #include "src/core/lib/transport/connectivity_state.h" +#include "src/core/lib/transport/metadata_batch.h" #include "src/core/lib/transport/transport.h" // Avoid some IWYU confusion: @@ -77,7 +78,13 @@ ArenaPromise<ServerMetadataHandle> LameClientFilter::MakeCallPromise( // TODO(ctiller): remove if check once promise_based_filter is removed (Close // is still needed) if (args.server_to_client_messages != nullptr) { - args.server_to_client_messages->Close(); + args.server_to_client_messages->CloseWithError(); + } + if (args.client_to_server_messages != nullptr) { + args.client_to_server_messages->CloseWithError(); + } + if (args.server_initial_metadata != nullptr) { + args.server_initial_metadata->CloseWithError(); } args.client_initial_metadata_outstanding.Complete(true); return Immediate(ServerMetadataFromStatus(error_)); |