aboutsummaryrefslogtreecommitdiffhomepage
path: root/test/cpp/end2end/health_service_end2end_test.cc
diff options
context:
space:
mode:
authorGravatar yang-g <yangg@google.com>2016-12-27 13:17:47 -0800
committerGravatar yang-g <yangg@google.com>2016-12-27 15:37:59 -0800
commitb74cf429fdec9e72364b4cbe4ae1b7389d28672d (patch)
tree0a15c9a69d663cd82e1ab0305156c501db5da7d7 /test/cpp/end2end/health_service_end2end_test.cc
parentc3c475fd144b3d43a775b569dad36610014e08e4 (diff)
test pass
Diffstat (limited to 'test/cpp/end2end/health_service_end2end_test.cc')
-rw-r--r--test/cpp/end2end/health_service_end2end_test.cc13
1 files changed, 10 insertions, 3 deletions
diff --git a/test/cpp/end2end/health_service_end2end_test.cc b/test/cpp/end2end/health_service_end2end_test.cc
index 17e8c4b761..02aa5cea3f 100644
--- a/test/cpp/end2end/health_service_end2end_test.cc
+++ b/test/cpp/end2end/health_service_end2end_test.cc
@@ -85,7 +85,6 @@ class HealthServiceEnd2endTest : public ::testing::Test {
void ResetStubs() {
std::shared_ptr<Channel> channel =
CreateChannel(server_address_.str(), InsecureChannelCredentials());
- stub_ = grpc::testing::EchoTestService::NewStub(channel);
hc_stub_ = grpc::health::v1::Health::NewStub(channel);
}
@@ -98,14 +97,12 @@ class HealthServiceEnd2endTest : public ::testing::Test {
ClientContext context;
Status s = hc_stub_->Check(&context, request, &response);
EXPECT_EQ(expected_status.error_code(), s.error_code());
- // EXPECT_EQ(expected_status.error_details(), s.error_details());
if (s.ok()) {
EXPECT_EQ(expected_serving_status, response.status());
}
}
TestServiceImpl echo_test_service_;
- std::unique_ptr<grpc::testing::EchoTestService::Stub> stub_;
std::unique_ptr<Health::Stub> hc_stub_;
std::unique_ptr<Server> server_;
std::ostringstream server_address_;
@@ -129,6 +126,8 @@ TEST_F(HealthServiceEnd2endTest, DefaultHealthService) {
EXPECT_TRUE(default_service != nullptr);
const grpc::string kHealthyService("healthy_service");
const grpc::string kUnhealthyService("unhealthy_service");
+ const grpc::string kNotRegisteredService("not_registered");
+ const grpc::string kTooLongServiceName(201, 'x');
default_service->SetServingStatus(kHealthyService, true);
default_service->SetServingStatus(kUnhealthyService, false);
@@ -138,6 +137,10 @@ TEST_F(HealthServiceEnd2endTest, DefaultHealthService) {
SendHealthCheckRpc(kHealthyService, Status::OK, HealthCheckResponse::SERVING);
SendHealthCheckRpc(kUnhealthyService, Status::OK,
HealthCheckResponse::NOT_SERVING);
+ SendHealthCheckRpc(kNotRegisteredService, Status(StatusCode::NOT_FOUND, ""),
+ HealthCheckResponse::NOT_SERVING);
+ SendHealthCheckRpc(kTooLongServiceName, Status(StatusCode::INVALID_ARGUMENT, ""),
+ HealthCheckResponse::NOT_SERVING);
default_service->SetServingStatus(false);
SendHealthCheckRpc("", Status::OK, HealthCheckResponse::NOT_SERVING);
@@ -145,6 +148,10 @@ TEST_F(HealthServiceEnd2endTest, DefaultHealthService) {
HealthCheckResponse::NOT_SERVING);
SendHealthCheckRpc(kUnhealthyService, Status::OK,
HealthCheckResponse::NOT_SERVING);
+ SendHealthCheckRpc(kNotRegisteredService, Status(StatusCode::NOT_FOUND, ""),
+ HealthCheckResponse::NOT_SERVING);
+ SendHealthCheckRpc(kTooLongServiceName, Status(StatusCode::INVALID_ARGUMENT, ""),
+ HealthCheckResponse::NOT_SERVING);
}
} // namespace