diff options
| author | unknown <heikki@hundin.mysql.fi> | 2004-06-17 16:05:19 +0300 |
|---|---|---|
| committer | unknown <heikki@hundin.mysql.fi> | 2004-06-17 16:05:19 +0300 |
| commit | 1ebf24b9576a3b2b70b742759c2e160215c895ce (patch) | |
| tree | cd7cd2f9901044e747392c77a5279674bfa9fe83 | |
| parent | 3774abe3c03cbed7b0b7e04d1d4534671a8be5cf (diff) | |
| download | mariadb-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
| -rw-r--r-- | innobase/que/que0que.c | 4 | ||||
| -rw-r--r-- | innobase/srv/srv0que.c | 2 |
2 files changed, 6 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) { diff --git a/innobase/srv/srv0que.c b/innobase/srv/srv0que.c index ac8bd7d0e65..9dc9ae453d9 100644 --- a/innobase/srv/srv0que.c +++ b/innobase/srv/srv0que.c @@ -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); |