| 85 | } |
| 86 | |
| 87 | void MoveTabletProcedure::LoadTabletPhaseHandler(const MoveTabletPhase&) { |
| 88 | if (!load_proc_) { |
| 89 | tablet_->IncVersion(); |
| 90 | load_proc_.reset(new LoadTabletProcedure(tablet_, dest_node_, thread_pool_, true)); |
| 91 | PROC_LOG(INFO) << "MoveTablet: generate async LoadTabletProcedure: " << load_proc_->ProcId() |
| 92 | << "tablet " << tablet_; |
| 93 | MasterEnv().GetExecutor()->AddProcedure(load_proc_); |
| 94 | } |
| 95 | SetNextPhase(MoveTabletPhase::kEofPhase); |
| 96 | } |
| 97 | |
| 98 | void MoveTabletProcedure::EOFPhaseHandler(const MoveTabletPhase&) { |
| 99 | PROC_LOG(INFO) << "tablet: " << tablet_->GetPath() << "move EOF_PHASE"; |