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

Support rescind offer in swarm. 

Signed-off-by: Yongqiao Wang <yqwyq@cn.ibm.com>
This commit is contained in:
Yongqiao Wang 2016-02-24 15:46:31 +08:00
parent ba31ab2d4b
commit 134df4293c
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
cluster/mesos/scheduler.go
View File

@ -91,7 +91,15 @@ func (s *Scheduler) ResourceOffers(_ mesosscheduler.SchedulerDriver, offers []*m
}
// OfferRescinded method
func (s *Scheduler) OfferRescinded(mesosscheduler.SchedulerDriver, *mesosproto.OfferID) {
func (s *Scheduler) OfferRescinded(_ mesosscheduler.SchedulerDriver, offerID *mesosproto.OfferID) {
log.WithFields(log.Fields{"name": "mesos", "OfferID": offerID.GetValue()}).Debug("Offer Rescinded")
for _, agent := range s.cluster.agents {
if offer, ok := agent.offers[offerID.GetValue()]; ok {
s.cluster.removeOffer(offer)
break
}
}
}
// StatusUpdate method