Commit 9017a05d authored by Marko Mäkelä's avatar Marko Mäkelä

Merge 10.0 into 10.1

parents 981534b1 d831e4c2
...@@ -179,7 +179,7 @@ UNIV_INTERN mysql_pfs_key_t recv_writer_mutex_key; ...@@ -179,7 +179,7 @@ UNIV_INTERN mysql_pfs_key_t recv_writer_mutex_key;
# endif /* UNIV_PFS_MUTEX */ # endif /* UNIV_PFS_MUTEX */
/** Flag indicating if recv_writer thread is active. */ /** Flag indicating if recv_writer thread is active. */
UNIV_INTERN bool recv_writer_thread_active = false; static volatile bool recv_writer_thread_active;
UNIV_INTERN os_thread_t recv_writer_thread_handle = 0; UNIV_INTERN os_thread_t recv_writer_thread_handle = 0;
#endif /* !UNIV_HOTBACKUP */ #endif /* !UNIV_HOTBACKUP */
...@@ -349,8 +349,6 @@ DECLARE_THREAD(recv_writer_thread)( ...@@ -349,8 +349,6 @@ DECLARE_THREAD(recv_writer_thread)(
os_thread_pf(os_thread_get_curr_id())); os_thread_pf(os_thread_get_curr_id()));
#endif /* UNIV_DEBUG_THREAD_CREATION */ #endif /* UNIV_DEBUG_THREAD_CREATION */
recv_writer_thread_active = true;
while (srv_shutdown_state == SRV_SHUTDOWN_NONE) { while (srv_shutdown_state == SRV_SHUTDOWN_NONE) {
/* Wait till we get a signal to clean the LRU list. /* Wait till we get a signal to clean the LRU list.
...@@ -3008,6 +3006,7 @@ recv_init_crash_recovery(void) ...@@ -3008,6 +3006,7 @@ recv_init_crash_recovery(void)
/* Spawn the background thread to flush dirty pages /* Spawn the background thread to flush dirty pages
from the buffer pools. */ from the buffer pools. */
recv_writer_thread_active = true;
recv_writer_thread_handle = os_thread_create( recv_writer_thread_handle = os_thread_create(
recv_writer_thread, 0, 0); recv_writer_thread, 0, 0);
} }
......
...@@ -182,7 +182,7 @@ UNIV_INTERN mysql_pfs_key_t recv_writer_mutex_key; ...@@ -182,7 +182,7 @@ UNIV_INTERN mysql_pfs_key_t recv_writer_mutex_key;
# endif /* UNIV_PFS_MUTEX */ # endif /* UNIV_PFS_MUTEX */
/** Flag indicating if recv_writer thread is active. */ /** Flag indicating if recv_writer thread is active. */
UNIV_INTERN bool recv_writer_thread_active = false; static volatile bool recv_writer_thread_active;
UNIV_INTERN os_thread_t recv_writer_thread_handle = 0; UNIV_INTERN os_thread_t recv_writer_thread_handle = 0;
#endif /* !UNIV_HOTBACKUP */ #endif /* !UNIV_HOTBACKUP */
...@@ -348,8 +348,6 @@ DECLARE_THREAD(recv_writer_thread)( ...@@ -348,8 +348,6 @@ DECLARE_THREAD(recv_writer_thread)(
os_thread_pf(os_thread_get_curr_id())); os_thread_pf(os_thread_get_curr_id()));
#endif /* UNIV_DEBUG_THREAD_CREATION */ #endif /* UNIV_DEBUG_THREAD_CREATION */
recv_writer_thread_active = true;
while (srv_shutdown_state == SRV_SHUTDOWN_NONE) { while (srv_shutdown_state == SRV_SHUTDOWN_NONE) {
os_thread_sleep(100000); os_thread_sleep(100000);
...@@ -3100,6 +3098,7 @@ recv_init_crash_recovery(void) ...@@ -3100,6 +3098,7 @@ recv_init_crash_recovery(void)
/* Spawn the background thread to flush dirty pages /* Spawn the background thread to flush dirty pages
from the buffer pools. */ from the buffer pools. */
recv_writer_thread_active = true;
recv_writer_thread_handle = os_thread_create( recv_writer_thread_handle = os_thread_create(
recv_writer_thread, 0, 0); recv_writer_thread, 0, 0);
} }
......
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