|
|
|
@ -891,7 +891,7 @@ TEST_P(AsyncEnd2endTest, ClientInitialMetadataRpc) { |
|
|
|
|
cq_.get(), tag(2)); |
|
|
|
|
Verifier().Expect(2, true).Verify(cq_.get()); |
|
|
|
|
EXPECT_EQ(send_request.message(), recv_request.message()); |
|
|
|
|
auto client_initial_metadata = srv_ctx.client_metadata(); |
|
|
|
|
const auto& client_initial_metadata = srv_ctx.client_metadata(); |
|
|
|
|
EXPECT_EQ(meta1.second, |
|
|
|
|
ToString(client_initial_metadata.find(meta1.first)->second)); |
|
|
|
|
EXPECT_EQ(meta2.second, |
|
|
|
@ -937,7 +937,7 @@ TEST_P(AsyncEnd2endTest, ServerInitialMetadataRpc) { |
|
|
|
|
srv_ctx.AddInitialMetadata(meta2.first, meta2.second); |
|
|
|
|
response_writer.SendInitialMetadata(tag(3)); |
|
|
|
|
Verifier().Expect(3, true).Expect(4, true).Verify(cq_.get()); |
|
|
|
|
auto server_initial_metadata = cli_ctx.GetServerInitialMetadata(); |
|
|
|
|
const auto& server_initial_metadata = cli_ctx.GetServerInitialMetadata(); |
|
|
|
|
EXPECT_EQ(meta1.second, |
|
|
|
|
ToString(server_initial_metadata.find(meta1.first)->second)); |
|
|
|
|
EXPECT_EQ(meta2.second, |
|
|
|
@ -990,7 +990,7 @@ TEST_P(AsyncEnd2endTest, ServerTrailingMetadataRpc) { |
|
|
|
|
|
|
|
|
|
EXPECT_EQ(send_response.message(), recv_response.message()); |
|
|
|
|
EXPECT_TRUE(recv_status.ok()); |
|
|
|
|
auto server_trailing_metadata = cli_ctx.GetServerTrailingMetadata(); |
|
|
|
|
const auto& server_trailing_metadata = cli_ctx.GetServerTrailingMetadata(); |
|
|
|
|
EXPECT_EQ(meta1.second, |
|
|
|
|
ToString(server_trailing_metadata.find(meta1.first)->second)); |
|
|
|
|
EXPECT_EQ(meta2.second, |
|
|
|
@ -1038,7 +1038,7 @@ TEST_P(AsyncEnd2endTest, MetadataRpc) { |
|
|
|
|
cq_.get(), tag(2)); |
|
|
|
|
Verifier().Expect(2, true).Verify(cq_.get()); |
|
|
|
|
EXPECT_EQ(send_request.message(), recv_request.message()); |
|
|
|
|
auto client_initial_metadata = srv_ctx.client_metadata(); |
|
|
|
|
const auto& client_initial_metadata = srv_ctx.client_metadata(); |
|
|
|
|
EXPECT_EQ(meta1.second, |
|
|
|
|
ToString(client_initial_metadata.find(meta1.first)->second)); |
|
|
|
|
EXPECT_EQ(meta2.second, |
|
|
|
@ -1049,7 +1049,7 @@ TEST_P(AsyncEnd2endTest, MetadataRpc) { |
|
|
|
|
srv_ctx.AddInitialMetadata(meta4.first, meta4.second); |
|
|
|
|
response_writer.SendInitialMetadata(tag(3)); |
|
|
|
|
Verifier().Expect(3, true).Expect(4, true).Verify(cq_.get()); |
|
|
|
|
auto server_initial_metadata = cli_ctx.GetServerInitialMetadata(); |
|
|
|
|
const auto& server_initial_metadata = cli_ctx.GetServerInitialMetadata(); |
|
|
|
|
EXPECT_EQ(meta3.second, |
|
|
|
|
ToString(server_initial_metadata.find(meta3.first)->second)); |
|
|
|
|
EXPECT_EQ(meta4.second, |
|
|
|
@ -1066,7 +1066,7 @@ TEST_P(AsyncEnd2endTest, MetadataRpc) { |
|
|
|
|
|
|
|
|
|
EXPECT_EQ(send_response.message(), recv_response.message()); |
|
|
|
|
EXPECT_TRUE(recv_status.ok()); |
|
|
|
|
auto server_trailing_metadata = cli_ctx.GetServerTrailingMetadata(); |
|
|
|
|
const auto& server_trailing_metadata = cli_ctx.GetServerTrailingMetadata(); |
|
|
|
|
EXPECT_EQ(meta5.second, |
|
|
|
|
ToString(server_trailing_metadata.find(meta5.first)->second)); |
|
|
|
|
EXPECT_EQ(meta6.second, |
|
|
|
@ -1144,7 +1144,7 @@ TEST_P(AsyncEnd2endTest, ServerCheckDone) { |
|
|
|
|
|
|
|
|
|
TEST_P(AsyncEnd2endTest, UnimplementedRpc) { |
|
|
|
|
ChannelArguments args; |
|
|
|
|
auto channel_creds = GetCredentialsProvider()->GetChannelCredentials( |
|
|
|
|
const auto& channel_creds = GetCredentialsProvider()->GetChannelCredentials( |
|
|
|
|
GetParam().credentials_type, &args); |
|
|
|
|
std::shared_ptr<Channel> channel = |
|
|
|
|
!(GetParam().inproc) |
|
|
|
|