Method Update

src/observer/executor/random_key_selector.cc:98–133

}

void RandomKeySelector::Update() {
  tera::ErrorCode err;
  while (true) {
    {
      MutexLock locker(&quit_mutex_);
      if (quit_) {
        return;
      }
      cond_.TimeWaitInUs(FLAGS_observer_update_table_info_period_s * 1000000);
    }

    // update data first
    std::shared_ptr<std::map<std::string, std::vector<tera::TabletInfo>>> table_update_copy(
        new std::map<std::string, std::vector<tera::TabletInfo>>);

    // updated table
    for (uint32_t i = 0; i < observe_tables_.size(); ++i) {
      std::string table_name = observe_tables_[i];

      std::vector<tera::TabletInfo> tablets;
      client_->GetTabletLocation(table_name, &tablets, &err);
      if (tera::ErrorCode::kOK != err.GetType()) {
        LOG(ERROR) << "Update table info failed, tablename:" << table_name
                   << " err:" << err.ToString();
        continue;
      }

      table_update_copy->insert(
          std::pair<std::string, std::vector<tera::TabletInfo>>(table_name, tablets));
    }

    // update pointer
    MutexLock locker(&table_mutex_);
    tables_.swap(table_update_copy);
  }
}

}  // namespace observer
}  // namespace tera