/* ************************************************************************ * Copyright (c) 2019 Advanced Micro Devices, Inc. * * Permission is hereby granted, free of charge, to any person obtaining a copy * of this software and associated documentation files (the "Software"), to deal * in the Software without restriction, including without limitation the rights * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell * copies of the Software, and to permit persons to whom the Software is * furnished to do so, subject to the following conditions: * * The above copyright notice and this permission notice shall be included in * all copies or substantial portions of the Software. * * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN * THE SOFTWARE. * * ************************************************************************ */ #pragma once #ifndef TESTING_CSR2CSC_HPP #define TESTING_CSR2CSC_HPP #include #include "gbyte.hpp" #include "rocsparse_check.hpp" #include "rocsparse_host.hpp" #include "rocsparse_init.hpp" #include "rocsparse_math.hpp" #include "rocsparse_random.hpp" #include "rocsparse_test.hpp" #include "rocsparse_vector.hpp" #include "utility.hpp" template void testing_csr2csc_bad_arg(const Arguments& arg) { static const size_t safe_size = 100; // Create rocsparse handle rocsparse_local_handle handle; // Allocate memory on device device_vector dcsr_row_ptr(safe_size); device_vector dcsr_col_ind(safe_size); device_vector dcsr_val(safe_size); device_vector dcsc_row_ind(safe_size); device_vector dcsc_col_ptr(safe_size); device_vector dcsc_val(safe_size); device_vector dbuffer(safe_size); if(!dcsr_row_ptr || !dcsr_col_ind || !dcsr_val || !dcsc_row_ind || !dcsc_col_ptr || !dcsc_val || !dbuffer) { CHECK_HIP_ERROR(hipErrorOutOfMemory); return; } // Test rocsparse_csr2csc_buffer_size() size_t buffer_size; EXPECT_ROCSPARSE_STATUS(rocsparse_csr2csc_buffer_size(nullptr, safe_size, safe_size, safe_size, dcsr_row_ptr, dcsr_col_ind, rocsparse_action_numeric, &buffer_size), rocsparse_status_invalid_handle); EXPECT_ROCSPARSE_STATUS(rocsparse_csr2csc_buffer_size(handle, safe_size, safe_size, safe_size, nullptr, dcsr_col_ind, rocsparse_action_numeric, &buffer_size), rocsparse_status_invalid_pointer); EXPECT_ROCSPARSE_STATUS(rocsparse_csr2csc_buffer_size(handle, safe_size, safe_size, safe_size, dcsr_row_ptr, nullptr, rocsparse_action_numeric, &buffer_size), rocsparse_status_invalid_pointer); EXPECT_ROCSPARSE_STATUS(rocsparse_csr2csc_buffer_size(handle, safe_size, safe_size, safe_size, dcsr_row_ptr, dcsr_col_ind, rocsparse_action_numeric, nullptr), rocsparse_status_invalid_pointer); // Test rocsparse_csr2csc() EXPECT_ROCSPARSE_STATUS(rocsparse_csr2csc(nullptr, safe_size, safe_size, safe_size, dcsr_val, dcsr_row_ptr, dcsr_col_ind, dcsc_val, dcsc_row_ind, dcsc_col_ptr, rocsparse_action_numeric, rocsparse_index_base_zero, dbuffer), rocsparse_status_invalid_handle); EXPECT_ROCSPARSE_STATUS(rocsparse_csr2csc(handle, safe_size, safe_size, safe_size, nullptr, dcsr_row_ptr, dcsr_col_ind, dcsc_val, dcsc_row_ind, dcsc_col_ptr, rocsparse_action_numeric, rocsparse_index_base_zero, dbuffer), rocsparse_status_invalid_pointer); EXPECT_ROCSPARSE_STATUS(rocsparse_csr2csc(handle, safe_size, safe_size, safe_size, dcsr_val, nullptr, dcsr_col_ind, dcsc_val, dcsc_row_ind, dcsc_col_ptr, rocsparse_action_numeric, rocsparse_index_base_zero, dbuffer), rocsparse_status_invalid_pointer); EXPECT_ROCSPARSE_STATUS(rocsparse_csr2csc(handle, safe_size, safe_size, safe_size, dcsr_val, dcsr_row_ptr, nullptr, dcsc_val, dcsc_row_ind, dcsc_col_ptr, rocsparse_action_numeric, rocsparse_index_base_zero, dbuffer), rocsparse_status_invalid_pointer); EXPECT_ROCSPARSE_STATUS(rocsparse_csr2csc(handle, safe_size, safe_size, safe_size, dcsr_val, dcsr_row_ptr, dcsr_col_ind, nullptr, dcsc_row_ind, dcsc_col_ptr, rocsparse_action_numeric, rocsparse_index_base_zero, dbuffer), rocsparse_status_invalid_pointer); EXPECT_ROCSPARSE_STATUS(rocsparse_csr2csc(handle, safe_size, safe_size, safe_size, dcsr_val, dcsr_row_ptr, dcsr_col_ind, dcsc_val, nullptr, dcsc_col_ptr, rocsparse_action_numeric, rocsparse_index_base_zero, dbuffer), rocsparse_status_invalid_pointer); EXPECT_ROCSPARSE_STATUS(rocsparse_csr2csc(handle, safe_size, safe_size, safe_size, dcsr_val, dcsr_row_ptr, dcsr_col_ind, dcsc_val, dcsc_row_ind, nullptr, rocsparse_action_numeric, rocsparse_index_base_zero, dbuffer), rocsparse_status_invalid_pointer); EXPECT_ROCSPARSE_STATUS(rocsparse_csr2csc(handle, safe_size, safe_size, safe_size, dcsr_val, dcsr_row_ptr, dcsr_col_ind, dcsc_val, dcsc_row_ind, dcsc_col_ptr, rocsparse_action_numeric, rocsparse_index_base_zero, nullptr), rocsparse_status_invalid_pointer); } template void testing_csr2csc(const Arguments& arg) { rocsparse_int M = arg.M; rocsparse_int N = arg.N; rocsparse_int K = arg.K; rocsparse_int dim_x = arg.dimx; rocsparse_int dim_y = arg.dimy; rocsparse_int dim_z = arg.dimz; rocsparse_index_base base = arg.baseA; rocsparse_matrix_init mat = arg.matrix; rocsparse_action action = arg.action; bool full_rank = false; std::string filename = arg.timing ? arg.filename : rocsparse_exepath() + "../matrices/" + arg.filename + ".csr"; // Create rocsparse handle rocsparse_local_handle handle; // Argument sanity check before allocating invalid memory if(M <= 0 || N <= 0) { static const size_t safe_size = 100; // Allocate memory on device device_vector dcsr_row_ptr(safe_size); device_vector dcsr_col_ind(safe_size); device_vector dcsr_val(safe_size); device_vector dcsc_row_ind(safe_size); device_vector dcsc_col_ptr(safe_size); device_vector dcsc_val(safe_size); device_vector dbuffer(safe_size); if(!dcsr_row_ptr || !dcsr_col_ind || !dcsr_val || !dcsc_row_ind || !dcsc_col_ptr || !dcsc_val || !dbuffer) { CHECK_HIP_ERROR(hipErrorOutOfMemory); return; } size_t buffer_size; EXPECT_ROCSPARSE_STATUS( rocsparse_csr2csc_buffer_size( handle, M, N, safe_size, dcsr_row_ptr, dcsr_col_ind, action, &buffer_size), (M < 0 || N < 0) ? rocsparse_status_invalid_size : rocsparse_status_success); EXPECT_ROCSPARSE_STATUS(rocsparse_csr2csc(handle, M, N, safe_size, dcsr_val, dcsr_row_ptr, dcsr_col_ind, dcsc_val, dcsc_row_ind, dcsc_col_ptr, action, base, dbuffer), (M < 0 || N < 0) ? rocsparse_status_invalid_size : rocsparse_status_success); return; } // Allocate host memory for CSR matrix host_vector hcsr_row_ptr; host_vector hcsr_col_ind; host_vector hcsr_val; rocsparse_seedrand(); // Sample matrix rocsparse_int nnz; rocsparse_init_csr_matrix(hcsr_row_ptr, hcsr_col_ind, hcsr_val, M, N, K, dim_x, dim_y, dim_z, nnz, base, mat, filename.c_str(), false, full_rank); // Allocate host memory for CSC matrix host_vector hcsc_row_ind(nnz); host_vector hcsc_col_ptr(N + 1); host_vector hcsc_val(nnz); host_vector hcsc_row_ind_gold; host_vector hcsc_col_ptr_gold; host_vector hcsc_val_gold; // Allocate device memory device_vector dcsr_row_ptr(M + 1); device_vector dcsr_col_ind(nnz); device_vector dcsr_val(nnz); device_vector dcsc_row_ind(nnz); device_vector dcsc_col_ptr(N + 1); device_vector dcsc_val(nnz); if(!dcsr_row_ptr || !dcsr_col_ind || !dcsr_val || !dcsc_row_ind || !dcsc_col_ptr || !dcsc_val) { CHECK_HIP_ERROR(hipErrorOutOfMemory); return; } // Copy data from CPU to device CHECK_HIP_ERROR(hipMemcpy( dcsr_row_ptr, hcsr_row_ptr, sizeof(rocsparse_int) * (M + 1), hipMemcpyHostToDevice)); CHECK_HIP_ERROR( hipMemcpy(dcsr_col_ind, hcsr_col_ind, sizeof(rocsparse_int) * nnz, hipMemcpyHostToDevice)); CHECK_HIP_ERROR(hipMemcpy(dcsr_val, hcsr_val, sizeof(T) * nnz, hipMemcpyHostToDevice)); // Obtain required buffer size size_t buffer_size; CHECK_ROCSPARSE_ERROR(rocsparse_csr2csc_buffer_size( handle, M, N, nnz, dcsr_row_ptr, dcsr_col_ind, action, &buffer_size)); void* dbuffer; CHECK_HIP_ERROR(hipMalloc(&dbuffer, buffer_size)); if(arg.unit_check) { CHECK_ROCSPARSE_ERROR(rocsparse_csr2csc(handle, M, N, nnz, dcsr_val, dcsr_row_ptr, dcsr_col_ind, dcsc_val, dcsc_row_ind, dcsc_col_ptr, action, base, dbuffer)); // Copy output to host CHECK_HIP_ERROR(hipMemcpy( hcsc_row_ind, dcsc_row_ind, sizeof(rocsparse_int) * nnz, hipMemcpyDeviceToHost)); CHECK_HIP_ERROR(hipMemcpy( hcsc_col_ptr, dcsc_col_ptr, sizeof(rocsparse_int) * (N + 1), hipMemcpyDeviceToHost)); CHECK_HIP_ERROR(hipMemcpy(hcsc_val, dcsc_val, sizeof(T) * nnz, hipMemcpyDeviceToHost)); // CPU csr2csc host_csr_to_csc(M, N, nnz, hcsr_row_ptr, hcsr_col_ind, hcsr_val, hcsc_row_ind_gold, hcsc_col_ptr_gold, hcsc_val_gold, action, base); unit_check_general(1, nnz, 1, hcsc_row_ind_gold, hcsc_row_ind); unit_check_general(1, N + 1, 1, hcsc_col_ptr_gold, hcsc_col_ptr); if(action == rocsparse_action_numeric) { unit_check_general(1, nnz, 1, hcsc_val_gold, hcsc_val); } } if(arg.timing) { int number_cold_calls = 2; int number_hot_calls = arg.iters; // Warm up for(int iter = 0; iter < number_cold_calls; ++iter) { CHECK_ROCSPARSE_ERROR(rocsparse_csr2csc(handle, M, N, nnz, dcsr_val, dcsr_row_ptr, dcsr_col_ind, dcsc_val, dcsc_row_ind, dcsc_col_ptr, action, base, dbuffer)); } double gpu_time_used = get_time_us(); // Performance run for(int iter = 0; iter < number_hot_calls; ++iter) { CHECK_ROCSPARSE_ERROR(rocsparse_csr2csc(handle, M, N, nnz, dcsr_val, dcsr_row_ptr, dcsr_col_ind, dcsc_val, dcsc_row_ind, dcsc_col_ptr, action, base, dbuffer)); } gpu_time_used = (get_time_us() - gpu_time_used) / number_hot_calls; double gpu_gbyte = csr2csc_gbyte_count(M, N, nnz, action) / gpu_time_used * 1e6; std::cout.precision(2); std::cout.setf(std::ios::fixed); std::cout.setf(std::ios::left); std::cout << std::setw(12) << "M" << std::setw(12) << "N" << std::setw(12) << "nnz" << std::setw(12) << "action" << std::setw(12) << "GB/s" << std::setw(12) << "msec" << std::setw(12) << "iter" << std::setw(12) << "verified" << std::endl; std::cout << std::setw(12) << M << std::setw(12) << N << std::setw(12) << nnz << std::setw(12) << rocsparse_action2string(action) << std::setw(12) << gpu_gbyte << std::setw(12) << gpu_time_used / 1e3 << std::setw(12) << number_hot_calls << std::setw(12) << (arg.unit_check ? "yes" : "no") << std::endl; } // Free buffer CHECK_HIP_ERROR(hipFree(dbuffer)); } #endif // TESTING_CSR2CSC_HPP