You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mesos.apache.org by vi...@apache.org on 2016/10/21 21:15:31 UTC
[7/8] mesos git commit: Added a new slave metric, "tasks_gone".
Added a new slave metric, "tasks_gone".
Review: https://reviews.apache.org/r/52802/
Project: http://git-wip-us.apache.org/repos/asf/mesos/repo
Commit: http://git-wip-us.apache.org/repos/asf/mesos/commit/b46df16d
Tree: http://git-wip-us.apache.org/repos/asf/mesos/tree/b46df16d
Diff: http://git-wip-us.apache.org/repos/asf/mesos/diff/b46df16d
Branch: refs/heads/master
Commit: b46df16ddee455c6ddb9171d7ffccfa0defbeb54
Parents: 976a1eb
Author: Neil Conway <ne...@gmail.com>
Authored: Fri Oct 21 14:13:40 2016 -0700
Committer: Vinod Kone <vi...@gmail.com>
Committed: Fri Oct 21 14:13:40 2016 -0700
----------------------------------------------------------------------
src/slave/metrics.cpp | 4 ++++
src/slave/metrics.hpp | 1 +
src/slave/slave.cpp | 1 +
3 files changed, 6 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/mesos/blob/b46df16d/src/slave/metrics.cpp
----------------------------------------------------------------------
diff --git a/src/slave/metrics.cpp b/src/slave/metrics.cpp
index 86eb8db..0eb2b59 100644
--- a/src/slave/metrics.cpp
+++ b/src/slave/metrics.cpp
@@ -64,6 +64,8 @@ Metrics::Metrics(const Slave& slave)
"slave/tasks_killed"),
tasks_lost(
"slave/tasks_lost"),
+ tasks_gone(
+ "slave/tasks_gone"),
executors_registering(
"slave/executors_registering",
defer(slave, &Slave::_executors_registering)),
@@ -107,6 +109,7 @@ Metrics::Metrics(const Slave& slave)
process::metrics::add(tasks_failed);
process::metrics::add(tasks_killed);
process::metrics::add(tasks_lost);
+ process::metrics::add(tasks_gone);
process::metrics::add(executors_registering);
process::metrics::add(executors_running);
@@ -193,6 +196,7 @@ Metrics::~Metrics()
process::metrics::remove(tasks_failed);
process::metrics::remove(tasks_killed);
process::metrics::remove(tasks_lost);
+ process::metrics::remove(tasks_gone);
process::metrics::remove(executors_registering);
process::metrics::remove(executors_running);
http://git-wip-us.apache.org/repos/asf/mesos/blob/b46df16d/src/slave/metrics.hpp
----------------------------------------------------------------------
diff --git a/src/slave/metrics.hpp b/src/slave/metrics.hpp
index d443213..3fc933c 100644
--- a/src/slave/metrics.hpp
+++ b/src/slave/metrics.hpp
@@ -50,6 +50,7 @@ struct Metrics
process::metrics::Counter tasks_failed;
process::metrics::Counter tasks_killed;
process::metrics::Counter tasks_lost;
+ process::metrics::Counter tasks_gone;
process::metrics::Gauge executors_registering;
process::metrics::Gauge executors_running;
http://git-wip-us.apache.org/repos/asf/mesos/blob/b46df16d/src/slave/slave.cpp
----------------------------------------------------------------------
diff --git a/src/slave/slave.cpp b/src/slave/slave.cpp
index ff3ed02..e13485c 100644
--- a/src/slave/slave.cpp
+++ b/src/slave/slave.cpp
@@ -6804,6 +6804,7 @@ Try<Nothing> Executor::updateTaskState(const TaskStatus& status)
case TASK_FAILED: ++slave->metrics.tasks_failed; break;
case TASK_KILLED: ++slave->metrics.tasks_killed; break;
case TASK_LOST: ++slave->metrics.tasks_lost; break;
+ case TASK_GONE: ++slave->metrics.tasks_gone; break;
default:
LOG(ERROR) << "Unexpected terminal task state " << status.state();
break;