未验证 提交 ed1678aa 编写于 作者: S seemingwang 提交者: GitHub

fix test api problem (#42297)

* extract sub-graph

* graph-engine merging

* fix

* fix

* fix heter-ps config

* test performance

* test performance

* test performance

* test

* test

* update bfs

* change cmake

* test

* test gpu speed

* gpu_graph_engine optimization

* add dsm sample method

* add graph_neighbor_sample_v2

* Add graph_neighbor_sample_v2

* fix for loop

* add cpu sample interface

* fix kernel judgement

* add ssd layer to graph_engine

* fix allocation

* fix syntax error

* fix syntax error

* fix pscore class

* fix

* change index settings

* recover test

* recover test

* fix spelling

* recover

* fix

* move cudamemcpy after cuda stream sync

* fix linking problem

* remove comment

* add cpu test

* test

* add cpu test

* change comment

* combine feature table and graph table

* test

* test

* pybind

* test

* test

* test

* test

* pybind

* pybind

* fix cmake

* pybind

* fix

* fix

* add pybind

* add pybind

* optimize pybind

* test

* fix pybind

* fix

* pybind change

* remove file
Co-authored-by: NDesmonDay <908660116@qq.com>
上级 b9bfcf14
...@@ -288,18 +288,18 @@ std::vector<int64_t> GraphGpuWrapper::graph_neighbor_sample( ...@@ -288,18 +288,18 @@ std::vector<int64_t> GraphGpuWrapper::graph_neighbor_sample(
} }
/* VLOG(0) << "cumsum " << cumsum; */ /* VLOG(0) << "cumsum " << cumsum; */
std::vector<int64_t> res; std::vector<int64_t> cpu_key, res;
res.resize(cumsum * 2); cpu_key.resize(key.size() * sample_size);
int count = 0;
cudaMemcpy(cpu_key.data(), neighbor_sample_res.val,
key.size() * sample_size * sizeof(int64_t),
cudaMemcpyDeviceToHost);
for (int i = 0; i < key.size(); i++) { for (int i = 0; i < key.size(); i++) {
for (int j = 0; j < actual_sample_size[i]; j++) { for (int j = 0; j < actual_sample_size[i]; j++) {
res[count] = key[i]; res.push_back(key[i]);
count += 1; res.push_back(cpu_key[i * sample_size + j]);
} }
} }
cudaMemcpy(res.data() + cumsum, neighbor_sample_res.val,
cumsum * sizeof(int64_t), cudaMemcpyDeviceToHost);
/* for(int i = 0;i < res.size();i ++) { */ /* for(int i = 0;i < res.size();i ++) { */
/* VLOG(0) << i << " " << res[i]; */ /* VLOG(0) << i << " " << res[i]; */
/* } */ /* } */
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册