aboutsummaryrefslogtreecommitdiffhomepage
path: root/test/cpp/end2end/health_service_end2end_test.cc
diff options
context:
space:
mode:
authorGravatar yang-g <yangg@google.com>2016-12-29 11:44:36 -0800
committerGravatar yang-g <yangg@google.com>2016-12-29 11:44:36 -0800
commit8e708b12cb1c88f5cb6e3984d887c3c2b9bee54f (patch)
tree75f3e48c8e05fa55e8f74841ca6ffc6bb260aee9 /test/cpp/end2end/health_service_end2end_test.cc
parent50993b7a4c083b8b202010aca1bb95cf9902cf74 (diff)
WIP
Diffstat (limited to 'test/cpp/end2end/health_service_end2end_test.cc')
-rw-r--r--test/cpp/end2end/health_service_end2end_test.cc126
1 files changed, 63 insertions, 63 deletions
diff --git a/test/cpp/end2end/health_service_end2end_test.cc b/test/cpp/end2end/health_service_end2end_test.cc
index c41a75ec37..9f2df90207 100644
--- a/test/cpp/end2end/health_service_end2end_test.cc
+++ b/test/cpp/end2end/health_service_end2end_test.cc
@@ -242,69 +242,69 @@ TEST_F(HealthServiceEnd2endTest, DefaultHealthServiceDisabled) {
SendHealthCheckRpc("", Status(StatusCode::UNIMPLEMENTED, ""));
}
-TEST_F(HealthServiceEnd2endTest, DefaultHealthService) {
- EnableDefaultHealthCheckService(true);
- EXPECT_TRUE(DefaultHealthCheckServiceEnabled());
- SetUpServer(true, false, nullptr);
- VerifyHealthCheckService();
-
- // The default service has a size limit of the service name.
- const grpc::string kTooLongServiceName(201, 'x');
- SendHealthCheckRpc(kTooLongServiceName,
- Status(StatusCode::INVALID_ARGUMENT, ""));
-}
-
-void LoopCompletionQueue(ServerCompletionQueue* cq) {
- void* tag;
- bool ok;
- while (cq->Next(&tag, &ok)) {
- gpr_log(GPR_ERROR, "next %p %d", tag, ok);
- }
- gpr_log(GPR_ERROR, "returning from thread");
-}
-
-TEST_F(HealthServiceEnd2endTest, DefaultHealthServiceAsync) {
- EnableDefaultHealthCheckService(true);
- EXPECT_TRUE(DefaultHealthCheckServiceEnabled());
- SetUpServer(false, false, nullptr);
- cq_thread_ = std::thread(LoopCompletionQueue, cq_.get());
- VerifyHealthCheckService();
-
- // The default service has a size limit of the service name.
- const grpc::string kTooLongServiceName(201, 'x');
- SendHealthCheckRpc(kTooLongServiceName,
- Status(StatusCode::INVALID_ARGUMENT, ""));
-}
-
-// Provide an empty service to disable the default service.
-TEST_F(HealthServiceEnd2endTest, ExplicitlyDisableViaOverride) {
- EnableDefaultHealthCheckService(true);
- EXPECT_TRUE(DefaultHealthCheckServiceEnabled());
- std::unique_ptr<HealthCheckServiceInterface> empty_service;
- SetUpServer(true, true, std::move(empty_service));
- HealthCheckServiceInterface* service = server_->GetHealthCheckService();
- EXPECT_TRUE(service == nullptr);
-
- ResetStubs();
-
- SendHealthCheckRpc("", Status(StatusCode::UNIMPLEMENTED, ""));
-}
-
-// Provide an explicit override of health checking service interface.
-TEST_F(HealthServiceEnd2endTest, ExplicitlyOverride) {
- EnableDefaultHealthCheckService(true);
- EXPECT_TRUE(DefaultHealthCheckServiceEnabled());
- std::unique_ptr<HealthCheckServiceInterface> override_service(
- new CustomHealthCheckService(&health_check_service_impl_));
- HealthCheckServiceInterface* underlying_service = override_service.get();
- SetUpServer(false, true, std::move(override_service));
- HealthCheckServiceInterface* service = server_->GetHealthCheckService();
- EXPECT_TRUE(service == underlying_service);
-
- ResetStubs();
-
- VerifyHealthCheckService();
-}
+// TEST_F(HealthServiceEnd2endTest, DefaultHealthService) {
+// EnableDefaultHealthCheckService(true);
+// EXPECT_TRUE(DefaultHealthCheckServiceEnabled());
+// SetUpServer(true, false, nullptr);
+// VerifyHealthCheckService();
+//
+// // The default service has a size limit of the service name.
+// const grpc::string kTooLongServiceName(201, 'x');
+// SendHealthCheckRpc(kTooLongServiceName,
+// Status(StatusCode::INVALID_ARGUMENT, ""));
+// }
+//
+// void LoopCompletionQueue(ServerCompletionQueue* cq) {
+// void* tag;
+// bool ok;
+// while (cq->Next(&tag, &ok)) {
+// abort(); // Nothing should come out of the cq.
+// }
+// gpr_log(GPR_ERROR, "returning from thread");
+// }
+//
+// TEST_F(HealthServiceEnd2endTest, DefaultHealthServiceAsync) {
+// EnableDefaultHealthCheckService(true);
+// EXPECT_TRUE(DefaultHealthCheckServiceEnabled());
+// SetUpServer(false, false, nullptr);
+// cq_thread_ = std::thread(LoopCompletionQueue, cq_.get());
+// VerifyHealthCheckService();
+//
+// // The default service has a size limit of the service name.
+// const grpc::string kTooLongServiceName(201, 'x');
+// SendHealthCheckRpc(kTooLongServiceName,
+// Status(StatusCode::INVALID_ARGUMENT, ""));
+// }
+//
+// // Provide an empty service to disable the default service.
+// TEST_F(HealthServiceEnd2endTest, ExplicitlyDisableViaOverride) {
+// EnableDefaultHealthCheckService(true);
+// EXPECT_TRUE(DefaultHealthCheckServiceEnabled());
+// std::unique_ptr<HealthCheckServiceInterface> empty_service;
+// SetUpServer(true, true, std::move(empty_service));
+// HealthCheckServiceInterface* service = server_->GetHealthCheckService();
+// EXPECT_TRUE(service == nullptr);
+//
+// ResetStubs();
+//
+// SendHealthCheckRpc("", Status(StatusCode::UNIMPLEMENTED, ""));
+// }
+//
+// // Provide an explicit override of health checking service interface.
+// TEST_F(HealthServiceEnd2endTest, ExplicitlyOverride) {
+// EnableDefaultHealthCheckService(true);
+// EXPECT_TRUE(DefaultHealthCheckServiceEnabled());
+// std::unique_ptr<HealthCheckServiceInterface> override_service(
+// new CustomHealthCheckService(&health_check_service_impl_));
+// HealthCheckServiceInterface* underlying_service = override_service.get();
+// SetUpServer(false, true, std::move(override_service));
+// HealthCheckServiceInterface* service = server_->GetHealthCheckService();
+// EXPECT_TRUE(service == underlying_service);
+//
+// ResetStubs();
+//
+// VerifyHealthCheckService();
+// }
} // namespace
} // namespace testing