diff options
Diffstat (limited to 'storage/innobase/fil/fil0fil.cc')
-rw-r--r-- | storage/innobase/fil/fil0fil.cc | 19 |
1 files changed, 6 insertions, 13 deletions
diff --git a/storage/innobase/fil/fil0fil.cc b/storage/innobase/fil/fil0fil.cc index db2a0b5f8d7..0007fde5f43 100644 --- a/storage/innobase/fil/fil0fil.cc +++ b/storage/innobase/fil/fil0fil.cc @@ -2650,7 +2650,7 @@ void fsp_flags_try_adjust(fil_space_t *space, uint32_t flags) if (buf_block_t* b = buf_page_get( page_id_t(space->id, 0), space->zip_size(), RW_X_LATCH, &mtr)) { - uint32_t f = fsp_header_get_flags(b->frame); + uint32_t f = fsp_header_get_flags(b->page.frame); if (fil_space_t::full_crc32(f)) { goto func_exit; } @@ -2668,7 +2668,7 @@ void fsp_flags_try_adjust(fil_space_t *space, uint32_t flags) mtr.set_named_space(space); mtr.write<4,mtr_t::FORCED>(*b, FSP_HEADER_OFFSET + FSP_SPACE_FLAGS - + b->frame, flags); + + b->page.frame, flags); } func_exit: mtr.commit(); @@ -2836,7 +2836,7 @@ fail: goto release_sync_write; } else { /* Queue the aio request */ - err = os_aio(IORequest(bpage, node, type.type), + err = os_aio(IORequest{bpage, type.slot, node, type.type}, buf, offset, len); } @@ -2892,7 +2892,7 @@ write_completed: files and never issue asynchronous reads of change buffer pages. */ const page_id_t id(request.bpage->id()); - if (dberr_t err= buf_page_read_complete(request.bpage, *request.node)) + if (dberr_t err= request.bpage->read_complete(*request.node)) { if (recv_recovery_is_on() && !srv_force_recovery) { @@ -3126,12 +3126,6 @@ fil_names_clear( bool do_write) { mtr_t mtr; - ulint mtr_checkpoint_size = RECV_SCAN_SIZE - 1; - - DBUG_EXECUTE_IF( - "increase_mtr_checkpoint_size", - mtr_checkpoint_size = 75 * 1024; - ); mysql_mutex_assert_owner(&log_sys.mutex); ut_ad(lsn); @@ -3140,9 +3134,8 @@ fil_names_clear( for (auto it = fil_system.named_spaces.begin(); it != fil_system.named_spaces.end(); ) { - if (mtr.get_log()->size() - + (3 + 5 + 1) + strlen(it->chain.start->name) - >= mtr_checkpoint_size) { + if (mtr.get_log()->size() + strlen(it->chain.start->name) + >= RECV_SCAN_SIZE - (3 + 5)) { /* Prevent log parse buffer overflow */ mtr.commit_files(); mtr.start(); |