From 3e13addfac81f3d1ead6cb612cf52ea120178539 Mon Sep 17 00:00:00 2001 From: Sai Charan Arvapally Date: Fri, 18 Jul 2025 11:55:10 -0600 Subject: [PATCH 01/74] updated algorithm_bulk test file --- .../include/hpx/execution/algorithms/bulk.hpp | 539 +++++++++--------- .../execution/tests/unit/algorithm_bulk.cpp | 16 + .../hpx/execution_base/stdexec_forward.hpp | 6 +- 3 files changed, 289 insertions(+), 272 deletions(-) diff --git a/libs/core/execution/include/hpx/execution/algorithms/bulk.hpp b/libs/core/execution/include/hpx/execution/algorithms/bulk.hpp index 9d67b8c16d08..12b87e777987 100644 --- a/libs/core/execution/include/hpx/execution/algorithms/bulk.hpp +++ b/libs/core/execution/include/hpx/execution/algorithms/bulk.hpp @@ -11,300 +11,301 @@ #if defined(HPX_HAVE_STDEXEC) #include -#endif +#else -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include +// #include +// #include +// #include +// #include +// #include +// #include +// #include +// #include +// #include +// #include +// #include +// #include +// #include +// #include -#include -#include -#include -#include +// #include +// #include +// #include +// #include -namespace hpx::execution::experimental { +// namespace hpx::execution::experimental { - /////////////////////////////////////////////////////////////////////////// - namespace detail { +// /////////////////////////////////////////////////////////////////////////// +// namespace detail { - template - struct bulk_sender - { - HPX_NO_UNIQUE_ADDRESS std::decay_t sender; - HPX_NO_UNIQUE_ADDRESS std::decay_t shape; - HPX_NO_UNIQUE_ADDRESS std::decay_t f; +// template +// struct bulk_sender +// { +// HPX_NO_UNIQUE_ADDRESS std::decay_t sender; +// HPX_NO_UNIQUE_ADDRESS std::decay_t shape; +// HPX_NO_UNIQUE_ADDRESS std::decay_t f; -#if defined(HPX_HAVE_STDEXEC) - using sender_concept = hpx::execution::experimental::sender_t; +// #if defined(HPX_HAVE_STDEXEC) +// using sender_concept = hpx::execution::experimental::sender_t; - template - using default_set_value = - hpx::execution::experimental::completion_signatures< - hpx::execution::experimental::set_value_t(Args...)>; +// template +// using default_set_value = +// hpx::execution::experimental::completion_signatures< +// hpx::execution::experimental::set_value_t(Args...)>; - template - using default_set_error = - hpx::execution::experimental::completion_signatures< - hpx::execution::experimental::set_error_t(Arg)>; +// template +// using default_set_error = +// hpx::execution::experimental::completion_signatures< +// hpx::execution::experimental::set_error_t(Arg)>; - using disable_set_stopped = - hpx::execution::experimental::completion_signatures<>; +// using disable_set_stopped = +// hpx::execution::experimental::completion_signatures<>; - // clang-format off - template - friend auto tag_invoke(get_completion_signatures_t, - bulk_sender const&, Env) noexcept -> hpx::execution:: - experimental::transform_completion_signatures_of, - default_set_value, default_set_error, disable_set_stopped>; - // clang-format on +// // clang-format off +// template +// friend auto tag_invoke(get_completion_signatures_t, +// bulk_sender const&, Env) noexcept -> hpx::execution:: +// experimental::transform_completion_signatures_of, +// default_set_value, default_set_error, disable_set_stopped>; +// // clang-format on - friend constexpr auto tag_invoke( - hpx::execution::experimental::get_env_t, - bulk_sender const& s) noexcept - { - return hpx::execution::experimental::get_env(s.sender); - } -#else - using is_sender = void; +// friend constexpr auto tag_invoke( +// hpx::execution::experimental::get_env_t, +// bulk_sender const& s) noexcept +// { +// return hpx::execution::experimental::get_env(s.sender); +// } +// #else +// using is_sender = void; - template - struct generate_completion_signatures - { - template