aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/cpp/server/server_cc.cc
diff options
context:
space:
mode:
authorGravatar yang-g <yangg@google.com>2016-12-06 16:49:04 -0800
committerGravatar yang-g <yangg@google.com>2016-12-27 15:37:59 -0800
commit6d0fbfaf7b887ed96defc46f96fd1e7d5b4875b9 (patch)
tree83a08835e02740d9b8b46a80e7633763959c2e34 /src/cpp/server/server_cc.cc
parentc9d2954e556db3f102a858d97e339edb9db0388c (diff)
WIP
Diffstat (limited to 'src/cpp/server/server_cc.cc')
-rw-r--r--src/cpp/server/server_cc.cc25
1 files changed, 9 insertions, 16 deletions
diff --git a/src/cpp/server/server_cc.cc b/src/cpp/server/server_cc.cc
index 03210883bf..4eaafeabb8 100644
--- a/src/cpp/server/server_cc.cc
+++ b/src/cpp/server/server_cc.cc
@@ -36,7 +36,6 @@
#include <utility>
#include <grpc++/completion_queue.h>
-#include <grpc++/ext/g.h>
#include <grpc++/generic/async_generic_service.h>
#include <grpc++/impl/codegen/completion_queue_tag.h>
#include <grpc++/impl/grpc_library.h>
@@ -307,15 +306,6 @@ class Server::SyncRequestThreadManager : public ThreadManager {
sync_requests_.emplace_back(new SyncRequest(method, tag));
}
- void AddHealthCheckSyncMethod() {
- if (!sync_requests_.empty()) {
- health_check_.reset(
- new RpcServiceMethod("???", RpcMethod::NORMAL_RPC, new XXXHandler));
- sync_requests_.emplace_back(
- new SyncRequest(health_check_.get(), nullptr));
- }
- }
-
void AddUnknownSyncMethod() {
if (!sync_requests_.empty()) {
unknown_method_.reset(new RpcServiceMethod(
@@ -390,10 +380,11 @@ Server::Server(
for (size_t i = 0; i < channel_args.num_args; i++) {
if (0 == strcmp(channel_args.args[i].key,
kDefaultHealthCheckServiceInterfaceArg)) {
- if (channel_args.args[i].value == nullptr) {
- health_check_service_disabled_ = true;
+ if (channel_args.args[i].value.pointer.p == nullptr) {
+ health_check_service_disabled = true;
} else {
- health_check_service_.reset(channel_args.args[i].value);
+ health_check_service_.reset(static_cast<HealthCheckServiceInterface*>(
+ channel_args.args[i].value.pointer.p));
}
break;
}
@@ -401,10 +392,12 @@ Server::Server(
// Only create default health check service when user did not provide an
// explicit one.
if (health_check_service_ == nullptr && !health_check_service_disabled &&
- EnableDefaultHealthCheckService()) {
- health_check_service_.reset(new DefaultHealthCheckService);
+ DefaultHealthCheckServiceEnabled()) {
+ auto* default_hc_service = new DefaultHealthCheckService;
+ health_check_service_.reset(default_hc_service);
if (!sync_server_cqs->empty()) { // Has sync methods.
- RegisterService(health_check_service_->GetSyncHealthCheckService());
+ grpc::string host;
+ RegisterService(&host, default_hc_service->GetSyncHealthCheckService());
}
}