Commit e9f26097 authored by Marko Mäkelä's avatar Marko Mäkelä

Merge 10.2 into 10.3

parents 9be99dac fe95cb2e
...@@ -4256,15 +4256,12 @@ ibuf_restore_pos( ...@@ -4256,15 +4256,12 @@ ibuf_restore_pos(
return(TRUE); return(TRUE);
} }
if (fil_space_get_flags(space) == ULINT_UNDEFINED) { if (fil_space_t* s = fil_space_acquire_silent(space)) {
/* The tablespace has been dropped. It is possible ib::error() << "ibuf cursor restoration fails!"
that another thread has deleted the insert buffer
entry. Do not complain. */
ibuf_btr_pcur_commit_specify_mtr(pcur, mtr);
} else {
ib::error() << "ibuf cursor restoration fails!."
" ibuf record inserted to page " " ibuf record inserted to page "
<< space << ":" << page_no; << space << ":" << page_no
<< " in file " << s->chain.start->name;
s->release();
ib::error() << BUG_REPORT_MSG; ib::error() << BUG_REPORT_MSG;
...@@ -4274,10 +4271,9 @@ ibuf_restore_pos( ...@@ -4274,10 +4271,9 @@ ibuf_restore_pos(
rec_print_old(stderr, rec_print_old(stderr,
page_rec_get_next(btr_pcur_get_rec(pcur))); page_rec_get_next(btr_pcur_get_rec(pcur)));
ib::fatal() << "Failed to restore ibuf position.";
} }
ibuf_btr_pcur_commit_specify_mtr(pcur, mtr);
return(FALSE); return(FALSE);
} }
......
...@@ -2366,10 +2366,6 @@ DECLARE_THREAD(srv_master_thread)( ...@@ -2366,10 +2366,6 @@ DECLARE_THREAD(srv_master_thread)(
ut_a(slot == srv_sys.sys_threads); ut_a(slot == srv_sys.sys_threads);
loop: loop:
if (srv_force_recovery >= SRV_FORCE_NO_BACKGROUND) {
goto suspend_thread;
}
while (srv_shutdown_state == SRV_SHUTDOWN_NONE) { while (srv_shutdown_state == SRV_SHUTDOWN_NONE) {
srv_master_sleep(); srv_master_sleep();
...@@ -2384,7 +2380,6 @@ DECLARE_THREAD(srv_master_thread)( ...@@ -2384,7 +2380,6 @@ DECLARE_THREAD(srv_master_thread)(
} }
} }
suspend_thread:
switch (srv_shutdown_state) { switch (srv_shutdown_state) {
case SRV_SHUTDOWN_NONE: case SRV_SHUTDOWN_NONE:
break; break;
......
...@@ -2464,11 +2464,14 @@ dberr_t srv_start(bool create_new_db) ...@@ -2464,11 +2464,14 @@ dberr_t srv_start(bool create_new_db)
trx_temp_rseg_create(); trx_temp_rseg_create();
thread_handles[1 + SRV_MAX_N_IO_THREADS] = os_thread_create( if (srv_force_recovery < SRV_FORCE_NO_BACKGROUND) {
srv_master_thread, thread_handles[1 + SRV_MAX_N_IO_THREADS]
NULL, thread_ids + (1 + SRV_MAX_N_IO_THREADS)); = os_thread_create(srv_master_thread, NULL,
thread_started[1 + SRV_MAX_N_IO_THREADS] = true; (1 + SRV_MAX_N_IO_THREADS)
srv_start_state_set(SRV_START_STATE_MASTER); + thread_ids);
thread_started[1 + SRV_MAX_N_IO_THREADS] = true;
srv_start_state_set(SRV_START_STATE_MASTER);
}
} }
if (!srv_read_only_mode && srv_operation == SRV_OPERATION_NORMAL if (!srv_read_only_mode && srv_operation == SRV_OPERATION_NORMAL
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment