← Back to branch summary

~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to plugin/innobase/srv/srv0start.c

  • Committer: Monty Taylor
  • Date: 2010-09-26 21:24:15 UTC
  • mto: (1796.1.2 build)
  • mto: This revision was merged to the branch mainline in revision 1797.
  • Revision ID: mordred@inaugust.com-20100926212415-5fn3p3q75pgiei7r
Moved protocol doc into the docs.

Show diffs side-by-side

added added

removed removed

Lines of Context:
plugin/innobase/srv/srv0start.c
1
1
/*****************************************************************************
2
2
 
3
 
Copyright (C) 1996, 2010, Innobase Oy. All Rights Reserved.
4
 
Copyright (C) 2008, Google Inc.
5
 
Copyright (C) 2009, Percona Inc.
 
3
Copyright (c) 1996, 2009, Innobase Oy. All Rights Reserved.
 
4
Copyright (c) 2008, Google Inc.
6
5
 
7
6
Portions of this file contain modifications contributed and copyrighted by
8
7
Google, Inc. Those modifications are gratefully acknowledged and are described
10
9
incorporated with their permission, and subject to the conditions contained in
11
10
the file COPYING.Google.
12
11
 
13
 
Portions of this file contain modifications contributed and copyrighted
14
 
by Percona Inc.. Those modifications are
15
 
gratefully acknowledged and are described briefly in the InnoDB
16
 
documentation. The contributions by Percona Inc. are incorporated with
17
 
their permission, and subject to the conditions contained in the file
18
 
COPYING.Percona.
19
 
 
20
12
This program is free software; you can redistribute it and/or modify it under
21
13
the terms of the GNU General Public License as published by the Free Software
22
14
Foundation; version 2 of the License.
26
18
FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details.
27
19
 
28
20
You should have received a copy of the GNU General Public License along with
29
 
this program; if not, write to the Free Software Foundation, Inc., 51 Franklin
30
 
St, Fifth Floor, Boston, MA 02110-1301 USA
 
21
this program; if not, write to the Free Software Foundation, Inc., 59 Temple
 
22
Place, Suite 330, Boston, MA 02111-1307 USA
31
23
 
32
24
*****************************************************************************/
 
25
/***********************************************************************
 
26
 
 
27
Copyright (c) 1995, 2009, Innobase Oy. All Rights Reserved.
 
28
Copyright (c) 2009, Percona Inc.
 
29
 
 
30
Portions of this file contain modifications contributed and copyrighted
 
31
by Percona Inc.. Those modifications are
 
32
gratefully acknowledged and are described briefly in the InnoDB
 
33
documentation. The contributions by Percona Inc. are incorporated with
 
34
their permission, and subject to the conditions contained in the file
 
35
COPYING.Percona.
 
36
 
 
37
This program is free software; you can redistribute it and/or modify it
 
38
under the terms of the GNU General Public License as published by the
 
39
Free Software Foundation; version 2 of the License.
 
40
 
 
41
This program is distributed in the hope that it will be useful, but
 
42
WITHOUT ANY WARRANTY; without even the implied warranty of
 
43
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General
 
44
Public License for more details.
 
45
 
 
46
You should have received a copy of the GNU General Public License along
 
47
with this program; if not, write to the Free Software Foundation, Inc.,
 
48
59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
 
49
 
 
50
***********************************************************************/
33
51
 
34
52
/********************************************************************//**
35
53
@file srv/srv0start.c
85
103
# include "row0row.h"
86
104
# include "row0mysql.h"
87
105
# include "btr0pcur.h"
88
 
# include "thr0loc.h"
89
 
# include "os0sync.h" /* for INNODB_RW_LOCKS_USE_ATOMICS */
90
 
# include "zlib.h" /* for ZLIB_VERSION */
91
106
 
92
107
#include <errno.h>
93
108
#include <unistd.h>
129
144
static ulint            ios;
130
145
 
131
146
/** io_handler_thread parameters for thread identification */
132
 
static ulint            n[SRV_MAX_N_IO_THREADS + 6];
 
147
static ulint            n[SRV_MAX_N_IO_THREADS + 5];
133
148
/** io_handler_thread identifiers */
134
 
static os_thread_id_t   thread_ids[SRV_MAX_N_IO_THREADS + 6];
 
149
static os_thread_id_t   thread_ids[SRV_MAX_N_IO_THREADS + 5];
135
150
 
136
151
/** We use this mutex to test the return value of pthread_mutex_trylock
137
152
   on successful locking. HP-UX does NOT return 0, though Linux et al do. */
145
160
#define SRV_N_PENDING_IOS_PER_THREAD    OS_AIO_N_PENDING_IOS_PER_THREAD
146
161
#define SRV_MAX_N_PENDING_SYNC_IOS      100
147
162
 
148
 
#ifdef UNIV_PFS_THREAD
149
 
/* Keys to register InnoDB threads with performance schema */
150
 
UNIV_INTERN mysql_pfs_key_t     io_handler_thread_key;
151
 
UNIV_INTERN mysql_pfs_key_t     srv_lock_timeout_thread_key;
152
 
UNIV_INTERN mysql_pfs_key_t     srv_error_monitor_thread_key;
153
 
