(
&mut self,
senders: &Senders,
worker_id: WorkerId,
configuration: &WorkerConfiguration,
)
| 179 | } |
| 180 | |
| 181 | pub fn process_worker_new( |
| 182 | &mut self, |
| 183 | senders: &Senders, |
| 184 | worker_id: WorkerId, |
| 185 | configuration: &WorkerConfiguration, |
| 186 | ) { |
| 187 | log::debug!("New worker id={worker_id}"); |
| 188 | self.add_worker(Worker::new(worker_id, configuration.clone())); |
| 189 | // TODO: use observer in event storage instead of sending these messages directly |
| 190 | senders |
| 191 | .autoalloc |
| 192 | .on_worker_connected(worker_id, configuration); |
| 193 | senders |
| 194 | .events |
| 195 | .on_worker_added(worker_id, configuration.clone()); |
| 196 | } |
| 197 | |
| 198 | pub fn process_worker_lost( |
| 199 | &mut self, |
no test coverage detected