docker
/
docs
mirror of https://github.com/docker/docs.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Add MESOS_OFFER_REFUSE_SECONDS environment configuration 

Signed-off-by: Klaus Ma <klaus.ma@outlook.com>
This commit is contained in:
Klaus Ma 2015-12-02 18:09:22 +08:00 committed by Isabel Jimenez
parent b2739245ce
commit a23ce43337
1 changed files with 16 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
cluster/mesos/cluster.go
View File

@ -9,6 +9,7 @@ import (
"io"
"os"
"sort"
"strconv"
"sync"
"time"
@ -470,7 +471,21 @@ func (c *Cluster) scheduleTask(t *task) bool {
t.build(n.ID, c.agents[n.ID].offers)
if _, err := c.driver.LaunchTasks(offerIDs, []*mesosproto.TaskInfo{&t.TaskInfo}, &mesosproto.Filters{}); err != nil {
// Set Mesos refuse seconds by environment variables.
var offerFilters *mesosproto.Filters;
var refuseSecondsStr string;
offerFilters = &mesosproto.Filters{};
refuseSecondsStr = os.Getenv("MESOS_OFFER_REFUSE_SECONDS");
if refuseSecondsStr != "" {
refuseSeconds, err := strconv.ParseFloat(refuseSecondsStr, 64);
if !err {
offerFilters.RefuseSeconds = &refuseSeconds;
}
}
if _, err := c.driver.LaunchTasks(offerIDs, []*mesosproto.TaskInfo{&t.TaskInfo}, offerFilters); err != nil {
// TODO: Do not erase all the offers, only the one used
for _, offer := range s.offers {
c.removeOffer(offer)