(&mut self, cmd: ComputeCommand)
| 429 | } |
| 430 | |
| 431 | fn handle_command(&mut self, cmd: ComputeCommand) { |
| 432 | if matches!(&cmd, ComputeCommand::CreateInstance(_)) { |
| 433 | self.compute_state = Some(ComputeState::new( |
| 434 | Arc::clone(&self.persist_clients), |
| 435 | self.txns_ctx.clone(), |
| 436 | self.metrics.clone(), |
| 437 | Arc::clone(&self.tracing_handle), |
| 438 | self.context.clone(), |
| 439 | self.metrics_registry.clone(), |
| 440 | self.workers_per_process, |
| 441 | self.storage_log_reader.take(), |
| 442 | )); |
| 443 | } |
| 444 | self.activate_compute().unwrap().handle_compute_command(cmd); |
| 445 | } |
| 446 | |
| 447 | fn activate_compute(&mut self) -> Option<ActiveComputeState<'_>> { |
| 448 | if let Some(compute_state) = &mut self.compute_state { |
no test coverage detected