Method InitGraphServer

src/graph/server/dist_graph_server.cc:57–92

using ::embedx::graph_op::LocalGSOpResource;

bool DistGraphServer::InitGraphServer(const GraphConfig& config) {
  resource_.reset(new graph_op::LocalGSOpResource);

  resource_->set_graph_config(config);

  // data
  auto graph = InMemoryGraph::Create(config);
  if (!graph) {
    return false;
  }
  resource_->set_graph(std::move(graph));

  auto sampler_source = NewGraphSamplerSource(resource_->graph());
  if (!sampler_source) {
    return false;
  }
  resource_->set_sampler_source(std::move(sampler_source));

  auto negative_sampler_builder = NewSamplerBuilder(
      resource_->sampler_source(), SamplerBuilderEnum::NEGATIVE_SAMPLER,
      config.negative_sampler_type(), config.thread_num());
  if (!negative_sampler_builder) {
    return false;
  }
  resource_->set_negative_sampler_builder(std::move(negative_sampler_builder));

  auto neighbor_sampler_builder = NewSamplerBuilder(
      resource_->sampler_source(), SamplerBuilderEnum::NEIGHBOR_SAMPLER,
      config.neighbor_sampler_type(), config.thread_num());
  if (!neighbor_sampler_builder) {
    return false;
  }
  resource_->set_neighbor_sampler_builder(std::move(neighbor_sampler_builder));

  return LocalGSOpFactory::GetInstance()->Init(resource_.get());
}

bool DistGraphServer::InitRpcServer(const GraphConfig& config) {
  vec_str_t ip_ports;