que0que.c, srv0que.c:

  Put asserts that make sure srv_que_task_enqueue() is never called under MySQL
parent 0e3c22ea
...@@ -214,6 +214,7 @@ que_thr_end_wait( ...@@ -214,6 +214,7 @@ que_thr_end_wait(
if (next_thr && *next_thr == NULL) { if (next_thr && *next_thr == NULL) {
*next_thr = thr; *next_thr = thr;
} else { } else {
ut_a(0);
srv_que_task_enqueue_low(thr); srv_que_task_enqueue_low(thr);
} }
} }
...@@ -394,6 +395,7 @@ que_fork_error_handle( ...@@ -394,6 +395,7 @@ que_fork_error_handle(
que_thr_move_to_run_state(thr); que_thr_move_to_run_state(thr);
ut_a(0);
srv_que_task_enqueue_low(thr); srv_que_task_enqueue_low(thr);
} }
...@@ -804,6 +806,7 @@ que_thr_dec_refer_count( ...@@ -804,6 +806,7 @@ que_thr_dec_refer_count(
if (next_thr && *next_thr == NULL) { if (next_thr && *next_thr == NULL) {
*next_thr = thr; *next_thr = thr;
} else { } else {
ut_a(0);
srv_que_task_enqueue_low(thr); srv_que_task_enqueue_low(thr);
} }
...@@ -1257,6 +1260,7 @@ loop: ...@@ -1257,6 +1260,7 @@ loop:
loop_count++; loop_count++;
if (next_thr != thr) { if (next_thr != thr) {
ut_a(next_thr == NULL);
que_thr_dec_refer_count(thr, &next_thr); que_thr_dec_refer_count(thr, &next_thr);
if (next_thr == NULL) { if (next_thr == NULL) {
......
...@@ -103,6 +103,8 @@ srv_que_task_enqueue( ...@@ -103,6 +103,8 @@ srv_que_task_enqueue(
{ {
ut_ad(thr); ut_ad(thr);
ut_a(0); /* Under MySQL this is never called */
mutex_enter(&kernel_mutex); mutex_enter(&kernel_mutex);
srv_que_task_enqueue_low(thr); srv_que_task_enqueue_low(thr);
......
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