Commit 0ddf32c8 authored by sjaakola's avatar sjaakola Committed by Jan Lindström

refs: MW-322 * generating fake trx id for CTAS, requires trx_sys mutex...

refs: MW-322 * generating fake trx id for CTAS, requires trx_sys mutex protection to be safe for concurrent CTAS processors
parent 790a8274
...@@ -17945,7 +17945,7 @@ wsrep_fake_trx_id( ...@@ -17945,7 +17945,7 @@ wsrep_fake_trx_id(
mutex_enter(&trx_sys->mutex); mutex_enter(&trx_sys->mutex);
trx_id_t trx_id = trx_sys_get_new_trx_id(); trx_id_t trx_id = trx_sys_get_new_trx_id();
mutex_exit(&trx_sys->mutex); mutex_exit(&trx_sys->mutex);
WSREP_DEBUG("innodb fake trx id: %lu thd: %s", trx_id, wsrep_thd_query(thd));
(void *)wsrep_ws_handle_for_trx(wsrep_thd_ws_handle(thd), trx_id); (void *)wsrep_ws_handle_for_trx(wsrep_thd_ws_handle(thd), trx_id);
} }
......
...@@ -19247,7 +19247,7 @@ wsrep_fake_trx_id( ...@@ -19247,7 +19247,7 @@ wsrep_fake_trx_id(
mutex_enter(&trx_sys->mutex); mutex_enter(&trx_sys->mutex);
trx_id_t trx_id = trx_sys_get_new_trx_id(); trx_id_t trx_id = trx_sys_get_new_trx_id();
mutex_exit(&trx_sys->mutex); mutex_exit(&trx_sys->mutex);
WSREP_DEBUG("innodb fake trx id: %lu thd: %s", trx_id, wsrep_thd_query(thd));
(void *)wsrep_ws_handle_for_trx(wsrep_thd_ws_handle(thd), trx_id); (void *)wsrep_ws_handle_for_trx(wsrep_thd_ws_handle(thd), trx_id);
} }
......
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