Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Add column sanitization checks in CUDF_TEST_EXPECT_COLUMN_* macros #14559

Merged
merged 5 commits into from
Dec 18, 2023
Merged

Add column sanitization checks in CUDF_TEST_EXPECT_COLUMN_* macros #14559

Changes from 2 commits
Commits
Show all changes
5 commits
Select commit Hold shift + click to select a range
3a70103
check has_nonempty_nulls in macros
SurajAralihalli Dec 2, 2023
7f83e83
update cu file
SurajAralihalli Dec 4, 2023
1f4bb46
reduce code duplication and improve readability
SurajAralihalli Dec 6, 2023
fe57348
Merge branch 'branch-24.02' into verify_column_sanity_cudf_tests
SurajAralihalli Dec 18, 2023
6a6fc86
remove UnsanitaryLists test
SurajAralihalli Dec 18, 2023
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
25 changes: 25 additions & 0 deletions cpp/tests/utilities/column_utilities.cu
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,7 @@

#include <cudf/column/column_view.hpp>
#include <cudf/copying.hpp>
#include <cudf/detail/copy.hpp>
#include <cudf/detail/get_value.cuh>
#include <cudf/detail/iterator.cuh>
#include <cudf/detail/utilities/vector_factories.hpp>
Expand Down Expand Up @@ -804,6 +805,12 @@ bool expect_column_properties_equal(column_view const& lhs,
column_view const& rhs,
debug_output_level verbosity)
{
if (cudf::detail::has_nonempty_nulls(lhs, cudf::get_default_stream())) {
throw std::invalid_argument("Unsanitized lhs column");
SurajAralihalli marked this conversation as resolved.
Show resolved Hide resolved
}
if (cudf::detail::has_nonempty_nulls(rhs, cudf::get_default_stream())) {
throw std::invalid_argument("Unsanitized rhs column");
}
auto lhs_indices = generate_all_row_indices(lhs.size());
auto rhs_indices = generate_all_row_indices(rhs.size());
return cudf::type_dispatcher(lhs.type(),
Expand All @@ -822,6 +829,12 @@ bool expect_column_properties_equivalent(column_view const& lhs,
column_view const& rhs,
debug_output_level verbosity)
{
if (cudf::detail::has_nonempty_nulls(lhs, cudf::get_default_stream())) {
throw std::invalid_argument("Unsanitized lhs column");
}
if (cudf::detail::has_nonempty_nulls(rhs, cudf::get_default_stream())) {
throw std::invalid_argument("Unsanitized rhs column");
}
SurajAralihalli marked this conversation as resolved.
Show resolved Hide resolved
auto lhs_indices = generate_all_row_indices(lhs.size());
auto rhs_indices = generate_all_row_indices(rhs.size());
return cudf::type_dispatcher(lhs.type(),
Expand All @@ -840,6 +853,12 @@ bool expect_columns_equal(cudf::column_view const& lhs,
cudf::column_view const& rhs,
debug_output_level verbosity)
{
if (cudf::detail::has_nonempty_nulls(lhs, cudf::get_default_stream())) {
throw std::invalid_argument("Unsanitized lhs column");
}
if (cudf::detail::has_nonempty_nulls(rhs, cudf::get_default_stream())) {
throw std::invalid_argument("Unsanitized rhs column");
}
auto lhs_indices = generate_all_row_indices(lhs.size());
auto rhs_indices = generate_all_row_indices(rhs.size());
return cudf::type_dispatcher(lhs.type(),
Expand All @@ -860,6 +879,12 @@ bool expect_columns_equivalent(cudf::column_view const& lhs,
debug_output_level verbosity,
size_type fp_ulps)
{
if (cudf::detail::has_nonempty_nulls(lhs, cudf::get_default_stream())) {
throw std::invalid_argument("Unsanitized lhs column");
}
if (cudf::detail::has_nonempty_nulls(rhs, cudf::get_default_stream())) {
throw std::invalid_argument("Unsanitized rhs column");
}
auto lhs_indices = generate_all_row_indices(lhs.size());
auto rhs_indices = generate_all_row_indices(rhs.size());
return cudf::type_dispatcher(lhs.type(),
Expand Down
Loading