Method ScheduleUpdateMeta

src/sdk/table_impl.cc:1896–1921

}

void TableImpl::ScheduleUpdateMeta(const std::string& row, int64_t meta_timestamp) {
  MutexLock lock(&meta_mutex_);
  TabletMetaNode* node = GetTabletMetaNodeForKey(row);
  if (node == NULL) {
    TabletMetaNode& new_node = tablet_meta_list_[row];
    new_node.meta.mutable_key_range()->set_key_start(row);
    new_node.meta.mutable_key_range()->set_key_end(row + '\0');
    new_node.status = WAIT_UPDATE;
    UpdateMetaAsync();
    return;
  }
  if (node->status == NORMAL && meta_timestamp >= node->update_time) {
    int64_t update_interval =
        node->update_time + FLAGS_tera_sdk_update_meta_internal - get_micros() / 1000;
    if (update_interval <= 0) {
      node->status = WAIT_UPDATE;
      UpdateMetaAsync();
    } else {
      node->status = DELAY_UPDATE;
      ThreadPool::Task delay_task =
          std::bind(&TableImpl::DelayUpdateMeta, this, node->meta.key_range().key_start(),
                    node->meta.key_range().key_end());
      thread_pool_->DelayTask(update_interval, delay_task);
    }
  }
}

bool TableImpl::UpdateTableMeta(ErrorCode* err) {
  MutexLock lock(&table_meta_mutex_);