| 11812 | |
| 11813 | |
| 11814 | void Master::rescindOffer(Offer* offer, const Option<Filters>& filters) |
| 11815 | { |
| 11816 | Framework* framework = getFramework(offer->framework_id()); |
| 11817 | CHECK(framework != nullptr) |
| 11818 | << "Unknown framework " << offer->framework_id() |
| 11819 | << " in the offer " << offer->id(); |
| 11820 | |
| 11821 | RescindResourceOfferMessage message; |
| 11822 | message.mutable_offer_id()->MergeFrom(offer->id()); |
| 11823 | |
| 11824 | framework->metrics.offers_rescinded++; |
| 11825 | framework->send(message); |
| 11826 | |
| 11827 | allocator->recoverResources( |
| 11828 | offer->framework_id(), |
| 11829 | offer->slave_id(), |
| 11830 | offer->resources(), |
| 11831 | filters, |
| 11832 | false); |
| 11833 | |
| 11834 | _removeOffer(framework, offer); |
| 11835 | } |
| 11836 | |
| 11837 | |
| 11838 | void Master::discardOffer(Offer* offer, const Option<Filters>& filters) |
no test coverage detected