Fixing thread number selection

The check if a core is disabled needs to honor the thread offset
STEllAR-GROUP · Sep 7, 2017 · 4cc9e6f · 4cc9e6f
1 parent 0c4b3b5
commit 4cc9e6f
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/hpx/runtime/threads/policies/local_priority_queue_scheduler.hpp b/hpx/runtime/threads/policies/local_priority_queue_scheduler.hpp
@@ -471,7 +471,7 @@ namespace hpx { namespace threads { namespace policies
             while (true)
             {
                 auto const& rp = resource::get_partitioner();
-                auto mask = rp.get_pu_mask(num_thread);
+                auto mask = rp.get_pu_mask(num_thread + parent_pool_->get_thread_offset());
                 if(bit_and(mask, parent_pool_->get_used_processing_units()))
                     break;
                 else

diff --git a/hpx/runtime/threads/policies/local_queue_scheduler.hpp b/hpx/runtime/threads/policies/local_queue_scheduler.hpp
@@ -315,7 +315,7 @@ namespace hpx { namespace threads { namespace policies
             while (true)
             {
                 auto const& rp = resource::get_partitioner();
-                auto mask = rp.get_pu_mask(num_thread);
+                auto mask = rp.get_pu_mask(num_thread + parent_pool_->get_thread_offset());
                 if(bit_and(mask, parent_pool_->get_used_processing_units()))
                     break;
                 else