Commit 1ebf24b9 authored by unknown's avatar unknown
Browse files

que0que.c, srv0que.c: 

  Put asserts that make sure srv_que_task_enqueue() is never called under MySQL


innobase/srv/srv0que.c:
  Put asserts that make sure srv_que_task_enqueu() is never called under MySQL
innobase/que/que0que.c:
  Put asserts that make sure srv_que_task_enqueu() is never called under MySQL
parent 3774abe3

innobase/que/que0que.c

+4 −0
Original line number Diff line number Diff line
@@ -214,6 +214,7 @@ que_thr_end_wait( 
	if (next_thr && *next_thr == NULL) {

		*next_thr = thr;

	} else {

		ut_a(0);

		srv_que_task_enqueue_low(thr);

	}

}
@@ -394,6 +395,7 @@ que_fork_error_handle( 
	

	que_thr_move_to_run_state(thr);



	ut_a(0);

	srv_que_task_enqueue_low(thr);

}
@@ -804,6 +806,7 @@ que_thr_dec_refer_count( 
			if (next_thr && *next_thr == NULL) {

				*next_thr = thr;

			} else {

				ut_a(0);

				srv_que_task_enqueue_low(thr);

			}
@@ -1257,6 +1260,7 @@ que_run_threads( 
	loop_count++;



	if (next_thr != thr) {

		ut_a(next_thr == NULL);

		que_thr_dec_refer_count(thr, &next_thr);



		if (next_thr == NULL) {

innobase/srv/srv0que.c

+2 −0
Original line number Diff line number Diff line
@@ -103,6 +103,8 @@ srv_que_task_enqueue( 
{

	ut_ad(thr);



	ut_a(0);	/* Under MySQL this is never called */



	mutex_enter(&kernel_mutex);

	

	srv_que_task_enqueue_low(thr);