diff options
Diffstat (limited to 'storage/innobase/trx/trx0i_s.cc')
-rw-r--r-- | storage/innobase/trx/trx0i_s.cc | 29 |
1 files changed, 9 insertions, 20 deletions
diff --git a/storage/innobase/trx/trx0i_s.cc b/storage/innobase/trx/trx0i_s.cc index 2736dbd285f..82477399552 100644 --- a/storage/innobase/trx/trx0i_s.cc +++ b/storage/innobase/trx/trx0i_s.cc @@ -394,13 +394,11 @@ i_s_locks_row_validate( if (!row->lock_index) { /* table lock */ ut_ad(!row->lock_data); - ut_ad(!row->lock_space); - ut_ad(!row->lock_page); + ut_ad(row->lock_page == page_id_t(0, 0)); ut_ad(!row->lock_rec); } else { /* record lock */ /* row->lock_data == NULL if buf_page_try_get() == NULL */ - ut_ad(row->lock_page); } return(TRUE); @@ -631,9 +629,7 @@ fill_lock_data( mtr_start(&mtr); - block = buf_page_try_get(page_id_t(lock->un_member.rec_lock.space, - lock->un_member.rec_lock.page_no), - &mtr); + block = buf_page_try_get(lock->un_member.rec_lock.page_id, &mtr); if (block == NULL) { @@ -754,8 +750,7 @@ static bool fill_locks_row( return false; } - row->lock_space = lock->un_member.rec_lock.space; - row->lock_page = lock->un_member.rec_lock.page_no; + row->lock_page = lock->un_member.rec_lock.page_id; row->lock_rec = heap_no; if (!fill_lock_data(&row->lock_data, lock, heap_no, cache)) { @@ -766,8 +761,7 @@ static bool fill_locks_row( } else { row->lock_index = NULL; - row->lock_space = 0; - row->lock_page = 0; + row->lock_page = page_id_t(0, 0); row->lock_rec = 0; row->lock_data = NULL; @@ -831,13 +825,9 @@ fold_lock( switch (lock_get_type(lock)) { case LOCK_REC: ut_a(heap_no != 0xFFFF); - ret = ut_fold_ulint_pair((ulint) lock->trx->id, - lock->un_member.rec_lock.space); - - ret = ut_fold_ulint_pair(ret, - lock->un_member.rec_lock.page_no); - + lock->un_member.rec_lock.page_id. + fold()); ret = ut_fold_ulint_pair(ret, heap_no); break; @@ -880,8 +870,7 @@ locks_row_eq_lock( ut_a(heap_no != 0xFFFF); return(row->lock_trx_id == lock->trx->id - && row->lock_space == lock->un_member.rec_lock.space - && row->lock_page == lock->un_member.rec_lock.page_no + && row->lock_page == lock->un_member.rec_lock.page_id && row->lock_rec == heap_no); case LOCK_TABLE: @@ -1477,8 +1466,8 @@ trx_i_s_create_lock_id( res_len = snprintf(lock_id, lock_id_size, TRX_ID_FMT ":%u:%u:%u", - row->lock_trx_id, row->lock_space, - row->lock_page, row->lock_rec); + row->lock_trx_id, row->lock_page.space(), + row->lock_page.page_no(), row->lock_rec); } else { /* table lock */ res_len = snprintf(lock_id, lock_id_size, |