diff --git a/test/core/end2end/tests/request_with_payload.cc b/test/core/end2end/tests/request_with_payload.cc index 7651a926d3d..79fba04bf05 100644 --- a/test/core/end2end/tests/request_with_payload.cc +++ b/test/core/end2end/tests/request_with_payload.cc @@ -16,10 +16,12 @@ // // +#include "absl/strings/str_cat.h" #include "gtest/gtest.h" #include +#include "src/core/lib/gprpp/crash.h" #include "src/core/lib/gprpp/time.h" #include "test/core/end2end/end2end_tests.h" @@ -27,7 +29,7 @@ namespace grpc_core { namespace { CORE_END2END_TEST(CoreEnd2endTest, RequestWithPayload) { - auto c = NewClientCall("/foo").Timeout(Duration::Seconds(5)).Create(); + auto c = NewClientCall("/foo").Timeout(Duration::Seconds(30)).Create(); IncomingMetadata server_initial_metadata; IncomingStatusOnClient server_status; c.NewBatch(1) @@ -38,6 +40,12 @@ CORE_END2END_TEST(CoreEnd2endTest, RequestWithPayload) { .RecvStatusOnClient(server_status); auto s = RequestCall(101); Expect(101, true); + Expect(1, CoreEnd2endTest::MaybePerformAction{[&](bool success) { + Crash(absl::StrCat( + "Unexpected completion of client side call: success=", + success ? "true" : "false", " status=", server_status.ToString(), + " initial_md=", server_initial_metadata.ToString())); + }}); Step(); IncomingMessage client_message; s.NewBatch(102).SendInitialMetadata({}).RecvMessage(client_message);