Skip to content

Commit 0732897

Browse files
committed
Fix nvexec sync_wait scheduler query
1 parent 0916515 commit 0732897

2 files changed

Lines changed: 12 additions & 1 deletion

File tree

include/nvexec/stream/sync_wait.cuh

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,7 @@ namespace nv::execution::_strm
3636
struct env
3737
{
3838
template <
39-
__one_of<get_start_scheduler_t, get_start_scheduler_t, get_delegation_scheduler_t> _Query>
39+
__one_of<get_scheduler_t, get_start_scheduler_t, get_delegation_scheduler_t> _Query>
4040
[[nodiscard]]
4141
constexpr auto query(_Query) const noexcept -> run_loop::scheduler
4242
{

test/nvexec/continues_on.cpp

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -32,4 +32,15 @@ namespace
3232

3333
STDEXEC::sync_wait(std::move(sndr));
3434
}
35+
36+
TEST_CASE("nvexec sync_wait provides a scheduler", "[cuda][stream][sync_wait]")
37+
{
38+
nvexec::stream_context ctx;
39+
40+
auto sndr = STDEXEC::get_scheduler() | STDEXEC::continues_on(ctx.get_scheduler());
41+
42+
auto result = STDEXEC::sync_wait(std::move(sndr));
43+
44+
REQUIRE(result.has_value());
45+
}
3546
} // namespace

0 commit comments

Comments
 (0)