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 <neil.con...@gmail.com> Authored: Fri Oct 21 14:13:40 2016 -0700 Committer: Vinod Kone <vinodk...@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;
