hcq/MaxScale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Use Semaphore multi-wait

Browse Source 
The dcb_foreach_parallel now uses the correct method of the Semaphore
class.
This commit is contained in:
Markus Mäkelä
2017-04-25 15:05:24 +03:00
parent c3df805b22
commit 4cdb7bc49b
1 changed files with 1 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
server/core/dcb.cc
View File

@ -3106,13 +3106,7 @@ void dcb_foreach_parallel(bool(*func)(DCB *dcb, void *data), void **data)
{ {
Semaphore sem; Semaphore sem;
ParallelDcbTask task(func, data); ParallelDcbTask task(func, data);
size_t n = Worker::execute_on_all(&task, &sem); sem.wait_n(Worker::execute_on_all(&task, &sem));
// TODO: Use the multi-wait version of this function
for (size_t i = 0; i < n; i++)
{
sem.wait();
}
} }
int dcb_get_port(const DCB *dcb) int dcb_get_port(const DCB *dcb)