Method LoadGraphAndIndex

euler/service/grpc_server.cc:100–192

}

Status GrpcServer::LoadGraphAndIndex() {
  auto& options = server_def_.options;
  auto it = options.find("data_path");
  if (it == options.end()) {
    return Status::InvalidArgument(
        "Server options[data_path] must be specified!");
  }

  auto& data_path = it->second;

  std::unique_ptr<FileIO> data_dir;
  RETURN_IF_ERROR(Env::Default()->NewFileIO(data_path, true, &data_dir));
  if (!data_dir->initialized() || !data_dir->IsDirectory()) {
    EULER_LOG(ERROR) << "No such directory found, path: " << data_path;
    return Status::NotFound("Directory ", data_path, " not found!");
  }

  std::string sampler_type = "node";
  it = options.find("global_sampler_type");
  if (it != options.end()) {
    sampler_type = it->second;
  }

  std::string load_data_type = "node";
  it = options.find("load_data_type");
  if (it != options.end()) {
    load_data_type = it->second;
  }

  auto& graph = Graph::Instance();

  // Load Graph
  RETURN_IF_ERROR(graph.Init(server_def_.shard_index,
                             server_def_.shard_number,
                             sampler_type, data_path, load_data_type));

  it = options.find("zk_server");
  if (it == options.end()) {
    return Status::InvalidArgument(
        "Server options[zk_server] must be specified!");
  }
  zk_server_ = it->second;

  it = options.find("zk_path");
  if (it == options.end()) {
    return Status::InvalidArgument(
        "Server options[zk_path] must be specified!");
  }
  zk_path_ = it->second;

  host_port_ = GetIP();
  it = options.find("server");
  if (it != options.end()) {
    host_port_ = it->second;
  }
  host_port_ += ":" + std::to_string(bound_port_);

  auto& index_manager = IndexManager::Instance();