Commit e13459a1 authored by Sergey Vojtovich's avatar Sergey Vojtovich

MDEV-7148 - Recurring: InnoDB: Failing assertion: !lock->recursive

Re-applied lost in the merge revision:
commit ed313e8a
Author: Sergey Vojtovich <svoj@mariadb.org>
Date:   Mon Dec 1 14:58:29 2014 +0400

    MDEV-7148 - Recurring: InnoDB: Failing assertion: !lock->recursive

    On PPC64 high-loaded server may crash due to assertion failure in InnoDB
    rwlocks code.

    This happened because load order between "recursive" and "writer_thread"
    wasn't properly enforced.
parent 7dee7a03
...@@ -386,6 +386,7 @@ rw_lock_x_lock_func_nowait( ...@@ -386,6 +386,7 @@ rw_lock_x_lock_func_nowait(
ulint line) /*!< in: line where requested */ ulint line) /*!< in: line where requested */
{ {
ibool success; ibool success;
ibool local_recursive= lock->recursive;
#ifdef INNODB_RW_LOCKS_USE_ATOMICS #ifdef INNODB_RW_LOCKS_USE_ATOMICS
success = os_compare_and_swap_lint(&lock->lock_word, X_LOCK_DECR, 0); success = os_compare_and_swap_lint(&lock->lock_word, X_LOCK_DECR, 0);
...@@ -400,10 +401,14 @@ rw_lock_x_lock_func_nowait( ...@@ -400,10 +401,14 @@ rw_lock_x_lock_func_nowait(
mutex_exit(&(lock->mutex)); mutex_exit(&(lock->mutex));
#endif #endif
/* Note: recursive must be loaded before writer_thread see
comment for rw_lock_set_writer_id_and_recursion_flag().
To achieve this we load it before os_compare_and_swap_lint(),
which implies full memory barrier in current implementation. */
if (success) { if (success) {
rw_lock_set_writer_id_and_recursion_flag(lock, TRUE); rw_lock_set_writer_id_and_recursion_flag(lock, TRUE);
} else if (lock->recursive } else if (local_recursive
&& os_thread_eq(lock->writer_thread, && os_thread_eq(lock->writer_thread,
os_thread_get_curr_id())) { os_thread_get_curr_id())) {
/* Relock: this lock_word modification is safe since no other /* Relock: this lock_word modification is safe since no other
......
...@@ -545,6 +545,8 @@ rw_lock_x_lock_low( ...@@ -545,6 +545,8 @@ rw_lock_x_lock_low(
const char* file_name,/*!< in: file name where lock requested */ const char* file_name,/*!< in: file name where lock requested */
ulint line) /*!< in: line where requested */ ulint line) /*!< in: line where requested */
{ {
ibool local_recursive= lock->recursive;
if (rw_lock_lock_word_decr(lock, X_LOCK_DECR)) { if (rw_lock_lock_word_decr(lock, X_LOCK_DECR)) {
/* lock->recursive also tells us if the writer_thread /* lock->recursive also tells us if the writer_thread
...@@ -566,12 +568,12 @@ rw_lock_x_lock_low( ...@@ -566,12 +568,12 @@ rw_lock_x_lock_low(
} else { } else {
os_thread_id_t thread_id = os_thread_get_curr_id(); os_thread_id_t thread_id = os_thread_get_curr_id();
if (!pass) { /* Decrement failed: relock or failed lock
os_rmb; Note: recursive must be loaded before writer_thread see
} comment for rw_lock_set_writer_id_and_recursion_flag().
To achieve this we load it before rw_lock_lock_word_decr(),
/* Decrement failed: relock or failed lock */ which implies full memory barrier in current implementation. */
if (!pass && lock->recursive if (!pass && local_recursive
&& os_thread_eq(lock->writer_thread, thread_id)) { && os_thread_eq(lock->writer_thread, thread_id)) {
/* Relock */ /* Relock */
if (lock->lock_word == 0) { if (lock->lock_word == 0) {
......
...@@ -511,6 +511,7 @@ rw_lock_x_lock_func_nowait( ...@@ -511,6 +511,7 @@ rw_lock_x_lock_func_nowait(
ulint line) /*!< in: line where requested */ ulint line) /*!< in: line where requested */
{ {
ibool success; ibool success;
ibool local_recursive= lock->recursive;
#ifdef INNODB_RW_LOCKS_USE_ATOMICS #ifdef INNODB_RW_LOCKS_USE_ATOMICS
success = os_compare_and_swap_lint(&lock->lock_word, X_LOCK_DECR, 0); success = os_compare_and_swap_lint(&lock->lock_word, X_LOCK_DECR, 0);
...@@ -525,10 +526,14 @@ rw_lock_x_lock_func_nowait( ...@@ -525,10 +526,14 @@ rw_lock_x_lock_func_nowait(
mutex_exit(&(lock->mutex)); mutex_exit(&(lock->mutex));
#endif #endif
/* Note: recursive must be loaded before writer_thread see
comment for rw_lock_set_writer_id_and_recursion_flag().
To achieve this we load it before os_compare_and_swap_lint(),
which implies full memory barrier in current implementation. */
if (success) { if (success) {
rw_lock_set_writer_id_and_recursion_flag(lock, TRUE); rw_lock_set_writer_id_and_recursion_flag(lock, TRUE);
} else if (lock->recursive } else if (local_recursive
&& os_thread_eq(lock->writer_thread, && os_thread_eq(lock->writer_thread,
os_thread_get_curr_id())) { os_thread_get_curr_id())) {
/* Relock: this lock_word modification is safe since no other /* Relock: this lock_word modification is safe since no other
......
...@@ -694,6 +694,8 @@ rw_lock_x_lock_low( ...@@ -694,6 +694,8 @@ rw_lock_x_lock_low(
const char* file_name,/*!< in: file name where lock requested */ const char* file_name,/*!< in: file name where lock requested */
ulint line) /*!< in: line where requested */ ulint line) /*!< in: line where requested */
{ {
ibool local_recursive= lock->recursive;
if (rw_lock_lock_word_decr(lock, X_LOCK_DECR)) { if (rw_lock_lock_word_decr(lock, X_LOCK_DECR)) {
/* lock->recursive also tells us if the writer_thread /* lock->recursive also tells us if the writer_thread
...@@ -715,12 +717,12 @@ rw_lock_x_lock_low( ...@@ -715,12 +717,12 @@ rw_lock_x_lock_low(
} else { } else {
os_thread_id_t thread_id = os_thread_get_curr_id(); os_thread_id_t thread_id = os_thread_get_curr_id();
if (!pass) { /* Decrement failed: relock or failed lock
os_rmb; Note: recursive must be loaded before writer_thread see
} comment for rw_lock_set_writer_id_and_recursion_flag().
To achieve this we load it before rw_lock_lock_word_decr(),
/* Decrement failed: relock or failed lock */ which implies full memory barrier in current implementation. */
if (!pass && lock->recursive if (!pass && local_recursive
&& os_thread_eq(lock->writer_thread, thread_id)) { && os_thread_eq(lock->writer_thread, thread_id)) {
/* Relock */ /* Relock */
if (lock->lock_word == 0) { if (lock->lock_word == 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