|
|
|
@ -16,10 +16,12 @@ |
|
|
|
|
//
|
|
|
|
|
//
|
|
|
|
|
|
|
|
|
|
#include "absl/strings/str_cat.h" |
|
|
|
|
#include "gtest/gtest.h" |
|
|
|
|
|
|
|
|
|
#include <grpc/status.h> |
|
|
|
|
|
|
|
|
|
#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); |
|
|
|
|