Skip to content

Commit 357377e

Browse files
author
Sai Charan
committed
fix compile rrors in partitioner_iteration
1 parent be8f1fd commit 357377e

3 files changed

Lines changed: 16 additions & 6 deletions

File tree

libs/core/algorithms/include/hpx/parallel/util/detail/partitioner_iteration.hpp

Lines changed: 12 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -44,17 +44,18 @@ namespace hpx::parallel::util::detail {
4444
requires(is_tuple_like_v<T>)
4545
HPX_HOST_DEVICE HPX_FORCEINLINE constexpr Result operator()(T&& t)
4646
{
47-
using embedded_index_pack_type =
48-
hpx::util::make_index_pack<hpx::tuple_size<std::decay_t<T>>::value>;
47+
using embedded_index_pack_type = hpx::util::make_index_pack<
48+
hpx::tuple_size<std::decay_t<T>>::value>;
4949

5050
// NOLINTBEGIN(bugprone-use-after-move)
5151
if constexpr (std::is_invocable_v<F, embedded_index_pack_type, T&&>)
5252
{
53-
return HPX_INVOKE_R(Result, f_, embedded_index_pack_type{}, HPX_FORWARD(T, t));
53+
return HPX_INVOKE_R(
54+
Result, f_, embedded_index_pack_type{}, HPX_FORWARD(T, t));
5455
}
5556
else
5657
{
57-
return (*this)(embedded_index_pack_type{}, HPX_FORWARD(T, t));
58+
return (*this)(embedded_index_pack_type{}, t);
5859
}
5960
// NOLINTEND(bugprone-use-after-move)
6061
}
@@ -74,6 +75,13 @@ namespace hpx::parallel::util::detail {
7475
return HPX_INVOKE_R(Result, f_, hpx::get<Is>(t)...);
7576
}
7677

78+
template <std::size_t... Is, typename... Ts>
79+
HPX_HOST_DEVICE HPX_FORCEINLINE constexpr Result operator()(
80+
hpx::util::index_pack<Is...>, hpx::tuple<Ts...> const& t)
81+
{
82+
return HPX_INVOKE_R(Result, f_, hpx::get<Is>(t)...);
83+
}
84+
7785
template <std::size_t... Is, typename... Ts>
7886
HPX_HOST_DEVICE HPX_FORCEINLINE constexpr Result operator()(
7987
hpx::util::index_pack<Is...>, hpx::tuple<Ts...>&& t)

libs/core/algorithms/tests/unit/container_algorithms/foreach_range.cpp

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,8 @@ void test_for_each()
3939
test_for_each_sender_bulk(hpx::launch::sync, seq(task), IteratorTag());
4040
test_for_each_sender_bulk(hpx::launch::async, par(task), IteratorTag());
4141
test_for_each_sender_bulk(hpx::launch::sync, unseq(task), IteratorTag());
42-
test_for_each_sender_bulk(hpx::launch::async, par_unseq(task), IteratorTag());
42+
test_for_each_sender_bulk(
43+
hpx::launch::async, par_unseq(task), IteratorTag());
4344
}
4445

4546
void for_each_test()

libs/core/executors/include/hpx/executors/thread_pool_scheduler.hpp

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -103,7 +103,8 @@ namespace hpx::execution::experimental {
103103
auto&& [tag, data, child] = sndr;
104104
auto&& [pol, shape, f] = data;
105105

106-
auto iota_shape = hpx::util::counting_shape(decltype(shape){0}, shape);
106+
auto iota_shape =
107+
hpx::util::counting_shape(decltype(shape){0}, shape);
107108

108109
constexpr bool is_chunked =
109110
!hpx::execution::experimental::stdexec_internal::

0 commit comments

Comments
 (0)