kate/BadFish
1
0
Fork 0
mirror of https://github.com/sockspls/badfish synced 2025-04-30 08:43:09 +00:00
Code Issues Releases Wiki Activity

Fix obey the "maxThreadsPerSplitPoint" setting

Browse source 
Spotted by Joona.

Signed-off-by: Marco Costalba <mcostalba@gmail.com>
This commit is contained in:
Marco Costalba 2011-08-07 15:15:19 +01:00
parent 5b35c149e8
commit 68583f4d48
1 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
src/thread.cpp
View file

@ -281,26 +281,26 @@ Value ThreadsManager::split(Position& pos, SearchStack* ss, Value alpha, Value b
// If we are here it means we are not available // If we are here it means we are not available
assert(masterThread.state == Thread::SEARCHING); assert(masterThread.state == Thread::SEARCHING);
int booked = 0; int workersCnt = 1; // At least the master is included
// Try to allocate available threads setting state to Thread::BOOKED, this // Try to allocate available threads setting state to Thread::BOOKED, this
// must be done under lock protection to avoid concurrent allocation of // must be done under lock protection to avoid concurrent allocation of
// the same slave by another master. // the same slave by another master.
lock_grab(&threadsLock); lock_grab(&threadsLock);
for (i = 0; !Fake && i < activeThreads && booked < maxThreadsPerSplitPoint; i++) for (i = 0; !Fake && i < activeThreads && workersCnt < maxThreadsPerSplitPoint; i++)
if (i != master && threads[i].is_available_to(master)) if (i != master && threads[i].is_available_to(master))
{ {
threads[i].state = Thread::BOOKED; threads[i].state = Thread::BOOKED;
threads[i].splitPoint = &splitPoint; threads[i].splitPoint = &splitPoint;
splitPoint.is_slave[i] = true; splitPoint.is_slave[i] = true;
booked++; workersCnt++;
} }
lock_release(&threadsLock); lock_release(&threadsLock);
// We failed to allocate even one slave, return // We failed to allocate even one slave, return
if (!Fake && !booked) if (!Fake && workersCnt == 1)
return bestValue; return bestValue;
masterThread.activeSplitPoints++; masterThread.activeSplitPoints++;