This commit is contained in:
Hendrik Groove 2024-10-21 00:26:25 +02:00
parent 0d600b4535
commit 86fcbaf0e5

View File

@ -987,26 +987,6 @@ auto Reduce(Policy policy, InputIt first, InputIt second, Init init, Func reduce
using Ty = std::remove_cv_t<Init>;
Ty aggregate = init;
// Get the stream from the policy
hipStream_t stream = nullptr;
try {
stream = policy.stream();
std::cerr << "HIP stream from policy: " << static_cast<void*>(stream) << std::endl;
} catch (const std::exception& e) {
std::cerr << "Unable to get stream from policy: " << e.what() << std::endl;
std::cerr << "Using default stream" << std::endl;
}
// Check stream validity
if (stream != nullptr) {
hipError_t stream_err = hipStreamQuery(stream);
if (stream_err != hipSuccess && stream_err != hipErrorNotReady) {
std::cerr << "Invalid stream: " << hipGetErrorString(stream_err) << std::endl;
} else {
std::cerr << "Stream is valid" << std::endl;
}
}
for (size_t offset = 0; offset < size; offset += kLimit) {
auto begin_it = first + offset;
auto end_it = first + std::min(offset + kLimit, size);