#include #include #include "./common.h" using namespace dgl; using namespace dgl::runtime; namespace { template aten::CSRMatrix CSR1(DLContext ctx = CTX) { // [[0, 1, 1, 0, 0], // [1, 0, 0, 0, 0], // [0, 0, 1, 1, 0], // [0, 0, 0, 0, 0]] // data: [0, 2, 3, 1, 4] return aten::CSRMatrix( 4, 5, aten::VecToIdArray(std::vector({0, 2, 3, 5, 5}), sizeof(IDX)*8, ctx), aten::VecToIdArray(std::vector({1, 2, 0, 2, 3}), sizeof(IDX)*8, ctx), aten::VecToIdArray(std::vector({0, 2, 3, 1, 4}), sizeof(IDX)*8, ctx), false); } template aten::CSRMatrix CSR2(DLContext ctx = CTX) { // has duplicate entries // [[0, 1, 2, 0, 0], // [1, 0, 0, 0, 0], // [0, 0, 1, 1, 0], // [0, 0, 0, 0, 0]] // data: [0, 2, 5, 3, 1, 4] return aten::CSRMatrix( 4, 5, aten::VecToIdArray(std::vector({0, 3, 4, 6, 6}), sizeof(IDX)*8, ctx), aten::VecToIdArray(std::vector({1, 2, 2, 0, 2, 3}), sizeof(IDX)*8, ctx), aten::VecToIdArray(std::vector({0, 2, 5, 3, 1, 4}), sizeof(IDX)*8, ctx), false); } template aten::COOMatrix COO1(DLContext ctx = CTX) { // [[0, 1, 1, 0, 0], // [1, 0, 0, 0, 0], // [0, 0, 1, 1, 0], // [0, 0, 0, 0, 0]] // data: [0, 2, 3, 1, 4] // row : [0, 2, 0, 1, 2] // col : [1, 2, 2, 0, 3] return aten::COOMatrix( 4, 5, aten::VecToIdArray(std::vector({0, 2, 0, 1, 2}), sizeof(IDX)*8, ctx), aten::VecToIdArray(std::vector({1, 2, 2, 0, 3}), sizeof(IDX)*8, ctx)); } template aten::COOMatrix COO2(DLContext ctx = CTX) { // has duplicate entries // [[0, 1, 2, 0, 0], // [1, 0, 0, 0, 0], // [0, 0, 1, 1, 0], // [0, 0, 0, 0, 0]] // data: [0, 2, 5, 3, 1, 4] // row : [0, 2, 0, 1, 2, 0] // col : [1, 2, 2, 0, 3, 2] return aten::COOMatrix( 4, 5, aten::VecToIdArray(std::vector({0, 2, 0, 1, 2, 0}), sizeof(IDX)*8, ctx), aten::VecToIdArray(std::vector({1, 2, 2, 0, 3, 2}), sizeof(IDX)*8, ctx)); } template aten::CSRMatrix SR_CSR3(DLContext ctx) { // [[0, 1, 2, 0, 0], // [1, 0, 0, 0, 0], // [0, 0, 1, 1, 0], // [0, 0, 0, 0, 0]] return aten::CSRMatrix( 4, 5, aten::VecToIdArray(std::vector({0, 3, 4, 6, 6}), sizeof(IDX)*8, ctx), aten::VecToIdArray(std::vector({2, 1, 2, 0, 2, 3}), sizeof(IDX)*8, ctx), aten::VecToIdArray(std::vector({0, 2, 5, 3, 1, 4}), sizeof(IDX)*8, ctx), false); } template aten::CSRMatrix SRC_CSR3(DLContext ctx) { // [[0, 1, 2, 0, 0], // [1, 0, 0, 0, 0], // [0, 0, 1, 1, 0], // [0, 0, 0, 0, 0]] return aten::CSRMatrix( 4, 5, aten::VecToIdArray(std::vector({0, 3, 4, 6, 6}), sizeof(IDX)*8, ctx), aten::VecToIdArray(std::vector({1, 2, 2, 0, 2, 3}), sizeof(IDX)*8, ctx), aten::VecToIdArray(std::vector({2, 0, 5, 3, 1, 4}), sizeof(IDX)*8, ctx), false); } template aten::COOMatrix COO3(DLContext ctx) { // has duplicate entries // [[0, 1, 2, 0, 0], // [1, 0, 0, 0, 0], // [0, 0, 1, 1, 0], // [0, 0, 0, 0, 0]] // row : [0, 2, 0, 1, 2, 0] // col : [2, 2, 1, 0, 3, 2] return aten::COOMatrix( 4, 5, aten::VecToIdArray(std::vector({0, 2, 0, 1, 2, 0}), sizeof(IDX)*8, ctx), aten::VecToIdArray(std::vector({2, 2, 1, 0, 3, 2}), sizeof(IDX)*8, ctx)); } } // namespace template void _TestCSRIsNonZero() { auto csr = CSR1(); ASSERT_TRUE(aten::CSRIsNonZero(csr, 0, 1)); ASSERT_FALSE(aten::CSRIsNonZero(csr, 0, 0)); IdArray r = aten::VecToIdArray(std::vector({2, 2, 0, 0}), sizeof(IDX)*8, CTX); IdArray c = aten::VecToIdArray(std::vector({1, 1, 1, 3}), sizeof(IDX)*8, CTX); IdArray x = aten::CSRIsNonZero(csr, r, c); IdArray tx = aten::VecToIdArray(std::vector({0, 0, 1, 0}), sizeof(IDX)*8, CTX); ASSERT_TRUE(ArrayEQ(x, tx)); } TEST(SpmatTest, TestCSRIsNonZero) { _TestCSRIsNonZero(); _TestCSRIsNonZero(); } template void _TestCSRGetRowNNZ() { auto csr = CSR2(); ASSERT_EQ(aten::CSRGetRowNNZ(csr, 0), 3); ASSERT_EQ(aten::CSRGetRowNNZ(csr, 3), 0); IdArray r = aten::VecToIdArray(std::vector({0, 3}), sizeof(IDX)*8, CTX); IdArray x = aten::CSRGetRowNNZ(csr, r); IdArray tx = aten::VecToIdArray(std::vector({3, 0}), sizeof(IDX)*8, CTX); ASSERT_TRUE(ArrayEQ(x, tx)); } TEST(SpmatTest, TestCSRGetRowNNZ) { _TestCSRGetRowNNZ(); _TestCSRGetRowNNZ(); } template void _TestCSRGetRowColumnIndices() { auto csr = CSR2(); auto x = aten::CSRGetRowColumnIndices(csr, 0); auto tx = aten::VecToIdArray(std::vector({1, 2, 2}), sizeof(IDX)*8, CTX); ASSERT_TRUE(ArrayEQ(x, tx)); x = aten::CSRGetRowColumnIndices(csr, 1); tx = aten::VecToIdArray(std::vector({0}), sizeof(IDX)*8, CTX); ASSERT_TRUE(ArrayEQ(x, tx)); x = aten::CSRGetRowColumnIndices(csr, 3); tx = aten::VecToIdArray(std::vector({}), sizeof(IDX)*8, CTX); ASSERT_TRUE(ArrayEQ(x, tx)); } TEST(SpmatTest, TestCSRGetRowColumnIndices) { _TestCSRGetRowColumnIndices(); _TestCSRGetRowColumnIndices(); } template void _TestCSRGetRowData() { auto csr = CSR2(); auto x = aten::CSRGetRowData(csr, 0); auto tx = aten::VecToIdArray(std::vector({0, 2, 5}), sizeof(IDX)*8, CTX); ASSERT_TRUE(ArrayEQ(x, tx)); x = aten::CSRGetRowData(csr, 1); tx = aten::VecToIdArray(std::vector({3}), sizeof(IDX)*8, CTX); ASSERT_TRUE(ArrayEQ(x, tx)); x = aten::CSRGetRowData(csr, 3); tx = aten::VecToIdArray(std::vector({}), sizeof(IDX)*8, CTX); ASSERT_TRUE(ArrayEQ(x, tx)); } TEST(SpmatTest, TestCSRGetRowData) { _TestCSRGetRowData(); _TestCSRGetRowData(); } template void _TestCSRGetData() { auto csr = CSR2(); auto x = aten::CSRGetData(csr, 0, 0); auto tx = aten::VecToIdArray(std::vector({}), sizeof(IDX)*8, CTX); ASSERT_TRUE(ArrayEQ(x, tx)); x = aten::CSRGetData(csr, 0, 2); tx = aten::VecToIdArray(std::vector({2, 5}), sizeof(IDX)*8, CTX); ASSERT_TRUE(ArrayEQ(x, tx)); auto r = aten::VecToIdArray(std::vector({0, 0, 0}), sizeof(IDX)*8, CTX); auto c = aten::VecToIdArray(std::vector({0, 1, 2}), sizeof(IDX)*8, CTX); x = aten::CSRGetData(csr, r, c); tx = aten::VecToIdArray(std::vector({0, 2, 5}), sizeof(IDX)*8, CTX); ASSERT_TRUE(ArrayEQ(x, tx)); } TEST(SpmatTest, TestCSRGetData) { _TestCSRGetData(); _TestCSRGetData(); } template void _TestCSRGetDataAndIndices() { auto csr = CSR2(); auto r = aten::VecToIdArray(std::vector({0, 0, 0}), sizeof(IDX)*8, CTX); auto c = aten::VecToIdArray(std::vector({0, 1, 2}), sizeof(IDX)*8, CTX); auto x = aten::CSRGetDataAndIndices(csr, r, c); auto tr = aten::VecToIdArray(std::vector({0, 0, 0}), sizeof(IDX)*8, CTX); auto tc = aten::VecToIdArray(std::vector({1, 2, 2}), sizeof(IDX)*8, CTX); auto td = aten::VecToIdArray(std::vector({0, 2, 5}), sizeof(IDX)*8, CTX); ASSERT_TRUE(ArrayEQ(x[0], tr)); ASSERT_TRUE(ArrayEQ(x[1], tc)); ASSERT_TRUE(ArrayEQ(x[2], td)); } TEST(SpmatTest, TestCSRGetDataAndIndices) { _TestCSRGetDataAndIndices(); _TestCSRGetDataAndIndices(); } template void _TestCSRTranspose(DLContext ctx) { auto csr = CSR2(ctx); auto csr_t = aten::CSRTranspose(csr); // [[0, 1, 0, 0], // [1, 0, 0, 0], // [2, 0, 1, 0], // [0, 0, 1, 0], // [0, 0, 0, 0]] // data: [3, 0, 2, 5, 1, 4] ASSERT_EQ(csr_t.num_rows, 5); ASSERT_EQ(csr_t.num_cols, 4); auto tp = aten::VecToIdArray(std::vector({0, 1, 2, 5, 6, 6}), sizeof(IDX)*8, ctx); auto ti = aten::VecToIdArray(std::vector({1, 0, 0, 0, 2, 2}), sizeof(IDX)*8, ctx); auto td = aten::VecToIdArray(std::vector({3, 0, 2, 5, 1, 4}), sizeof(IDX)*8, ctx); ASSERT_TRUE(ArrayEQ(csr_t.indptr, tp)); ASSERT_TRUE(ArrayEQ(csr_t.indices, ti)); ASSERT_TRUE(ArrayEQ(csr_t.data, td)); } TEST(SpmatTest, TestCSRTranspose) { _TestCSRTranspose(CPU); _TestCSRTranspose(CPU); #ifdef DGL_USE_CUDA _TestCSRTranspose(GPU); #endif } template void _TestCSRToCOO(DLContext ctx) { auto csr = CSR2(ctx); { auto coo = CSRToCOO(csr, false); ASSERT_EQ(coo.num_rows, 4); ASSERT_EQ(coo.num_cols, 5); auto tr = aten::VecToIdArray(std::vector({0, 0, 0, 1, 2, 2}), sizeof(IDX)*8, ctx); auto tc = aten::VecToIdArray(std::vector({1, 2, 2, 0, 2, 3}), sizeof(IDX)*8, ctx); auto td = aten::VecToIdArray(std::vector({0, 2, 5, 3, 1, 4}), sizeof(IDX)*8, ctx); ASSERT_TRUE(ArrayEQ(coo.row, tr)); ASSERT_TRUE(ArrayEQ(coo.col, tc)); ASSERT_TRUE(ArrayEQ(coo.data, td)); } { auto coo = CSRToCOO(csr, true); ASSERT_EQ(coo.num_rows, 4); ASSERT_EQ(coo.num_cols, 5); auto tcoo = COO2(ctx); ASSERT_TRUE(ArrayEQ(coo.row, tcoo.row)); ASSERT_TRUE(ArrayEQ(coo.col, tcoo.col)); } } TEST(SpmatTest, TestCSRToCOO) { _TestCSRToCOO(CPU); _TestCSRToCOO(CPU); #if DGL_USE_CUDA _TestCSRToCOO(GPU); #endif } template void _TestCSRSliceRows() { auto csr = CSR2(); auto x = aten::CSRSliceRows(csr, 1, 4); // [1, 0, 0, 0, 0], // [0, 0, 1, 1, 0], // [0, 0, 0, 0, 0]] // data: [3, 1, 4] ASSERT_EQ(x.num_rows, 3); ASSERT_EQ(x.num_cols, 5); auto tp = aten::VecToIdArray(std::vector({0, 1, 3, 3}), sizeof(IDX)*8, CTX); auto ti = aten::VecToIdArray(std::vector({0, 2, 3}), sizeof(IDX)*8, CTX); auto td = aten::VecToIdArray(std::vector({3, 1, 4}), sizeof(IDX)*8, CTX); ASSERT_TRUE(ArrayEQ(x.indptr, tp)); ASSERT_TRUE(ArrayEQ(x.indices, ti)); ASSERT_TRUE(ArrayEQ(x.data, td)); auto r = aten::VecToIdArray(std::vector({0, 1, 3}), sizeof(IDX)*8, CTX); x = aten::CSRSliceRows(csr, r); // [[0, 1, 2, 0, 0], // [1, 0, 0, 0, 0], // [0, 0, 0, 0, 0]] // data: [0, 2, 5, 3] tp = aten::VecToIdArray(std::vector({0, 3, 4, 4}), sizeof(IDX)*8, CTX); ti = aten::VecToIdArray(std::vector({1, 2, 2, 0}), sizeof(IDX)*8, CTX); td = aten::VecToIdArray(std::vector({0, 2, 5, 3}), sizeof(IDX)*8, CTX); ASSERT_TRUE(ArrayEQ(x.indptr, tp)); ASSERT_TRUE(ArrayEQ(x.indices, ti)); ASSERT_TRUE(ArrayEQ(x.data, td)); } TEST(SpmatTest, TestCSRSliceRows) { _TestCSRSliceRows(); _TestCSRSliceRows(); } template void _TestCSRSliceMatrix() { auto csr = CSR2(); auto r = aten::VecToIdArray(std::vector({0, 1, 3}), sizeof(IDX)*8, CTX); auto c = aten::VecToIdArray(std::vector({1, 2, 3}), sizeof(IDX)*8, CTX); auto x = aten::CSRSliceMatrix(csr, r, c); // [[1, 2, 0], // [0, 0, 0], // [0, 0, 0]] // data: [0, 2, 5] ASSERT_EQ(x.num_rows, 3); ASSERT_EQ(x.num_cols, 3); auto tp = aten::VecToIdArray(std::vector({0, 3, 3, 3}), sizeof(IDX)*8, CTX); auto ti = aten::VecToIdArray(std::vector({0, 1, 1}), sizeof(IDX)*8, CTX); auto td = aten::VecToIdArray(std::vector({0, 2, 5}), sizeof(IDX)*8, CTX); ASSERT_TRUE(ArrayEQ(x.indptr, tp)); ASSERT_TRUE(ArrayEQ(x.indices, ti)); ASSERT_TRUE(ArrayEQ(x.data, td)); } TEST(SpmatTest, TestCSRSliceMatrix) { _TestCSRSliceMatrix(); _TestCSRSliceMatrix(); } template void _TestCSRHasDuplicate() { auto csr = CSR1(); ASSERT_FALSE(aten::CSRHasDuplicate(csr)); csr = CSR2(); ASSERT_TRUE(aten::CSRHasDuplicate(csr)); } TEST(SpmatTest, TestCSRHasDuplicate) { _TestCSRHasDuplicate(); _TestCSRHasDuplicate(); } template void _TestCOOToCSR(DLContext ctx) { auto coo = COO1(ctx); auto csr = CSR1(ctx); auto tcsr = aten::COOToCSR(coo); ASSERT_EQ(coo.num_rows, csr.num_rows); ASSERT_EQ(coo.num_cols, csr.num_cols); ASSERT_TRUE(ArrayEQ(csr.indptr, tcsr.indptr)); coo = COO2(ctx); csr = CSR2(ctx); tcsr = aten::COOToCSR(coo); ASSERT_EQ(coo.num_rows, csr.num_rows); ASSERT_EQ(coo.num_cols, csr.num_cols); ASSERT_TRUE(ArrayEQ(csr.indptr, tcsr.indptr)); coo = COO1(ctx); auto rs_coo = aten::COOSort(coo, false); auto rs_csr = CSR1(ctx); auto rs_tcsr = aten::COOToCSR(rs_coo); ASSERT_EQ(coo.num_rows, rs_tcsr.num_rows); ASSERT_EQ(coo.num_cols, rs_tcsr.num_cols); ASSERT_TRUE(ArrayEQ(rs_csr.indptr, rs_tcsr.indptr)); coo = COO3(ctx); rs_coo = aten::COOSort(coo, false); rs_csr = SR_CSR3(ctx); rs_tcsr = aten::COOToCSR(rs_coo); ASSERT_EQ(coo.num_rows, rs_tcsr.num_rows); ASSERT_EQ(coo.num_cols, rs_tcsr.num_cols); ASSERT_TRUE(ArrayEQ(rs_csr.indptr, rs_tcsr.indptr)); coo = COO1(ctx); auto src_coo = aten::COOSort(coo, true); auto src_csr = CSR1(ctx); auto src_tcsr = aten::COOToCSR(src_coo); ASSERT_EQ(coo.num_rows, src_tcsr.num_rows); ASSERT_EQ(coo.num_cols, src_tcsr.num_cols); ASSERT_TRUE(ArrayEQ(src_csr.indptr, src_tcsr.indptr)); ASSERT_TRUE(ArrayEQ(src_csr.indices, src_tcsr.indices)); ASSERT_TRUE(ArrayEQ(src_csr.data, src_tcsr.data)); coo = COO3(ctx); src_coo = aten::COOSort(coo, true); src_csr = SRC_CSR3(ctx); src_tcsr = aten::COOToCSR(src_coo); ASSERT_EQ(coo.num_rows, src_tcsr.num_rows); ASSERT_EQ(coo.num_cols, src_tcsr.num_cols); ASSERT_TRUE(ArrayEQ(src_csr.indptr, src_tcsr.indptr)); ASSERT_TRUE(ArrayEQ(src_csr.indices, src_tcsr.indices)); ASSERT_TRUE(ArrayEQ(src_csr.data, src_tcsr.data)); } TEST(SpmatTest, TestCOOToCSR) { _TestCOOToCSR(CPU); _TestCOOToCSR(CPU); #ifdef DGL_USE_CUDA _TestCOOToCSR(GPU); #endif } template void _TestCOOHasDuplicate() { auto csr = COO1(); ASSERT_FALSE(aten::COOHasDuplicate(csr)); csr = COO2(); ASSERT_TRUE(aten::COOHasDuplicate(csr)); } TEST(SpmatTest, TestCOOHasDuplicate) { _TestCOOHasDuplicate(); _TestCOOHasDuplicate(); } template void _TestCOOSort(DLContext ctx) { auto coo = COO3(ctx); auto sr_coo = COOSort(coo, false); ASSERT_EQ(coo.num_rows, sr_coo.num_rows); ASSERT_EQ(coo.num_cols, sr_coo.num_cols); auto src_coo = COOSort(coo, true); ASSERT_EQ(coo.num_rows, src_coo.num_rows); ASSERT_EQ(coo.num_cols, src_coo.num_cols); // COO3 // [[0, 1, 2, 0, 0], // [1, 0, 0, 0, 0], // [0, 0, 1, 1, 0], // [0, 0, 0, 0, 0]] // data: [0, 1, 2, 3, 4, 5] // row : [0, 2, 0, 1, 2, 0] // col : [2, 2, 1, 0, 3, 2] // Row Sorted // data: [0, 2, 5, 3, 1, 4] // row : [0, 0, 0, 1, 2, 2] // col : [2, 1, 2, 0, 2, 3] // Row Col Sorted // data: [2, 0, 5, 3, 1, 4] // row : [0, 0, 0, 1, 2, 2] // col : [1, 2, 2, 0, 2, 3] auto sort_row = aten::VecToIdArray( std::vector({0, 0, 0, 1, 2, 2}), sizeof(IDX)*8, ctx); auto sort_col = aten::VecToIdArray( std::vector({1, 2, 2, 0, 2, 3}), sizeof(IDX)*8, ctx); auto sort_col_data = aten::VecToIdArray( std::vector({2, 0, 5, 3, 1, 4}), sizeof(IDX)*8, ctx); ASSERT_TRUE(ArrayEQ(sr_coo.row, sort_row)); ASSERT_TRUE(ArrayEQ(src_coo.row, sort_row)); ASSERT_TRUE(ArrayEQ(src_coo.col, sort_col)); ASSERT_TRUE(ArrayEQ(src_coo.data, sort_col_data)); } TEST(SpmatTest, TestCOOSort) { _TestCOOSort(CPU); _TestCOOSort(CPU); #ifdef DGL_USE_CUDA _TestCOOSort(GPU); #endif }