Start Phase 1: Base Copy.
(&mut self, bytes_total: u64)
| 89 | |
| 90 | /// Start Phase 1: Base Copy. |
| 91 | pub fn start_base_copy(&mut self, bytes_total: u64) { |
| 92 | self.started_at = Some(Instant::now()); |
| 93 | self.phase = MigrationPhase::BaseCopy { |
| 94 | bytes_transferred: 0, |
| 95 | bytes_total, |
| 96 | }; |
| 97 | info!( |
| 98 | vshard = self.vshard_id, |
| 99 | source = self.source_node, |
| 100 | target = self.target_node, |
| 101 | bytes_total, |
| 102 | "starting base copy" |
| 103 | ); |
| 104 | } |
| 105 | |
| 106 | /// Update base copy progress. |
| 107 | pub fn update_base_copy(&mut self, bytes_transferred: u64) { |