database/mariadb
1
0
Fork 0
mirror of https://github.com/MariaDB/server.git synced 2025-08-07 00:04:31 +03:00
Code Activity

Merge MariaDB 10.0-base to 10.0.

Browse Source
This commit is contained in:
unknown
2014-02-10 15:12:17 +01:00
parent e8193eeb8d f3a6f86ec3
commit dd93ec5633
44 changed files with 1420 additions and 134 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
sql/rpl_parallel.cc
View File

@@ -765,6 +765,27 @@ rpl_parallel::wait_for_done()
}
bool
rpl_parallel::workers_idle()
{
struct rpl_parallel_entry *e;
uint32 i, max_i;
max_i= domain_hash.records;
for (i= 0; i < max_i; ++i)
{
bool active;
e= (struct rpl_parallel_entry *)my_hash_element(&domain_hash, i);
mysql_mutex_lock(&e->LOCK_parallel_entry);
active= e->current_sub_id > e->last_committed_sub_id;
mysql_mutex_unlock(&e->LOCK_parallel_entry);
if (active)
break;
}
return (i == max_i);
}
/*
do_event() is executed by the sql_driver_thd thread.
It's main purpose is to find a thread that can execute the query.