summaryrefslogtreecommitdiff
path: root/storage/innobase/row/row0sel.cc
diff options
context:
space:
mode:
Diffstat (limited to 'storage/innobase/row/row0sel.cc')
-rw-r--r--storage/innobase/row/row0sel.cc21
1 files changed, 6 insertions, 15 deletions
diff --git a/storage/innobase/row/row0sel.cc b/storage/innobase/row/row0sel.cc
index 89085a17bca..419a2e628aa 100644
--- a/storage/innobase/row/row0sel.cc
+++ b/storage/innobase/row/row0sel.cc
@@ -1098,13 +1098,13 @@ re_scan:
thr->lock_state = QUE_THR_LOCK_NOLOCK;
mtr->start();
- mutex_enter(&match->rtr_match_mutex);
+ mysql_mutex_lock(&match->rtr_match_mutex);
if (!match->valid && match->matched_recs->empty()) {
- mutex_exit(&match->rtr_match_mutex);
+ mysql_mutex_unlock(&match->rtr_match_mutex);
err = DB_RECORD_NOT_FOUND;
goto func_end;
}
- mutex_exit(&match->rtr_match_mutex);
+ mysql_mutex_unlock(&match->rtr_match_mutex);
/* MDEV-14059 FIXME: why re-latch the block?
pcur is already positioned on it! */
@@ -2164,7 +2164,6 @@ stop_for_a_while:
btr_pcur_store_position(&(plan->pcur), &mtr);
mtr.commit();
- ut_ad(!sync_check_iterate(sync_check()));
err = DB_SUCCESS;
goto func_exit;
@@ -2181,7 +2180,6 @@ commit_mtr_for_a_while:
mtr.commit();
mtr_has_extra_clust_latch = FALSE;
- ut_ad(!sync_check_iterate(dict_sync_check()));
goto table_loop;
@@ -2196,8 +2194,6 @@ lock_wait_or_error:
mtr.commit();
func_exit:
- ut_ad(!sync_check_iterate(dict_sync_check()));
-
if (heap != NULL) {
mem_heap_free(heap);
}
@@ -3292,16 +3288,16 @@ Row_sel_get_clust_rec_for_mysql::operator()(
|| rec != btr_pcur_get_rec(prebuilt->pcur))) {
#ifdef UNIV_DEBUG
rtr_info_t* rtr_info = btr_cur->rtr_info;
- mutex_enter(&rtr_info->matches->rtr_match_mutex);
+ mysql_mutex_lock(&rtr_info->matches->rtr_match_mutex);
/* The page could be deallocated (by rollback etc.) */
if (!rtr_info->matches->valid) {
- mutex_exit(&rtr_info->matches->rtr_match_mutex);
+ mysql_mutex_unlock(&rtr_info->matches->rtr_match_mutex);
clust_rec = NULL;
err = DB_SUCCESS;
goto func_exit;
}
- mutex_exit(&rtr_info->matches->rtr_match_mutex);
+ mysql_mutex_unlock(&rtr_info->matches->rtr_match_mutex);
if (rec_get_deleted_flag(rec,
dict_table_is_comp(sec_index->table))
@@ -4263,8 +4259,6 @@ row_search_mvcc(
DBUG_RETURN(DB_END_OF_INDEX);
}
- ut_ad(!sync_check_iterate(sync_check()));
-
if (!prebuilt->table->space) {
DBUG_RETURN(DB_TABLESPACE_DELETED);
} else if (!prebuilt->table->is_readable()) {
@@ -4496,7 +4490,6 @@ aborted:
/* NOTE that we do NOT store the cursor
position */
trx->op_info = "";
- ut_ad(!sync_check_iterate(sync_check()));
ut_ad(!did_semi_consistent_read);
if (UNIV_LIKELY_NULL(heap)) {
mem_heap_free(heap);
@@ -5786,8 +5779,6 @@ func_exit:
}
}
- ut_ad(!sync_check_iterate(sync_check()));
-
DEBUG_SYNC_C("innodb_row_search_for_mysql_exit");
DBUG_RETURN(err);