Method SyncTabletsSchemaHandler

src/master/update_table_procedure.cc:147–178

}

void UpdateTableProcedure::SyncTabletsSchemaHandler(const UpdateTablePhase&) {
  if (sync_tablets_schema_) {
    return;
  }
  sync_tablets_schema_.store(true);
  PROC_LOG(INFO) << "begin sync tablets schema";
  tablet_sync_cnt_++;
  // No LoadTabletProcedure will be issued once the tablet falls into
  // kTabletOffline status while
  // UpdateTableProcedure is running, because UpdateTableProcedure has got the
  // tablet's TransitionLocks.
  // So UpdateTableProcedure should takes of those offline tablets by issue
  // LoadTabletProcedure for
  // those tablets at the right point of time.
  for (std::size_t i = 0; i < tablet_list_.size(); ++i) {
    TabletPtr tablet = tablet_list_[i];
    if (tablet->GetStatus() == TabletMeta::kTabletOffline) {
      offline_tablets_.emplace_back(tablet);
      continue;
    }
    UpdateClosure done = std::bind(&UpdateTableProcedure::UpdateTabletSchemaCallback, this, tablet,
                                   0, _1, _2, _3, _4);
    NoticeTabletSchemaUpdate(tablet_list_[i], done);
    tablet_sync_cnt_++;
  }
  if (--tablet_sync_cnt_ == 0) {
    RecoverOfflineTablets();
    table_->CommitUpdate();
    PROC_VLOG(23) << "sync tablets schema finished";
    EnterPhaseWithResponseStatus(kMasterOk, UpdateTablePhase::kEofPhase);
  }
}

void UpdateTableProcedure::NoticeTabletSchemaUpdate(TabletPtr tablet, UpdateClosure done) {
  tabletnode::TabletNodeClient node_client(thread_pool_, tablet->GetServerAddr());