| 3242 | |
| 3243 | |
| 3244 | void Master::updateFramework( |
| 3245 | const process::UPID& from, |
| 3246 | mesos::scheduler::Call::UpdateFramework&& call) |
| 3247 | { |
| 3248 | FrameworkID frameworkId = call.framework_info().id(); |
| 3249 | |
| 3250 | updateFramework(std::move(call)) |
| 3251 | .onAny(defer(self(), [this, from, frameworkId]( |
| 3252 | const Future<process::http::Response>& response) { |
| 3253 | if (response->code != process::http::Status::OK) { |
| 3254 | CHECK_EQ(response->type, process::http::Response::BODY); |
| 3255 | FrameworkErrorMessage message; |
| 3256 | message.set_message(response->body); |
| 3257 | send(from, message); |
| 3258 | } |
| 3259 | })); |
| 3260 | } |
| 3261 | |
| 3262 | |
| 3263 | Future<process::http::Response> Master::updateFramework( |
nothing calls this directly
no test coverage detected