You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mesos.apache.org by al...@apache.org on 2016/11/25 15:19:44 UTC
[05/11] mesos git commit: Health checks may be stopped on demand.
Health checks may be stopped on demand.
Review: https://reviews.apache.org/r/52868/
Project: http://git-wip-us.apache.org/repos/asf/mesos/repo
Commit: http://git-wip-us.apache.org/repos/asf/mesos/commit/bd6186d2
Tree: http://git-wip-us.apache.org/repos/asf/mesos/tree/bd6186d2
Diff: http://git-wip-us.apache.org/repos/asf/mesos/diff/bd6186d2
Branch: refs/heads/master
Commit: bd6186d20d6ffe5a565ea29a08e1e0eb86873e63
Parents: 3da7397
Author: Alexander Rukletsov <ru...@gmail.com>
Authored: Fri Nov 25 16:13:54 2016 +0100
Committer: Alexander Rukletsov <al...@apache.org>
Committed: Fri Nov 25 16:13:54 2016 +0100
----------------------------------------------------------------------
src/health-check/health_checker.cpp | 8 ++++++++
src/health-check/health_checker.hpp | 5 +++++
2 files changed, 13 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/mesos/blob/bd6186d2/src/health-check/health_checker.cpp
----------------------------------------------------------------------
diff --git a/src/health-check/health_checker.cpp b/src/health-check/health_checker.cpp
index e66c9df..b769ecd 100644
--- a/src/health-check/health_checker.cpp
+++ b/src/health-check/health_checker.cpp
@@ -158,6 +158,14 @@ HealthChecker::~HealthChecker()
}
+void HealthChecker::stop()
+{
+ LOG(INFO) << "Health checking stopped";
+
+ terminate(process.get(), true);
+}
+
+
HealthCheckerProcess::HealthCheckerProcess(
const HealthCheck& _check,
const string& _launcherDir,
http://git-wip-us.apache.org/repos/asf/mesos/blob/bd6186d2/src/health-check/health_checker.hpp
----------------------------------------------------------------------
diff --git a/src/health-check/health_checker.hpp b/src/health-check/health_checker.hpp
index 733d2bd..bd7b753 100644
--- a/src/health-check/health_checker.hpp
+++ b/src/health-check/health_checker.hpp
@@ -70,6 +70,11 @@ public:
~HealthChecker();
+ /**
+ * Immediately stops health checking. Any in-flight health checks are dropped.
+ */
+ void stop();
+
private:
explicit HealthChecker(process::Owned<HealthCheckerProcess> process);