Active Reparenting

[stockfish] / src / thread.cpp

diff --git a/src/thread.cpp b/src/thread.cpp
index cb3f8223aacf26a93199c7c2ed6cef1b8a02916c..6d07ec35f3e29d1e83295c7417481dac7c9ffead 100644 (file)
--- a/src/thread.cpp
+++ b/src/thread.cpp
@@ -319,6 +319,7 @@ Value ThreadsManager::split(Position& pos, Stack* ss, Value alpha, Value beta,
   sp->master = master;
   sp->cutoff = false;
   sp->slavesMask = 1ULL << master->idx;
   sp->master = master;
   sp->cutoff = false;
   sp->slavesMask = 1ULL << master->idx;

+  sp->allSlavesMask = 1ULL << master->idx;

   sp->depth = depth;
   sp->bestMove = *bestMove;
   sp->threatMove = threatMove;
   sp->depth = depth;
   sp->bestMove = *bestMove;
   sp->threatMove = threatMove;


@@ -347,6 +348,7 @@ Value ThreadsManager::split(Position& pos, Stack* ss, Value alpha, Value beta,
       if (threads[i]->is_available_to(master))
       {
           sp->slavesMask |= 1ULL << i;
       if (threads[i]->is_available_to(master))
       {
           sp->slavesMask |= 1ULL << i;

+          sp->allSlavesMask |= 1ULL << i;

           threads[i]->curSplitPoint = sp;
           threads[i]->is_searching = true; // Slave leaves idle_loop()
 
           threads[i]->curSplitPoint = sp;
           threads[i]->is_searching = true; // Slave leaves idle_loop()
 


@@ -354,7 +356,10 @@ Value ThreadsManager::split(Position& pos, Stack* ss, Value alpha, Value beta,
               threads[i]->wake_up();
 
           if (++slavesCnt + 1 >= maxThreadsPerSplitPoint) // Master is always included
               threads[i]->wake_up();
 
           if (++slavesCnt + 1 >= maxThreadsPerSplitPoint) // Master is always included

+          {
+              sp->allSlavesMask = 0; // Disable reparenting to this split point

               break;
               break;

+          }

       }
 
   lock_release(splitLock);
       }
 
   lock_release(splitLock);