UNIV_INTERN mysql_pfs_key_t     srv_monitor_thread_key;
154
 
UNIV_INTERN mysql_pfs_key_t     srv_master_thread_key;
155
 
#endif /* UNIV_PFS_THREAD */
156
 
 
157
 
#ifdef UNIV_PFS_MUTEX
158
 
/* Key to register ios_mutex_key with performance schema */
159
 
UNIV_INTERN mysql_pfs_key_t     ios_mutex_key;
160
 
#endif /* UNIV_PFS_MUTEX */
161
163
 
162
164
/*********************************************************************//**
163
165
Convert a numeric string that optionally ends in G or M, to a number
479
481
                        the aio array */
480
482
{
481
483
        ulint   segment;
 
484
        ulint   i;
482
485
 
483
486
        segment = *((ulint*)arg);
484
487
 
486
489
        fprintf(stderr, "Io handler thread %lu starts, id %lu\n", segment,
487
490
                os_thread_pf(os_thread_get_curr_id()));
488
491
#endif
489
 
 
490
 
#ifdef UNIV_PFS_THREAD
491
 
        pfs_register_thread(io_handler_thread_key);
492
 
#endif /* UNIV_PFS_THREAD */
493
 
 
494
 
        while (srv_shutdown_state != SRV_SHUTDOWN_EXIT_THREADS) {
 
492
        for (i = 0;; i++) {
495
493
                fil_aio_wait(segment);
496
494
 
497
495
                mutex_enter(&ios_mutex);
499
497
                mutex_exit(&ios_mutex);
500
498
        }
501
499
 
502
 
        thr_local_free(os_thread_get_curr_id());
503
 
 
504
500
        /* We count the number of threads in os_thread_exit(). A created
505
501
        thread should always use that to exit and not use return() to exit.
506
502
        The thread actually never comes here because it is exited in an
507
503
        os_event_wait(). */
 
504
#if (!defined(__SUNPRO_C) && !defined(__SUNPRO_CC))
508
505
        return 0;
 
506
#endif
509
507
}
510
508
#endif /* !UNIV_HOTBACKUP */
511
509
 
534
532
#endif
535
533
}
536
534
 
 
535
/*********************************************************************//**
 
536
Adds a slash or a backslash to the end of a string if it is missing
 
537
and the string is not empty.
 
538
@return string which has the separator if the string is not empty */
 
539
UNIV_INTERN
 
540
char*
 
541
srv_add_path_separator_if_needed(
 
542
/*=============================*/
 
543
        char*   str)    /*!< in: null-terminated character string */
 
544
{
 
545
        char*   out_str;
 
546
        ulint   len     = ut_strlen(str);
 
547
 
 
548
        if (len == 0 || str[len - 1] == SRV_PATH_SEPARATOR) {
 
549
 
 
550
                return(str);
 
551
        }
 
552
 
 
553
        out_str = ut_malloc(len + 2);
 
554
        memcpy(out_str, str, len);
 
555
        out_str[len] = SRV_PATH_SEPARATOR;
 
556
        out_str[len + 1] = 0;
 
557
 
 
558
        return(out_str);
 
559
}
 
560
 
537
561
#ifndef UNIV_HOTBACKUP
538
562
/*********************************************************************//**
539
563
Calculates the low 32 bits when a file size which is given as a number
582
606
        ulint   size;
583
607
        ulint   size_high;
584
608
        char    name[10000];
585
 
        ulint   dirnamelen;
586
609
 
587
610
        UT_NOT_USED(create_new_db);
588
611
 
589
612
        *log_file_created = FALSE;
590
613
 
591
614
        srv_normalize_path_for_win(srv_log_group_home_dirs[k]);
592
 
 
593
 
        dirnamelen = strlen(srv_log_group_home_dirs[k]);
594
 
        ut_a(dirnamelen < (sizeof name) - 10 - sizeof "ib_logfile");
595
 
        memcpy(name, srv_log_group_home_dirs[k], dirnamelen);
596
 
 
597
 
        /* Add a path separator if needed. */
598
 
        if (dirnamelen && name[dirnamelen - 1] != SRV_PATH_SEPARATOR) {
599
 
                name[dirnamelen++] = SRV_PATH_SEPARATOR;
600
 
        }
601
 
 
602
 
        sprintf(name + dirnamelen, "%s%lu", "ib_logfile", (ulong) i);
