diff options
Diffstat (limited to 'storage/federatedx/federatedx_txn.cc')
| -rw-r--r-- | storage/federatedx/federatedx_txn.cc | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/storage/federatedx/federatedx_txn.cc b/storage/federatedx/federatedx_txn.cc index 84c7cd50e8d..5049b1ff79f 100644 --- a/storage/federatedx/federatedx_txn.cc +++ b/storage/federatedx/federatedx_txn.cc @@ -111,7 +111,7 @@ int federatedx_txn::acquire(FEDERATEDX_SHARE *share, bool readonly, if (!io) { /* check to see if there are any unowned IO connections */ - pthread_mutex_lock(&server->mutex); + mysql_mutex_lock(&server->mutex); if ((io= server->idle_list)) { server->idle_list= io->idle_next; @@ -123,7 +123,7 @@ int federatedx_txn::acquire(FEDERATEDX_SHARE *share, bool readonly, io->txn_next= txn_list; txn_list= io; - pthread_mutex_unlock(&server->mutex); + mysql_mutex_unlock(&server->mutex); } if (io->busy) @@ -188,10 +188,10 @@ void federatedx_txn::release_scan() /* reset some values */ io->readonly= TRUE; - pthread_mutex_lock(&server->mutex); + mysql_mutex_lock(&server->mutex); io->idle_next= server->idle_list; server->idle_list= io; - pthread_mutex_unlock(&server->mutex); + mysql_mutex_unlock(&server->mutex); returned++; } } |