summaryrefslogtreecommitdiff
path: root/innobase/que
diff options
context:
space:
mode:
authorunknown <heikki@hundin.mysql.fi>2004-06-17 16:05:19 +0300
committerunknown <heikki@hundin.mysql.fi>2004-06-17 16:05:19 +0300
commit1ebf24b9576a3b2b70b742759c2e160215c895ce (patch)
treecd7cd2f9901044e747392c77a5279674bfa9fe83 /innobase/que
parent3774abe3c03cbed7b0b7e04d1d4534671a8be5cf (diff)
downloadmariadb-git-1ebf24b9576a3b2b70b742759c2e160215c895ce.tar.gz
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
Diffstat (limited to 'innobase/que')
-rw-r--r--innobase/que/que0que.c4
1 files changed, 4 insertions, 0 deletions
diff --git a/innobase/que/que0que.c b/innobase/que/que0que.c
index 70656c57837..3af4cf09539 100644
--- a/innobase/que/que0que.c
+++ b/innobase/que/que0que.c
@@ -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 @@ loop:
loop_count++;
if (next_thr != thr) {
+ ut_a(next_thr == NULL);
que_thr_dec_refer_count(thr, &next_thr);
if (next_thr == NULL) {