From 134df4293cffa439ee542ff3644332b20d58ef48 Mon Sep 17 00:00:00 2001 From: Yongqiao Wang Date: Wed, 24 Feb 2016 15:46:31 +0800 Subject: [PATCH] Support rescind offer in swarm. Signed-off-by: Yongqiao Wang --- cluster/mesos/scheduler.go | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/cluster/mesos/scheduler.go b/cluster/mesos/scheduler.go index 6d17be04f0..be93cf3c39 100644 --- a/cluster/mesos/scheduler.go +++ b/cluster/mesos/scheduler.go @@ -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