Count pending tasks as staging in the slave. Review: https://reviews.apache.org/r/25302
Project: http://git-wip-us.apache.org/repos/asf/mesos/repo Commit: http://git-wip-us.apache.org/repos/asf/mesos/commit/aa95ca57 Tree: http://git-wip-us.apache.org/repos/asf/mesos/tree/aa95ca57 Diff: http://git-wip-us.apache.org/repos/asf/mesos/diff/aa95ca57 Branch: refs/heads/master Commit: aa95ca5767a250eb7abb3f79965641036315684c Parents: 20afa5e Author: Benjamin Mahler <[email protected]> Authored: Mon Aug 18 17:08:03 2014 -0700 Committer: Benjamin Mahler <[email protected]> Committed: Wed Sep 3 14:01:16 2014 -0700 ---------------------------------------------------------------------- src/slave/slave.cpp | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/mesos/blob/aa95ca57/src/slave/slave.cpp ---------------------------------------------------------------------- diff --git a/src/slave/slave.cpp b/src/slave/slave.cpp index 2c912fd..235e9ed 100644 --- a/src/slave/slave.cpp +++ b/src/slave/slave.cpp @@ -3333,6 +3333,8 @@ double Slave::_tasks_staging() { double count = 0.0; foreachvalue (Framework* framework, frameworks) { + count += framework->pending.size(); + foreachvalue (Executor* executor, framework->executors) { count += executor->queuedTasks.size(); }
