(&mut self, id: WorkerId, details: LostWorkerDetails)
| 2293 | } |
| 2294 | |
| 2295 | async fn stop_worker(&mut self, id: WorkerId, details: LostWorkerDetails) { |
| 2296 | self.handle.stop_worker(id).await; |
| 2297 | let config = self.workers.get(&id).unwrap(); |
| 2298 | let info = config.get_manager_info().unwrap(); |
| 2299 | assert!( |
| 2300 | handle_message( |
| 2301 | &mut self.state, |
| 2302 | &self.senders.events, |
| 2303 | AutoAllocMessage::WorkerLost(id, info, details) |
| 2304 | ) |
| 2305 | .await |
| 2306 | ); |
| 2307 | } |
| 2308 | |
| 2309 | async fn periodic_update(&mut self) { |
| 2310 | do_periodic_update(&self.senders, &mut self.state).await; |
no test coverage detected