summaryrefslogtreecommitdiff
path: root/innobase/fil/fil0fil.c
diff options
context:
space:
mode:
Diffstat (limited to 'innobase/fil/fil0fil.c')
-rw-r--r--innobase/fil/fil0fil.c5
1 files changed, 5 insertions, 0 deletions
diff --git a/innobase/fil/fil0fil.c b/innobase/fil/fil0fil.c
index 9f33013d2f9..35a028822c0 100644
--- a/innobase/fil/fil0fil.c
+++ b/innobase/fil/fil0fil.c
@@ -1331,6 +1331,7 @@ fil_aio_wait(
ut_ad(fil_validate());
if (os_aio_use_native_aio) {
+ ut_a(segment < SRV_MAX_N_IO_THREADS);
srv_io_thread_op_info[segment] = (char *) "native aio handle";
#ifdef WIN_ASYNC_IO
ret = os_aio_windows_handle(segment, 0, &fil_node, &message,
@@ -1342,6 +1343,7 @@ fil_aio_wait(
ut_error;
#endif
} else {
+ ut_a(segment < SRV_MAX_N_IO_THREADS);
srv_io_thread_op_info[segment] =(char *)"simulated aio handle";
ret = os_aio_simulated_handle(segment, (void**) &fil_node,
@@ -1350,6 +1352,7 @@ fil_aio_wait(
ut_a(ret);
+ ut_a(segment < SRV_MAX_N_IO_THREADS);
srv_io_thread_op_info[segment] = (char *) "complete io for fil node";
mutex_enter(&(system->mutex));
@@ -1363,10 +1366,12 @@ fil_aio_wait(
/* Do the i/o handling */
if (buf_pool_is_block(message)) {
+ ut_a(segment < SRV_MAX_N_IO_THREADS);
srv_io_thread_op_info[segment] =
(char *) "complete io for buf page";
buf_page_io_complete(message);
} else {
+ ut_a(segment < SRV_MAX_N_IO_THREADS);
srv_io_thread_op_info[segment] =(char *) "complete io for log";
log_io_complete(message);
}