603
 
 
604
 
        files[i] = os_file_create(innodb_file_log_key, name,
605
 
                                  OS_FILE_CREATE, OS_FILE_NORMAL,
 
615
        srv_log_group_home_dirs[k] = srv_add_path_separator_if_needed(
 
616
                srv_log_group_home_dirs[k]);
 
617
 
 
618
        ut_a(strlen(srv_log_group_home_dirs[k])
 
619
             < (sizeof name) - 10 - sizeof "ib_logfile");
 
620
        sprintf(name, "%s%s%lu", srv_log_group_home_dirs[k],
 
621
                "ib_logfile", (ulong) i);
 
622
 
 
623
        files[i] = os_file_create(name, OS_FILE_CREATE, OS_FILE_NORMAL,
606
624
                                  OS_LOG_FILE, &ret);
607
625
        if (ret == FALSE) {
608
626
                if (os_file_get_last_error(FALSE) != OS_FILE_ALREADY_EXISTS
620
638
                        return(DB_ERROR);
621
639
                }
622
640
 
623
 
                files[i] = os_file_create(innodb_file_log_key, name,
624
 
                                          OS_FILE_OPEN, OS_FILE_AIO,
 
641
                files[i] = os_file_create(name, OS_FILE_OPEN, OS_FILE_AIO,
625
642
                                          OS_LOG_FILE, &ret);
626
643
                if (!ret) {
627
644
                        fprintf(stderr,
764
781
        *create_new_db = FALSE;
765
782
 
766
783
        srv_normalize_path_for_win(srv_data_home);
 
784
        srv_data_home = srv_add_path_separator_if_needed(srv_data_home);
767
785
 
768
786
        for (i = 0; i < srv_n_data_files; i++) {
769
 
                ulint   dirnamelen;
770
 
 
771
787
                srv_normalize_path_for_win(srv_data_file_names[i]);
772
 
                dirnamelen = strlen(srv_data_home);
773
788
 
774
 
                ut_a(dirnamelen + strlen(srv_data_file_names[i])
 
789
                ut_a(strlen(srv_data_home) + strlen(srv_data_file_names[i])
775
790
                     < (sizeof name) - 1);
776
 
                memcpy(name, srv_data_home, dirnamelen);
777
 
                /* Add a path separator if needed. */
778
 
                if (dirnamelen && name[dirnamelen - 1] != SRV_PATH_SEPARATOR) {
779
 
                        name[dirnamelen++] = SRV_PATH_SEPARATOR;
780
 
                }
781
 
 
782
 
                strcpy(name + dirnamelen, srv_data_file_names[i]);
 
791
                sprintf(name, "%s%s", srv_data_home, srv_data_file_names[i]);
783
792
 
784
793
                if (srv_data_file_is_raw_partition[i] == 0) {
785
794
 
786
795
                        /* First we try to create the file: if it already
787
796
                        exists, ret will get value FALSE */
788
797
 
789
 
                        files[i] = os_file_create(innodb_file_data_key,
790
 
                                                  name, OS_FILE_CREATE,
 
798
                        files[i] = os_file_create(name, OS_FILE_CREATE,
791
799
                                                  OS_FILE_NORMAL,
792
800
                                                  OS_DATA_FILE, &ret);
793
801
 
814
822
                        srv_start_raw_disk_in_use = TRUE;
815
823
                        srv_created_new_raw = TRUE;
816
824
 
817
 
                        files[i] = os_file_create(innodb_file_data_key,
818
 
                                                  name, OS_FILE_OPEN_RAW,
 
825
                        files[i] = os_file_create(name, OS_FILE_OPEN_RAW,
819
826
                                                  OS_FILE_NORMAL,
820
827
                                                  OS_DATA_FILE, &ret);
821
828
                        if (!ret) {
848
855
 
849
856
                        if (srv_data_file_is_raw_partition[i] == SRV_OLD_RAW) {
850
857
                                files[i] = os_file_create(
851
 
                                        innodb_file_data_key,
852
858
                                        name, OS_FILE_OPEN_RAW,
853
859
                                        OS_FILE_NORMAL, OS_DATA_FILE, &ret);
854
860
                        } else if (i == 0) {
855
861
                                files[i] = os_file_create(
856
 
                                        innodb_file_data_key,
857
862
                                        name, OS_FILE_OPEN_RETRY,
858
863
                                        OS_FILE_NORMAL, OS_DATA_FILE, &ret);
859
864
                        } else {
860
865
                                files[i] = os_file_create(
861
 
                                        innodb_file_data_key,
862
866
                                        name, OS_FILE_OPEN, OS_FILE_NORMAL,
863
867
                                        OS_DATA_FILE, &ret);
864
868
                        }
1001
1005
 
1002
1006
        ios = 0;
1003
1007
 
1004
 
        mutex_create(ios_mutex_key, &ios_mutex, SYNC_NO_ORDER_CHECK);
 
1008
        mutex_create(&ios_mutex, SYNC_NO_ORDER_CHECK);
1005
1009
 
1006
1010
        return(DB_SUCCESS);
1007
1011
}
1008
1012
 
1009
 
/********************************************************************
 
1013
/****************************************************************//**
1010
1014
Starts InnoDB and creates a new database if database files
1011
1015
are not found and the user wants.
1012
1016
@return DB_SUCCESS or error code */
1015
1019
innobase_start_or_create_for_mysql(void)
1016
1020
/*====================================*/
1017
1021
{
 
1022
        buf_pool_t*     ret;
1018
1023
        ibool           create_new_db;
1019
1024
        ibool           log_file_created;
1020
1025
        ibool           log_created     = FALSE;
1080
1085
#ifdef UNIV_IBUF_DEBUG
1081
1086
        fprintf(stderr,
1082
1087
                "InnoDB: !!!!!!!! UNIV_IBUF_DEBUG switched on !!!!!!!!!\n"
1083
 
# ifdef UNIV_IBUF_COUNT_DEBUG
1084
 
                "InnoDB: !!!!!!!! UNIV_IBUF_COUNT_DEBUG switched on !!!!!!!!!\n"
1085
 
                "InnoDB: Crash recovery will fail with UNIV_IBUF_COUNT_DEBUG\n"
1086
 
# endif
1087
 
                );
 
1088
                "InnoDB: Crash recovery will fail with UNIV_IBUF_DEBUG\n");
1088
1089
#endif
1089
1090
 
1090
1091
#ifdef UNIV_SYNC_DEBUG
1097
1098
                "InnoDB: !!!!!!!! UNIV_SEARCH_DEBUG switched on !!!!!!!!!\n");
1098
1099
#endif
1099
1100
 
1100
 
#ifdef UNIV_LOG_LSN_DEBUG
1101
 
        fprintf(stderr,
1102
 
                "InnoDB: !!!!!!!! UNIV_LOG_LSN_DEBUG switched on !!!!!!!!!\n");
1103
 
#endif /* UNIV_LOG_LSN_DEBUG */
1104
1101
#ifdef UNIV_MEM_DEBUG
1105
1102
        fprintf(stderr,
1106
1103
                "InnoDB: !!!!!!!! UNIV_MEM_DEBUG switched on !!!!!!!!!\n");
1111
1108
                        "InnoDB: The InnoDB memory heap is disabled\n");
1112
1109
        }
1113
1110
 
1114
 
        fputs("InnoDB: " IB_ATOMICS_STARTUP_MSG
1115
 
              "\nInnoDB: Compressed tables use zlib " ZLIB_VERSION
1116
 
#ifdef UNIV_ZIP_DEBUG
1117
 
              " with validation"
1118
 
#endif /* UNIV_ZIP_DEBUG */
1119
 
#ifdef UNIV_ZIP_COPY
1120
 
              " and extra copying"
1121
 
#endif /* UNIV_ZIP_COPY */
1122
 
              "\n" , stderr);
1123
 
 
 
1111
#ifdef HAVE_GCC_ATOMIC_BUILTINS
 
1112
# ifdef INNODB_RW_LOCKS_USE_ATOMICS
 
1113
        fprintf(stderr,
 
1114
                "InnoDB: Mutexes and rw_locks use GCC atomic builtins.\n");
 
1115
# else /* INNODB_RW_LOCKS_USE_ATOMICS */
 
1116
        fprintf(stderr,
 
1117
                "InnoDB: Mutexes use GCC atomic builtins, rw_locks do not.\n");
 
1118
# endif /* INNODB_RW_LOCKS_USE_ATOMICS */
 
1119
#elif defined(HAVE_SOLARIS_ATOMICS)
 
1120
# ifdef INNODB_RW_LOCKS_USE_ATOMICS
 
1121
        fprintf(stderr,
 
1122
                "InnoDB: Mutexes and rw_locks use Solaris atomic functions.\n");
 
1123
# else
 
1124
        fprintf(stderr,
 
1125
                "InnoDB: Mutexes use Solaris atomic functions.\n");
 
1126
# endif /* INNODB_RW_LOCKS_USE_ATOMICS */
 
1127
#elif defined(HAVE_WINDOWS_ATOMICS)
 
1128
# ifdef INNODB_RW_LOCKS_USE_ATOMICS
 
1129
        fprintf(stderr,
 
1130
                "InnoDB: Mutexes and rw_locks use Windows interlocked functions.\n");
 
1131
# else
 
1132
        fprintf(stderr,
 
1133
                "InnoDB: Mutexes use Windows interlocked functions.\n");
 
1134
# endif /* INNODB_RW_LOCKS_USE_ATOMICS */
 
1135
#else /* HAVE_GCC_ATOMIC_BUILTINS */
 
1136
        fprintf(stderr,
 
1137
                "InnoDB: Neither mutexes nor rw_locks use GCC atomic builtins.\n");
 
1138
#endif /* HAVE_GCC_ATOMIC_BUILTINS */
1124
1139
 
1125
1140
        /* Since InnoDB does not currently clean up all its internal data
1126
1141
        structures in MySQL Embedded Server Library server_end(), we
1129
1144
 
1130
1145
        if (srv_start_has_been_called) {
1131
1146
                fprintf(stderr,
1132
 
                        "InnoDB: Error: startup called second time"
 
1147
                        "InnoDB: Error:startup called second time"
1133
1148
                        " during the process lifetime.\n"
1134
1149
                        "InnoDB: In the MySQL Embedded Server Library"
1135
1150
                        " you cannot call server_init()\n"
1146
1161
 
1147
1162
        srv_is_being_started = TRUE;
1148
1163
        srv_startup_is_before_trx_rollback_phase = TRUE;
 
1164
        os_aio_use_native_aio = FALSE;
1149
1165
 
1150
1166
#ifdef __WIN__
1151
1167
        switch (os_get_os_version()) {
1157
1173
                but when run in conjunction with InnoDB Hot Backup, it seemed
1158
1174
                to corrupt the data files. */
1159
1175
 
1160
 
                srv_use_native_aio = FALSE;
1161
 
                break;
1162
 
 
1163
 
        case OS_WIN2000:
1164
 
        case OS_WINXP:
1165
 
                /* On 2000 and XP, async IO is available. */
1166
 
                srv_use_native_aio = TRUE;
1167
 
                break;
1168
 
 
 
1176
                os_aio_use_native_aio = FALSE;
 
1177
                break;
1169
1178
        default:
1170
 
                /* Vista and later have both async IO and condition variables */
1171
 
                srv_use_native_aio = TRUE;
1172
 
                srv_use_native_conditions = TRUE;
 
1179
                /* On Win 2000 and XP use async i/o */
 
1180
                os_aio_use_native_aio = TRUE;
1173
1181
                break;
1174
1182
        }
1175
 
 
1176
 
#elif defined(LINUX_NATIVE_AIO)
1177
 
 
1178
 
        if (srv_use_native_aio) {
1179
 
                ut_print_timestamp(stderr);
1180
 
                fprintf(stderr,
1181
 
                        "  InnoDB: Using Linux native AIO\n");
1182
 
        }
1183
 
#else
1184
 
        /* Currently native AIO is supported only on windows and linux
1185
 
        and that also when the support is compiled in. In all other
1186
 
        cases, we ignore the setting of innodb_use_native_aio. */
1187
 
        srv_use_native_aio = FALSE;
1188
 
 
1189
1183
#endif
1190
 
 
1191
1184
        if (srv_file_flush_method_str == NULL) {
1192
1185
                /* These are the default options */
1193
1186
 
1212
1205
#else
1213
1206
        } else if (0 == ut_strcmp(srv_file_flush_method_str, "normal")) {
1214
1207
                srv_win_file_flush_method = SRV_WIN_IO_NORMAL;
1215
 
                srv_use_native_aio = FALSE;
 
1208
                os_aio_use_native_aio = FALSE;
1216
1209
 
1217
1210
        } else if (0 == ut_strcmp(srv_file_flush_method_str, "unbuffered")) {
1218
1211
                srv_win_file_flush_method = SRV_WIN_IO_UNBUFFERED;
1219
 
                srv_use_native_aio = FALSE;
 
1212
                os_aio_use_native_aio = FALSE;
1220
1213
 
1221
1214
        } else if (0 == ut_strcmp(srv_file_flush_method_str,
1222
1215
                                  "async_unbuffered")) {
1238
1231
        maximum number of threads that can wait in the 'srv_conc array' for
1239
1232
        their time to enter InnoDB. */
1240
1233
 
 
1234
#if defined(__NETWARE__)
 
1235
 
 
1236
        /* Create less event semaphores because Win 98/ME had
 
1237
        difficulty creating 40000 event semaphores.  Comment from
 
1238
        Novell, Inc.: also, these just take a lot of memory on
 
1239
        NetWare. */
 
1240
        srv_max_n_threads = 1000;
 
1241
#else
1241
1242
        if (srv_buf_pool_size >= 1000 * 1024 * 1024) {
1242
1243
                /* If buffer pool is less than 1000 MB,
1243
 
                assume fewer threads. Also use only one
1244
 
                buffer pool instance */
 
1244
                assume fewer threads. */
1245
1245
                srv_max_n_threads = 50000;
1246
1246
 
1247
1247
        } else if (srv_buf_pool_size >= 8 * 1024 * 1024) {
1248
1248
 
1249
 
                srv_buf_pool_instances = 1;
1250
1249
                srv_max_n_threads = 10000;
1251
1250
        } else {
1252
 
                srv_buf_pool_instances = 1;
1253
1251
                srv_max_n_threads = 1000;       /* saves several MB of memory,
1254
1252
                                                especially in 64-bit
1255
1253
                                                computers */
1256
1254
        }
1257
 
 
 
1255
#endif
1258
1256
        err = srv_boot();
1259
1257
 
1260
1258
        if (err != DB_SUCCESS) {
1262
1260
                return((int) err);
1263
1261
        }
1264
1262
 
1265
 
        mutex_create(srv_monitor_file_mutex_key,
1266
 
                     &srv_monitor_file_mutex, SYNC_NO_ORDER_CHECK);
 
1263
        mutex_create(&srv_monitor_file_mutex, SYNC_NO_ORDER_CHECK);
1267
1264
 
1268
1265
        if (srv_innodb_status) {
1269
1266
                srv_monitor_file_name = mem_alloc(
1285
1282
                }
1286
1283
        }
1287
1284
 
1288
 
        mutex_create(srv_dict_tmpfile_mutex_key,
1289
 
                     &srv_dict_tmpfile_mutex, SYNC_DICT_OPERATION);
 
1285
        mutex_create(&srv_dict_tmpfile_mutex, SYNC_DICT_OPERATION);
1290
1286
 
1291
1287
        srv_dict_tmpfile = os_file_create_tmpfile();
1292
1288
        if (!srv_dict_tmpfile) {
1293
1289
                return(DB_ERROR);
1294
1290
        }
1295
1291
 
1296
 
        mutex_create(srv_misc_tmpfile_mutex_key,
1297
 
                     &srv_misc_tmpfile_mutex, SYNC_ANY_LATCH);
 
1292
        mutex_create(&srv_misc_tmpfile_mutex, SYNC_ANY_LATCH);
1298
1293
 
1299
1294
        srv_misc_tmpfile = os_file_create_tmpfile();
1300
1295
        if (!srv_misc_tmpfile) {
1313
1308
 
1314
1309
        /* TODO: Investigate if SRV_N_PENDING_IOS_PER_THREAD (32) limit
1315
1310
        still applies to windows. */
1316
 
        if (!srv_use_native_aio) {
 
1311
        if (!os_aio_use_native_aio) {
1317
1312
                io_limit = 8 * SRV_N_PENDING_IOS_PER_THREAD;
1318
1313
        } else {
1319
1314
                io_limit = SRV_N_PENDING_IOS_PER_THREAD;
1327
1322
        fil_init(srv_file_per_table ? 50000 : 5000,
1328
1323
                 srv_max_n_open_files);
1329
1324
 
1330
 
        /* Print time to initialize the buffer pool */
1331
 
        ut_print_timestamp(stderr);
1332
 
        fprintf(stderr,
1333
 
                "  InnoDB: Initializing buffer pool, size =");
1334
 
 
1335
 
        if (srv_buf_pool_size >= 1024 * 1024 * 1024) {
1336
 
                fprintf(stderr,
1337
 
                        " %.1fG\n",
1338
 
                        ((double) srv_buf_pool_size) / (1024 * 1024 * 1024));
1339
 
        } else {
1340
 
                fprintf(stderr,
1341
 
                        " %.1fM\n",
1342
 
                        ((double) srv_buf_pool_size) / (1024 * 1024));
1343
 
        }
1344
 
 
1345
 
        err = buf_pool_init(srv_buf_pool_size, srv_buf_pool_instances);
1346
 
 
1347
 
        ut_print_timestamp(stderr);
1348
 
        fprintf(stderr,
1349
 
                "  InnoDB: Completed initialization of buffer pool\n");
1350
 
 
1351
 
        if (err != DB_SUCCESS) {
 
1325
        ret = buf_pool_init();
 
1326
 
 
1327
        if (ret == NULL) {
1352
1328
                fprintf(stderr,
1353
1329
                        "InnoDB: Fatal error: cannot allocate the memory"
1354
1330
                        " for the buffer pool\n");
1418
1394
                sum_of_new_sizes += srv_data_file_sizes[i];
1419
1395
        }
1420
1396
 
1421
 
        if (sum_of_new_sizes < 10485760 / UNIV_PAGE_SIZE) {
 
1397
        if (sum_of_new_sizes < 640) {
1422
1398
                fprintf(stderr,
1423
1399
                        "InnoDB: Error: tablespace size must be"
1424
1400
                        " at least 10 MB\n");
1545
1521
 
1546
1522
        if (create_new_db) {
1547
1523
                mtr_start(&mtr);
1548
 
 
1549
1524
                fsp_header_init(0, sum_of_new_sizes, &mtr);
1550
1525
 
1551
1526
                mtr_commit(&mtr);
1552
1527
 
1553
 
                /* To maintain backward compatibility we create only
1554
 
                the first rollback segment before the double write buffer.
1555
 
                All the remaining rollback segments will be created later,
1556
 
                after the double write buffer has been created. */
1557
1528
                trx_sys_create();
1558
 
 
1559
1529
                dict_create();
1560
 
 
1561
1530
                srv_startup_is_before_trx_rollback_phase = FALSE;
1562
1531
 
1563
1532
#ifdef UNIV_LOG_ARCHIVE
1576
1545
                in any disk i/o, first call dict_boot */
1577
1546
 
1578
1547
                dict_boot();
1579
 
 
1580
1548
                trx_sys_init_at_db_start();
1581
 
 
1582
1549
                srv_startup_is_before_trx_rollback_phase = FALSE;
1583
1550
 
1584
1551
                /* Initialize the fsp free limit global variable in the log
1602
1569
                consistent state, this is REQUIRED for the recovery
1603
1570
                process to work. */
1604
1571
                err = trx_sys_file_format_max_check(
1605
 
                        srv_max_file_format_at_startup);
 
1572
                        srv_check_file_format_at_startup);
1606
1573
 
1607
1574
                if (err != DB_SUCCESS) {
1608
1575
                        return(err);
1636
1603
                dict_boot();
1637
1604
                trx_sys_init_at_db_start();
1638
1605
 
1639
 
                /* Initialize the fsp free limit global variable in the log
1640
 
                system */
1641
 
                fsp_header_get_free_limit();
1642
 
 
1643
 
                /* recv_recovery_from_checkpoint_finish needs trx lists which
1644
 
                are initialized in trx_sys_init_at_db_start(). */
1645
 
 
1646
 
                recv_recovery_from_checkpoint_finish();
1647
1606
                if (srv_force_recovery < SRV_FORCE_NO_IBUF_MERGE) {
1648
1607
                        /* The following call is necessary for the insert
1649
1608
                        buffer to work with multiple tablespaces. We must
1659
1618
                        every table in the InnoDB data dictionary that has
1660
1619
                        an .ibd file.
1661
1620
 
1662
 
                        We also determine the maximum tablespace id used. */
 
1621
                        We also determine the maximum tablespace id used.
 
1622
 
 
1623
                        TODO: We may have incomplete transactions in the
 
1624
                        data dictionary tables. Does that harm the scanning of
 
1625
                        the data dictionary below? */
1663
1626
 
1664
1627
                        dict_check_tablespaces_and_store_max_id(
1665
1628
                                recv_needed_recovery);
1666
1629
                }
1667
1630
 
1668
1631
                srv_startup_is_before_trx_rollback_phase = FALSE;
1669
 
                recv_recovery_rollback_active();
 
1632
 
 
1633
                /* Initialize the fsp free limit global variable in the log
 
1634
                system */
 
1635
                fsp_header_get_free_limit();
 
1636
 
 
1637
                /* recv_recovery_from_checkpoint_finish needs trx lists which
 
1638
                are initialized in trx_sys_init_at_db_start(). */
 
1639
 
 
1640
                recv_recovery_from_checkpoint_finish();
1670
1641
 
1671
1642
                /* It is possible that file_format tag has never
1672
1643
                been set. In this case we initialize it to minimum
1715
1686
        /* fprintf(stderr, "Max allowed record size %lu\n",
1716
1687
        page_get_free_space_of_empty() / 2); */
1717
1688
 
1718
 
        if (trx_doublewrite == NULL) {
1719
 
                /* Create the doublewrite buffer to a new tablespace */
1720
 
 
1721
 
                trx_sys_create_doublewrite_buf();
1722
 
        }
1723
 
 
1724
 
        /* Here the double write buffer has already been created and so
1725
 
        any new rollback segments will be allocated after the double
1726
 
        write buffer. The default segment should already exist.
1727
 
        We create the new segments only if it's a new database or
1728
 
        the database was shutdown cleanly. */
1729
 
 
1730
 
        /* Note: When creating the extra rollback segments during an upgrade
1731
 
        we violate the latching order, even if the change buffer is empty.
1732
 
        We make an exception in sync0sync.c and check srv_is_being_started
1733
 
        for that violation. It cannot create a deadlock because we are still
1734
 
        running in single threaded mode essentially. Only the IO threads
1735
 
        should be running at this stage. */
1736
 
 
1737
 
        trx_sys_create_rsegs(TRX_SYS_N_RSEGS - 1);
1738
 
 
1739
 
        /* Create the thread which watches the timeouts for lock waits */
1740
 
        os_thread_create(&srv_lock_timeout_thread, NULL,
 
1689
        /* Create the thread which watches the timeouts for lock waits
 
1690
        and prints InnoDB monitor info */
 
1691
 
 
1692
        os_thread_create(&srv_lock_timeout_and_monitor_thread, NULL,
1741
1693
                         thread_ids + 2 + SRV_MAX_N_IO_THREADS);
1742
1694
 
1743
1695
        /* Create the thread which warns of long semaphore waits */
1744
1696
        os_thread_create(&srv_error_monitor_thread, NULL,
1745
1697
                         thread_ids + 3 + SRV_MAX_N_IO_THREADS);
1746
 
 
1747
 
        /* Create the thread which prints InnoDB monitor info */
1748
 
        os_thread_create(&srv_monitor_thread, NULL,
1749
 
                         thread_ids + 4 + SRV_MAX_N_IO_THREADS);
1750
 
 
1751
1698
        srv_is_being_started = FALSE;
1752
1699
 
 
1700
        if (trx_doublewrite == NULL) {
 
1701
                /* Create the doublewrite buffer to a new tablespace */
 
1702
 
 
1703
                trx_sys_create_doublewrite_buf();
 
1704
        }
 
1705
 
1753
1706
        err = dict_create_or_check_foreign_constraint_tables();
1754
1707
 
1755
1708
        if (err != DB_SUCCESS) {
1761
1714
 
1762
1715
        os_thread_create(&srv_master_thread, NULL, thread_ids
1763
1716
                         + (1 + SRV_MAX_N_IO_THREADS));
1764
 
 
1765
 
        /* Currently we allow only a single purge thread. */
1766
 
        ut_a(srv_n_purge_threads == 0 || srv_n_purge_threads == 1);
1767
 
 
1768
 
        /* If the user has requested a separate purge thread then
1769
 
        start the purge thread. */
1770
 
        if (srv_n_purge_threads == 1) {
1771
 
                os_thread_create(&srv_purge_thread, NULL, NULL);
1772
 
        }
1773
 
 
1774
1717
#ifdef UNIV_DEBUG
1775
1718
        /* buf_debug_prints = TRUE; */
1776
1719
#endif /* UNIV_DEBUG */
1864
1807
        if (srv_print_verbose_log) {
1865
1808
                ut_print_timestamp(stderr);
1866
1809
                fprintf(stderr,
1867
 
                        "  InnoDB %s started; "
 
1810
                        " InnoDB Plugin %s started; "
1868
1811
                        "log sequence number %"PRIu64"\n",
1869
1812
                        INNODB_VERSION_STR, srv_start_lsn);
1870
1813
        }
1951
1894
/*=============================*/
1952
1895
{
1953
1896
        ulint   i;
 
1897
#ifdef __NETWARE__
 
1898
        extern ibool panic_shutdown;
 
1899
#endif
1954
1900
        if (!srv_was_started) {
1955
1901
                if (srv_is_being_started) {
1956
1902
                        ut_print_timestamp(stderr);
1979
1925
                        "InnoDB will do a crash recovery!\n");
1980
1926
        }
1981
1927
 
1982
 
        logs_empty_and_mark_files_at_shutdown();
 
1928
#ifdef __NETWARE__
 
1929
        if (!panic_shutdown)
 
1930
#endif
 
1931
                logs_empty_and_mark_files_at_shutdown();
1983
1932
 
1984
1933
        if (srv_conc_n_threads != 0) {
1985
1934
                fprintf(stderr,
2018
1967
                /* c. We wake the master thread so that it exits */
2019
1968
                srv_wake_master_thread();
2020
1969
 
2021
 
                /* d. We wake the purge thread so that it exits */
2022
 
                srv_wake_purge_thread();
2023
 
 
2024
 
                /* e. Exit the i/o threads */
 
1970
                /* d. Exit the i/o threads */
2025
1971
 
2026
1972
                os_aio_wake_all_threads_at_shutdown();
2027
1973
 
2031
1977
                        /* All the threads have exited or are just exiting;
2032
1978
                        NOTE that the threads may not have completed their
2033
1979
                        exit yet. Should we use pthread_join() to make sure
2034
 
                        they have exited? If we did, we would have to
2035
 
                        remove the pthread_detach() from
2036
 
                        os_thread_exit().  Now we just sleep 0.1
2037
 
                        seconds and hope that is enough! */
 
1980
                        they have exited? Now we just sleep 0.1 seconds and
 
1981
                        hope that is enough! */
2038
1982
 
2039
1983
                        os_mutex_exit(os_sync_mutex);
2040
1984
 
2073
2017
                srv_misc_tmpfile = 0;
2074
2018
        }
2075
2019
 
2076
 
        /* This must be disabled before closing the buffer pool
2077
 
        and closing the data dictionary.  */
2078
 
        btr_search_disable();
2079
 
 
2080
 
        ibuf_close();
2081
 
        log_shutdown();
2082
 
        lock_sys_close();
2083
 
        thr_local_close();
2084
2020
        trx_sys_file_format_close();
2085
 
        trx_sys_close();
2086
2021
 
2087
2022
        mutex_free(&srv_monitor_file_mutex);
2088
2023
        mutex_free(&srv_dict_tmpfile_mutex);
2089
2024
        mutex_free(&srv_misc_tmpfile_mutex);
2090
 
        dict_close();
2091
 
        btr_search_sys_free();
2092
2025
 
2093
2026
        /* 3. Free all InnoDB's own mutexes and the os_fast_mutexes inside
2094
2027
        them */
2095
 
        os_aio_free();
2096
2028
        sync_close();
 
2029
 
 
2030
        /* 4. Free the os_conc_mutex and all os_events and os_mutexes */
 
2031
 
2097
2032
        srv_free();
2098
 
        fil_close();
2099
 
 
2100
 
        /* 4. Free the os_conc_mutex and all os_events and os_mutexes */
2101
 
 
2102
2033
        os_sync_free();
2103
2034
 
2104
 
        /* 5. Free all allocated memory */
2105
 
 
2106
 
        pars_lexer_close();
2107
 
        log_mem_free();
2108
 
        buf_pool_free(srv_buf_pool_instances);
2109
 
        mem_close();
2110
 
 
2111
 
        /* ut_free_all_mem() frees all allocated memory not freed yet
2112
 
        in shutdown, and it will also free the ut_list_mutex, so it
2113
 
        should be the last one for all operation */
 
2035
        /* Check that all read views are closed except read view owned
 
2036
        by a purge. */
 
2037
 
 
2038
        if (UT_LIST_GET_LEN(trx_sys->view_list) > 1) {
 
2039
                fprintf(stderr,
 
2040
                        "InnoDB: Error: all read views were not closed"
 
2041
                        " before shutdown:\n"
 
2042
                        "InnoDB: %lu read views open \n",
 
2043
                        UT_LIST_GET_LEN(trx_sys->view_list) - 1);
 
2044
        }
 
2045
 
 
2046
        /* 5. Free all allocated memory and the os_fast_mutex created in
 
2047
        ut0mem.c */
 
2048
 
 
2049
        buf_pool_free();
2114
2050
        ut_free_all_mem();
2115
2051
 
2116
2052
        if (os_thread_count != 0
2142
2078
        }
2143
2079
 
2144
2080
        srv_was_started = FALSE;
2145
 
        srv_start_has_been_called = FALSE;
2146
2081
 
2147
2082
        return((int) DB_SUCCESS);
2148
2083
}
 
2084
 
 
2085
#ifdef __NETWARE__
 
2086
void set_panic_flag_for_netware()
 
2087
{
 
2088
        extern ibool panic_shutdown;
 
2089
        panic_shutdown = TRUE;
 
2090
}
 
2091
#endif /* __NETWARE__ */
2149
2092
#endif /* !UNIV_HOTBACKUP */