For packaged continuations, check to see if the function is annotated

before creating the thread_description.
STEllAR-GROUP · Dec 3, 2019 · 37de97f · msimberg · Dec 3, 2019 · 37de97f
1 parent a965665
commit 37de97f
Showing 1 changed file with 10 additions and 2 deletions.
diff --git a/hpx/lcos/local/packaged_continuation.hpp b/hpx/lcos/local/packaged_continuation.hpp
@@ -376,8 +376,12 @@ namespace hpx { namespace lcos { namespace detail
             }
 
             hpx::intrusive_ptr<continuation> this_(this);
+            const char * annotation =
+                traits::get_function_annotation<typename hpx::util::decay<F>::type>::call(f_);
             hpx::util::thread_description desc(
-                "hpx::parallel::execution::parallel_executor::post");
+                annotation == nullptr ?
+                "hpx::parallel::execution::parallel_executor::post" :
+                annotation);
 
             parallel::execution::detail::post_policy_dispatch<
                     hpx::launch::async_policy
@@ -422,8 +426,12 @@ namespace hpx { namespace lcos { namespace detail
             }
 
             hpx::intrusive_ptr<continuation> this_(this);
+            const char * annotation =
+                traits::get_function_annotation<typename hpx::util::decay<F>::type>::call(f_);
             hpx::util::thread_description desc(
-                "hpx::parallel::execution::parallel_executor::post");
+                annotation == nullptr ?
+                "hpx::parallel::execution::parallel_executor::post" :
+                annotation);
 
             parallel::execution::detail::post_policy_dispatch<
                     hpx::launch::async_policy