Skip to content
Merged
Show file tree
Hide file tree
Changes from 2 commits
Commits
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
30 changes: 24 additions & 6 deletions dpnp/backend/extensions/statistics/sliding_window1d.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -574,9 +574,18 @@ void submit_sliding_window1d(const PaddedSpan<const T, SizeT> &a,
}

auto *const out_ptr = out.begin();
auto *const out_end = out.end();
results.store(&out_ptr[glid],
[out_end](auto &&ptr) { return ptr < out_end; });
// auto *const out_end = out.end();

auto y_start = glid;
auto y_stop =
std::min(y_start + WorkPI * results.size_x(), out.size());
int32_t i = 0;
for (uint32_t y = y_start; y < y_stop; y += results.size_x()) {
out_ptr[y] = results[i++];
}
// due to excessive optimizations this code results in memory
// corruption results.store(&out_ptr[glid],
// [out_end](auto &&ptr) { return ptr < out_end; });
});
}

Expand Down Expand Up @@ -635,9 +644,18 @@ void submit_sliding_window1d_small_kernel(const PaddedSpan<const T, SizeT> &a,
red);

auto *const out_ptr = out.begin();
auto *const out_end = out.end();
results.store(&out_ptr[glid],
[out_end](auto &&ptr) { return ptr < out_end; });
// auto *const out_end = out.end();

auto y_start = glid;
auto y_stop =
std::min(y_start + WorkPI * results.size_x(), out.size());
int32_t i = 0;
for (uint32_t y = y_start; y < y_stop; y += results.size_x()) {
out_ptr[y] = results[i++];
}
// due to excessive optimizations this code results in memory
// corruption results.store(&out_ptr[glid],
// [out_end](auto &&ptr) { return ptr < out_end; });
});
}

Expand Down
3 changes: 0 additions & 3 deletions dpnp/tests/test_usm_type.py
Original file line number Diff line number Diff line change
Expand Up @@ -800,9 +800,6 @@ def test_1in_1out(func, data, usm_type):
@pytest.mark.parametrize("usm_type_x", list_of_usm_types, ids=list_of_usm_types)
@pytest.mark.parametrize("usm_type_y", list_of_usm_types, ids=list_of_usm_types)
def test_2in_1out(func, data1, data2, usm_type_x, usm_type_y):
if func == "correlate" and is_win_platform():
pytest.skip("due to SAT-7693")

x = dp.array(data1, usm_type=usm_type_x)
y = dp.array(data2, usm_type=usm_type_y)
z = getattr(dp, func)(x, y)
Expand Down
Loading