Skip to content

Commit

Permalink
Put deprecation markings around braced clauses
Browse files Browse the repository at this point in the history
  • Loading branch information
ajpowelsnl committed Jan 30, 2024
1 parent 1f52f07 commit 5d85927
Showing 1 changed file with 12 additions and 12 deletions.
24 changes: 12 additions & 12 deletions core/src/HPX/Kokkos_HPX.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -1290,17 +1290,17 @@ class ParallelScan<FunctorType, Kokkos::RangePolicy<Traits...>,
const WorkRange range(m_policy, t, num_worker_threads);
execute_chunk(range.begin(), range.end(), update_sum, false);

#ifdef KOKKOS_ENABLE_DEPRECATED_CODE_4
{
// Since arrive_and_wait may yield and resume on another worker thread we
// set in_parallel = false on the current thread before suspending and set
// it again to true when we resume.
#ifdef KOKKOS_ENABLE_DEPRECATED_CODE_4
Kokkos::Experimental::HPX::impl_not_in_parallel_scope p;
barrier.arrive_and_wait();
}
#else
barrier.arrive_and_wait();
barrier.arrive_and_wait();
#endif
}

if (t == 0) {
final_reducer.init(reinterpret_cast<pointer_type>(
Expand All @@ -1322,17 +1322,17 @@ class ParallelScan<FunctorType, Kokkos::RangePolicy<Traits...>,
}
}

#ifdef KOKKOS_ENABLE_DEPRECATED_CODE_4
{
// Since arrive_and_wait may yield and resume on another worker thread we
// set in_parallel = false on the current thread before suspending and set
// it again to true when we resume.
#ifdef KOKKOS_ENABLE_DEPRECATED_CODE_4
Kokkos::Experimental::HPX::impl_not_in_parallel_scope p;
barrier.arrive_and_wait();
}
#else
barrier.arrive_and_wait();
barrier.arrive_and_wait();
#endif
}

reference_type update_base =
Analysis::Reducer::reference(reinterpret_cast<pointer_type>(
Expand Down Expand Up @@ -1413,17 +1413,17 @@ class ParallelScanWithTotal<FunctorType, Kokkos::RangePolicy<Traits...>,
const WorkRange range(m_policy, t, num_worker_threads);
execute_chunk(range.begin(), range.end(), update_sum, false);

#ifdef KOKKOS_ENABLE_DEPRECATED_CODE_4
{
// Since arrive_and_wait may yield and resume on another worker thread we
// set in_parallel = false on the current thread before suspending and set
// it again to true when we resume.
#ifdef KOKKOS_ENABLE_DEPRECATED_CODE_4
Kokkos::Experimental::HPX::impl_not_in_parallel_scope p;
barrier.arrive_and_wait();
}
#else
barrier.arrive_and_wait();
barrier.arrive_and_wait();
#endif
}

if (t == 0) {
final_reducer.init(reinterpret_cast<pointer_type>(
Expand All @@ -1445,17 +1445,17 @@ class ParallelScanWithTotal<FunctorType, Kokkos::RangePolicy<Traits...>,
}
}

#ifdef KOKKOS_ENABLE_DEPRECATED_CODE_4
{
// Since arrive_and_wait may yield and resume on another worker thread we
// set in_parallel = false on the current thread before suspending and set
// it again to true when we resume.
#ifdef KOKKOS_ENABLE_DEPRECATED_CODE_4
Kokkos::Experimental::HPX::impl_not_in_parallel_scope p;
barrier.arrive_and_wait();
}
#else
barrier.arrive_and_wait();
barrier.arrive_and_wait();
#endif
}

reference_type update_base =
Analysis::Reducer::reference(reinterpret_cast<pointer_type>(
Expand Down

0 comments on commit 5d85927

Please sign in to comment.