You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mesos.apache.org by bm...@apache.org on 2014/09/03 23:52:36 UTC
[3/5] git commit: Count pending tasks as staging in the slave.
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 <bm...@twitter.com>
Authored: Mon Aug 18 17:08:03 2014 -0700
Committer: Benjamin Mahler <bm...@twitter.com>
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();
}