Method GetTabletAddrOrScheduleUpdateMeta

src/sdk/table_impl.cc:1452–1498

}

bool TableImpl::GetTabletAddrOrScheduleUpdateMeta(const std::string& row, SdkTask* task,
                                                  std::string* server_addr) {
  CHECK_NOTNULL(task);
  MutexLock lock(&meta_mutex_);
  TabletMetaNode* node = GetTabletMetaNodeForKey(row);
  if (node == NULL) {
    VLOG(10) << "no meta for key: " << row;
    pending_task_id_list_[row].push_back(task->GetId());
    task->DecRef();
    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 false;
  }
  if (node->status != NORMAL) {
    VLOG(10) << "abnormal meta for key: " << row;
    pending_task_id_list_[row].push_back(task->GetId());
    task->DecRef();
    return false;
  }
  if ((task->GetInternalError() == kKeyNotInRange || task->GetInternalError() == kConnectError) &&
      task->GetMetaTimeStamp() >= node->update_time) {
    pending_task_id_list_[row].push_back(task->GetId());
    task->DecRef();
    int64_t update_interval =
        node->update_time + FLAGS_tera_sdk_update_meta_internal - get_micros() / 1000;
    if (update_interval <= 0) {
      VLOG(10) << "update meta now for key: " << row;
      node->status = WAIT_UPDATE;
      UpdateMetaAsync();
    } else {
      VLOG(10) << "update meta in " << update_interval << " (ms) for key:" << row;
      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);
    }
    return false;
  }
  CHECK_EQ(node->status, NORMAL);
  task->SetMetaTimeStamp(node->update_time);
  *server_addr = node->meta.server_addr();
  return true;
}

TableImpl::TabletMetaNode* TableImpl::GetTabletMetaNodeForKey(const std::string& key) {
  meta_mutex_.AssertHeld();