/***************************************************************************** Copyright (c) 1995, 2013, Oracle and/or its affiliates. All Rights Reserved. Copyright (c) 2009, Google Inc. Portions of this file contain modifications contributed and copyrighted by Google, Inc. Those modifications are gratefully acknowledged and are described briefly in the InnoDB documentation. The contributions by Google are incorporated with their permission, and subject to the conditions contained in the file COPYING.Google. This program is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation; version 2 of the License. This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details. You should have received a copy of the GNU General Public License along with this program; if not, write to the Free Software Foundation, Inc., 51 Franklin Street, Suite 500, Boston, MA 02110-1335 USA *****************************************************************************/ /**************************************************//** @file log/log0log.cc Database log Created 12/9/1995 Heikki Tuuri *******************************************************/ #include "config.h" #ifdef HAVE_ALLOCA_H #include "alloca.h" #elif defined(HAVE_MALLOC_H) #include "malloc.h" #endif #include "log0log.h" #ifdef UNIV_NONINL #include "log0log.ic" #endif #ifndef UNIV_HOTBACKUP #include "mem0mem.h" #include "buf0buf.h" #include "buf0flu.h" #include "srv0srv.h" #include "log0recv.h" #include "fil0fil.h" #include "dict0boot.h" #include "srv0srv.h" #include "srv0start.h" #include "trx0sys.h" #include "trx0trx.h" #include "srv0mon.h" /* General philosophy of InnoDB redo-logs: 1) Every change to a contents of a data page must be done through mtr, which in mtr_commit() writes log records to the InnoDB redo log. 2) Normally these changes are performed using a mlog_write_ulint() or similar function. 3) In some page level operations only a code number of a c-function and its parameters are written to the log to reduce the size of the log. 3a) You should not add parameters to these kind of functions (e.g. trx_undo_header_create(), trx_undo_insert_header_reuse()) 3b) You should not add such functionality which either change working when compared with the old or are dependent on data outside of the page. These kind of functions should implement self-contained page transformation and it should be unchanged if you don't have very essential reasons to change log semantics or format. */ /* Global log system variable */ UNIV_INTERN log_t* log_sys = NULL; /** Pointer to the log checksum calculation function */ UNIV_INTERN log_checksum_func_t log_checksum_algorithm_ptr = log_block_calc_checksum_innodb; /* Next log block number to do dummy record filling if no log records written for a while */ static ulint next_lbn_to_pad = 0; #ifdef UNIV_PFS_RWLOCK UNIV_INTERN mysql_pfs_key_t checkpoint_lock_key; # ifdef UNIV_LOG_ARCHIVE UNIV_INTERN mysql_pfs_key_t archive_lock_key; # endif #endif /* UNIV_PFS_RWLOCK */ #ifdef UNIV_PFS_MUTEX UNIV_INTERN mysql_pfs_key_t log_sys_mutex_key; UNIV_INTERN mysql_pfs_key_t log_flush_order_mutex_key; #endif /* UNIV_PFS_MUTEX */ #ifdef UNIV_DEBUG UNIV_INTERN ibool log_do_write = TRUE; #endif /* UNIV_DEBUG */ /* These control how often we print warnings if the last checkpoint is too old */ UNIV_INTERN ibool log_has_printed_chkp_warning = FALSE; UNIV_INTERN time_t log_last_warning_time; #ifdef UNIV_LOG_ARCHIVE /* Pointer to this variable is used as the i/o-message when we do i/o to an archive */ UNIV_INTERN byte log_archive_io; #endif /* UNIV_LOG_ARCHIVE */ UNIV_INTERN ulint log_disable_checkpoint_active= 0; /* A margin for free space in the log buffer before a log entry is catenated */ #define LOG_BUF_WRITE_MARGIN (4 * OS_FILE_LOG_BLOCK_SIZE) /* Margins for free space in the log buffer after a log entry is catenated */ #define LOG_BUF_FLUSH_RATIO 2 #define LOG_BUF_FLUSH_MARGIN (LOG_BUF_WRITE_MARGIN + 4 * UNIV_PAGE_SIZE) /* Margin for the free space in the smallest log group, before a new query step which modifies the database, is started */ #define LOG_CHECKPOINT_FREE_PER_THREAD (4 * UNIV_PAGE_SIZE) #define LOG_CHECKPOINT_EXTRA_FREE (8 * UNIV_PAGE_SIZE) /* This parameter controls asynchronous making of a new checkpoint; the value should be bigger than LOG_POOL_PREFLUSH_RATIO_SYNC */ #define LOG_POOL_CHECKPOINT_RATIO_ASYNC 32 /* This parameter controls synchronous preflushing of modified buffer pages */ #define LOG_POOL_PREFLUSH_RATIO_SYNC 16 /* The same ratio for asynchronous preflushing; this value should be less than the previous */ #define LOG_POOL_PREFLUSH_RATIO_ASYNC 8 /* Extra margin, in addition to one log file, used in archiving */ #define LOG_ARCHIVE_EXTRA_MARGIN (4 * UNIV_PAGE_SIZE) /* This parameter controls asynchronous writing to the archive */ #define LOG_ARCHIVE_RATIO_ASYNC 16 /* Codes used in unlocking flush latches */ #define LOG_UNLOCK_NONE_FLUSHED_LOCK 1 #define LOG_UNLOCK_FLUSH_LOCK 2 /* States of an archiving operation */ #define LOG_ARCHIVE_READ 1 #define LOG_ARCHIVE_WRITE 2 /******************************************************//** Completes a checkpoint write i/o to a log file. */ static void log_io_complete_checkpoint(void); /*============================*/ #ifdef UNIV_LOG_ARCHIVE /******************************************************//** Completes an archiving i/o. */ static void log_io_complete_archive(void); /*=========================*/ #endif /* UNIV_LOG_ARCHIVE */ /****************************************************************//** Returns the oldest modified block lsn in the pool, or log_sys->lsn if none exists. @return LSN of oldest modification */ static lsn_t log_buf_pool_get_oldest_modification(void) /*======================================*/ { lsn_t lsn; ut_ad(mutex_own(&(log_sys->mutex))); lsn = buf_pool_get_oldest_modification(); if (!lsn) { lsn = log_sys->lsn; } return(lsn); } /****************************************************************//** Returns the oldest modified block lsn in the pool, or log_sys->lsn if none exists. @return LSN of oldest modification */ static lsn_t log_buf_pool_get_oldest_modification_peek(void) /*===========================================*/ { lsn_t lsn; lsn = buf_pool_get_oldest_modification_peek(); if (!lsn) { lsn = log_sys->lsn; } return(lsn); } /****************************************************************//** Checks if the log groups have a big enough margin of free space in so that a new log entry can be written without overwriting log data that is not read by the changed page bitmap thread. @return TRUE if there is not enough free space. */ static ibool log_check_tracking_margin( ulint lsn_advance) /*!< in: an upper limit on how much log data we plan to write. If zero, the margin will be checked for the already-written log. */ { lsn_t tracked_lsn; lsn_t tracked_lsn_age; if (!srv_track_changed_pages) { return FALSE; } ut_ad(mutex_own(&(log_sys->mutex))); tracked_lsn = log_get_tracked_lsn(); tracked_lsn_age = log_sys->lsn - tracked_lsn; /* The overwrite would happen when log_sys->log_group_capacity is exceeded, but we use max_checkpoint_age for an extra safety margin. */ return tracked_lsn_age + lsn_advance > log_sys->max_checkpoint_age; } /** Extends the log buffer. @param[in] len requested minimum size in bytes */ static void log_buffer_extend( ulint len) { ulint move_start; ulint move_end; byte* tmp_buf = static_cast(alloca(OS_FILE_LOG_BLOCK_SIZE)); mutex_enter(&(log_sys->mutex)); while (log_sys->is_extending) { /* Another thread is trying to extend already. Needs to wait for. */ mutex_exit(&(log_sys->mutex)); log_buffer_flush_to_disk(); mutex_enter(&(log_sys->mutex)); if (srv_log_buffer_size > len / UNIV_PAGE_SIZE) { /* Already extended enough by the others */ mutex_exit(&(log_sys->mutex)); return; } } log_sys->is_extending = true; while (log_sys->n_pending_writes != 0 || ut_calc_align_down(log_sys->buf_free, OS_FILE_LOG_BLOCK_SIZE) != ut_calc_align_down(log_sys->buf_next_to_write, OS_FILE_LOG_BLOCK_SIZE)) { /* Buffer might have >1 blocks to write still. */ mutex_exit(&(log_sys->mutex)); log_buffer_flush_to_disk(); mutex_enter(&(log_sys->mutex)); } move_start = ut_calc_align_down( log_sys->buf_free, OS_FILE_LOG_BLOCK_SIZE); move_end = log_sys->buf_free; /* store the last log block in buffer */ ut_memcpy(tmp_buf, log_sys->buf + move_start, move_end - move_start); log_sys->buf_free -= move_start; log_sys->buf_next_to_write -= move_start; /* reallocate log buffer */ srv_log_buffer_size = len / UNIV_PAGE_SIZE + 1; mem_free(log_sys->buf_ptr); log_sys->buf_ptr = static_cast( mem_zalloc(LOG_BUFFER_SIZE + OS_FILE_LOG_BLOCK_SIZE)); log_sys->buf = static_cast( ut_align(log_sys->buf_ptr, OS_FILE_LOG_BLOCK_SIZE)); log_sys->buf_size = LOG_BUFFER_SIZE; log_sys->max_buf_free = log_sys->buf_size / LOG_BUF_FLUSH_RATIO - LOG_BUF_FLUSH_MARGIN; /* restore the last log block */ ut_memcpy(log_sys->buf, tmp_buf, move_end - move_start); ut_ad(log_sys->is_extending); log_sys->is_extending = false; mutex_exit(&(log_sys->mutex)); ib_logf(IB_LOG_LEVEL_INFO, "innodb_log_buffer_size was extended to %lu.", LOG_BUFFER_SIZE); } /************************************************************//** Opens the log for log_write_low. The log must be closed with log_close. @return start lsn of the log record */ UNIV_INTERN lsn_t log_open( /*=====*/ ulint len) /*!< in: length of data to be catenated */ { log_t* log = log_sys; ulint len_upper_limit; #ifdef UNIV_LOG_ARCHIVE ulint archived_lsn_age; ulint dummy; #endif /* UNIV_LOG_ARCHIVE */ ulint count = 0; ulint tcount = 0; if (len >= log->buf_size / 2) { DBUG_EXECUTE_IF("ib_log_buffer_is_short_crash", DBUG_SUICIDE();); /* log_buffer is too small. try to extend instead of crash. */ ib_logf(IB_LOG_LEVEL_WARN, "The transaction log size is too large" " for innodb_log_buffer_size (%lu >= %lu / 2). " "Trying to extend it.", len, LOG_BUFFER_SIZE); log_buffer_extend((len + 1) * 2); } loop: ut_ad(!recv_no_log_write); if (log->is_extending) { mutex_exit(&(log->mutex)); /* Log buffer size is extending. Writing up to the next block should wait for the extending finished. */ os_thread_sleep(100000); ut_ad(++count < 50); goto loop; } /* Calculate an upper limit for the space the string may take in the log buffer */ len_upper_limit = LOG_BUF_WRITE_MARGIN + (5 * len) / 4; if (log->buf_free + len_upper_limit > log->buf_size) { mutex_exit(&(log->mutex)); /* Not enough free space, do a syncronous flush of the log buffer */ log_buffer_flush_to_disk(); srv_stats.log_waits.inc(); ut_ad(++count < 50); mutex_enter(&(log->mutex)); goto loop; } #ifdef UNIV_LOG_ARCHIVE if (log->archiving_state != LOG_ARCH_OFF) { archived_lsn_age = log->lsn - log->archived_lsn; if (archived_lsn_age + len_upper_limit > log->max_archived_lsn_age) { /* Not enough free archived space in log groups: do a synchronous archive write batch: */ mutex_exit(&(log->mutex)); ut_ad(len_upper_limit <= log->max_archived_lsn_age); log_archive_do(TRUE, &dummy); ut_ad(++count < 50); mutex_enter(&(log->mutex)); goto loop; } } #endif /* UNIV_LOG_ARCHIVE */ if (log_check_tracking_margin(len_upper_limit) && (++tcount + count < 50)) { /* This log write would violate the untracked LSN free space margin. Limit this to 50 retries as there might be situations where we have no choice but to proceed anyway, i.e. if the log is about to be overflown, log tracking or not. */ mutex_exit(&(log->mutex)); os_thread_sleep(10000); mutex_enter(&(log->mutex)); goto loop; } #ifdef UNIV_LOG_DEBUG log->old_buf_free = log->buf_free; log->old_lsn = log->lsn; #endif return(log->lsn); } /************************************************************//** Writes to the log the string given. It is assumed that the caller holds the log mutex. */ UNIV_INTERN void log_write_low( /*==========*/ byte* str, /*!< in: string */ ulint str_len) /*!< in: string length */ { log_t* log = log_sys; ulint len; ulint data_len; byte* log_block; ut_ad(mutex_own(&(log->mutex))); part_loop: ut_ad(!recv_no_log_write); /* Calculate a part length */ data_len = (log->buf_free % OS_FILE_LOG_BLOCK_SIZE) + str_len; if (data_len <= OS_FILE_LOG_BLOCK_SIZE - LOG_BLOCK_TRL_SIZE) { /* The string fits within the current log block */ len = str_len; } else { data_len = OS_FILE_LOG_BLOCK_SIZE - LOG_BLOCK_TRL_SIZE; len = OS_FILE_LOG_BLOCK_SIZE - (log->buf_free % OS_FILE_LOG_BLOCK_SIZE) - LOG_BLOCK_TRL_SIZE; } ut_memcpy(log->buf + log->buf_free, str, len); str_len -= len; str = str + len; log_block = static_cast( ut_align_down( log->buf + log->buf_free, OS_FILE_LOG_BLOCK_SIZE)); log_block_set_data_len(log_block, data_len); if (data_len == OS_FILE_LOG_BLOCK_SIZE - LOG_BLOCK_TRL_SIZE) { /* This block became full */ log_block_set_data_len(log_block, OS_FILE_LOG_BLOCK_SIZE); log_block_set_checkpoint_no(log_block, log_sys->next_checkpoint_no); len += LOG_BLOCK_HDR_SIZE + LOG_BLOCK_TRL_SIZE; log->lsn += len; /* Initialize the next block header */ log_block_init(log_block + OS_FILE_LOG_BLOCK_SIZE, log->lsn); } else { log->lsn += len; } log->buf_free += len; ut_ad(log->buf_free <= log->buf_size); if (str_len > 0) { goto part_loop; } srv_stats.log_write_requests.inc(); } /************************************************************//** Closes the log. @return lsn */ UNIV_INTERN lsn_t log_close(void) /*===========*/ { byte* log_block; ulint first_rec_group; lsn_t oldest_lsn; lsn_t lsn; lsn_t tracked_lsn; lsn_t tracked_lsn_age; log_t* log = log_sys; lsn_t checkpoint_age; ut_ad(mutex_own(&(log->mutex))); ut_ad(!recv_no_log_write); lsn = log->lsn; log_block = static_cast( ut_align_down( log->buf + log->buf_free, OS_FILE_LOG_BLOCK_SIZE)); first_rec_group = log_block_get_first_rec_group(log_block); if (first_rec_group == 0) { /* We initialized a new log block which was not written full by the current mtr: the next mtr log record group will start within this block at the offset data_len */ log_block_set_first_rec_group( log_block, log_block_get_data_len(log_block)); } if (log->buf_free > log->max_buf_free) { log->check_flush_or_checkpoint = TRUE; } if (srv_track_changed_pages) { tracked_lsn = log_get_tracked_lsn(); tracked_lsn_age = lsn - tracked_lsn; if (tracked_lsn_age >= log->log_group_capacity) { fprintf(stderr, "InnoDB: Error: the age of the " "oldest untracked record exceeds the log " "group capacity!\n"); fprintf(stderr, "InnoDB: Error: stopping the log " "tracking thread at LSN " LSN_PF "\n", tracked_lsn); srv_track_changed_pages = FALSE; } } checkpoint_age = lsn - log->last_checkpoint_lsn; if (checkpoint_age >= log->log_group_capacity) { /* TODO: split btr_store_big_rec_extern_fields() into small steps so that we can release all latches in the middle, and call log_free_check() to ensure we never write over log written after the latest checkpoint. In principle, we should split all big_rec operations, but other operations are smaller. */ if (!log_has_printed_chkp_warning || difftime(time(NULL), log_last_warning_time) > 15) { log_has_printed_chkp_warning = TRUE; log_last_warning_time = time(NULL); ut_print_timestamp(stderr); fprintf(stderr, " InnoDB: ERROR: the age of the last" " checkpoint is " LSN_PF ",\n" "InnoDB: which exceeds the log group" " capacity " LSN_PF ".\n" "InnoDB: If you are using big" " BLOB or TEXT rows, you must set the\n" "InnoDB: combined size of log files" " at least 10 times bigger than the\n" "InnoDB: largest such row.\n", checkpoint_age, log->log_group_capacity); } } if (checkpoint_age <= log->max_modified_age_sync) { goto function_exit; } oldest_lsn = buf_pool_get_oldest_modification(); if (!oldest_lsn || lsn - oldest_lsn > log->max_modified_age_sync || checkpoint_age > log->max_checkpoint_age_async) { log->check_flush_or_checkpoint = TRUE; } function_exit: #ifdef UNIV_LOG_DEBUG log_check_log_recs(log->buf + log->old_buf_free, log->buf_free - log->old_buf_free, log->old_lsn); #endif return(lsn); } /******************************************************//** Pads the current log block full with dummy log records. Used in producing consistent archived log files and scrubbing redo log. */ static void log_pad_current_log_block(void) /*===========================*/ { byte b = MLOG_DUMMY_RECORD; ulint pad_length; ulint i; lsn_t lsn; /* We retrieve lsn only because otherwise gcc crashed on HP-UX */ lsn = log_reserve_and_open(OS_FILE_LOG_BLOCK_SIZE); pad_length = OS_FILE_LOG_BLOCK_SIZE - (log_sys->buf_free % OS_FILE_LOG_BLOCK_SIZE) - LOG_BLOCK_TRL_SIZE; if (pad_length == (OS_FILE_LOG_BLOCK_SIZE - LOG_BLOCK_HDR_SIZE - LOG_BLOCK_TRL_SIZE)) { pad_length = 0; } for (i = 0; i < pad_length; i++) { log_write_low(&b, 1); } lsn = log_sys->lsn; log_close(); log_release(); ut_a(lsn % OS_FILE_LOG_BLOCK_SIZE == LOG_BLOCK_HDR_SIZE); } /******************************************************//** Calculates the data capacity of a log group, when the log file headers are not included. @return capacity in bytes */ UNIV_INTERN lsn_t log_group_get_capacity( /*===================*/ const log_group_t* group) /*!< in: log group */ { ut_ad(mutex_own(&(log_sys->mutex))); return((group->file_size - LOG_FILE_HDR_SIZE) * group->n_files); } /******************************************************//** Calculates the offset within a log group, when the log file headers are not included. @return size offset (<= offset) */ UNIV_INLINE lsn_t log_group_calc_size_offset( /*=======================*/ lsn_t offset, /*!< in: real offset within the log group */ const log_group_t* group) /*!< in: log group */ { ut_ad(mutex_own(&(log_sys->mutex))); return(offset - LOG_FILE_HDR_SIZE * (1 + offset / group->file_size)); } /******************************************************//** Calculates the offset within a log group, when the log file headers are included. @return real offset (>= offset) */ UNIV_INLINE lsn_t log_group_calc_real_offset( /*=======================*/ lsn_t offset, /*!< in: size offset within the log group */ const log_group_t* group) /*!< in: log group */ { ut_ad(mutex_own(&(log_sys->mutex))); return(offset + LOG_FILE_HDR_SIZE * (1 + offset / (group->file_size - LOG_FILE_HDR_SIZE))); } /******************************************************//** Calculates the offset of an lsn within a log group. @return offset within the log group */ static lsn_t log_group_calc_lsn_offset( /*======================*/ lsn_t lsn, /*!< in: lsn */ const log_group_t* group) /*!< in: log group */ { lsn_t gr_lsn; lsn_t gr_lsn_size_offset; lsn_t difference; lsn_t group_size; lsn_t offset; ut_ad(mutex_own(&(log_sys->mutex))); gr_lsn = group->lsn; gr_lsn_size_offset = log_group_calc_size_offset(group->lsn_offset, group); group_size = log_group_get_capacity(group); if (lsn >= gr_lsn) { difference = lsn - gr_lsn; } else { difference = gr_lsn - lsn; difference = difference % group_size; difference = group_size - difference; } offset = (gr_lsn_size_offset + difference) % group_size; /* fprintf(stderr, "Offset is " LSN_PF " gr_lsn_offset is " LSN_PF " difference is " LSN_PF "\n", offset, gr_lsn_size_offset, difference); */ return(log_group_calc_real_offset(offset, group)); } #endif /* !UNIV_HOTBACKUP */ #ifdef UNIV_DEBUG UNIV_INTERN ibool log_debug_writes = FALSE; #endif /* UNIV_DEBUG */ /*******************************************************************//** Calculates where in log files we find a specified lsn. @return log file number */ UNIV_INTERN ulint log_calc_where_lsn_is( /*==================*/ ib_int64_t* log_file_offset, /*!< out: offset in that file (including the header) */ ib_uint64_t first_header_lsn, /*!< in: first log file start lsn */ ib_uint64_t lsn, /*!< in: lsn whose position to determine */ ulint n_log_files, /*!< in: total number of log files */ ib_int64_t log_file_size) /*!< in: log file size (including the header) */ { ib_int64_t capacity = log_file_size - LOG_FILE_HDR_SIZE; ulint file_no; ib_int64_t add_this_many; if (lsn < first_header_lsn) { add_this_many = 1 + (first_header_lsn - lsn) / (capacity * (ib_int64_t) n_log_files); lsn += add_this_many * capacity * (ib_int64_t) n_log_files; } ut_a(lsn >= first_header_lsn); file_no = ((ulint)((lsn - first_header_lsn) / capacity)) % n_log_files; *log_file_offset = (lsn - first_header_lsn) % capacity; *log_file_offset = *log_file_offset + LOG_FILE_HDR_SIZE; return(file_no); } #ifndef UNIV_HOTBACKUP /********************************************************//** Sets the field values in group to correspond to a given lsn. For this function to work, the values must already be correctly initialized to correspond to some lsn, for instance, a checkpoint lsn. */ UNIV_INTERN void log_group_set_fields( /*=================*/ log_group_t* group, /*!< in/out: group */ lsn_t lsn) /*!< in: lsn for which the values should be set */ { group->lsn_offset = log_group_calc_lsn_offset(lsn, group); group->lsn = lsn; } /*****************************************************************//** Calculates the recommended highest values for lsn - last_checkpoint_lsn, lsn - buf_get_oldest_modification(), and lsn - max_archive_lsn_age. @return error value FALSE if the smallest log group is too small to accommodate the number of OS threads in the database server */ static ibool log_calc_max_ages(void) /*===================*/ { log_group_t* group; lsn_t margin; ulint free; ibool success = TRUE; lsn_t smallest_capacity; lsn_t archive_margin; lsn_t smallest_archive_margin; mutex_enter(&(log_sys->mutex)); group = UT_LIST_GET_FIRST(log_sys->log_groups); ut_ad(group); smallest_capacity = LSN_MAX; smallest_archive_margin = LSN_MAX; while (group) { if (log_group_get_capacity(group) < smallest_capacity) { smallest_capacity = log_group_get_capacity(group); } archive_margin = log_group_get_capacity(group) - (group->file_size - LOG_FILE_HDR_SIZE) - LOG_ARCHIVE_EXTRA_MARGIN; if (archive_margin < smallest_archive_margin) { smallest_archive_margin = archive_margin; } group = UT_LIST_GET_NEXT(log_groups, group); } /* Add extra safety */ smallest_capacity = smallest_capacity - smallest_capacity / 10; /* For each OS thread we must reserve so much free space in the smallest log group that it can accommodate the log entries produced by single query steps: running out of free log space is a serious system error which requires rebooting the database. */ free = LOG_CHECKPOINT_FREE_PER_THREAD * (10 + srv_thread_concurrency) + LOG_CHECKPOINT_EXTRA_FREE; if (free >= smallest_capacity / 2) { success = FALSE; goto failure; } else { margin = smallest_capacity - free; } margin = margin - margin / 10; /* Add still some extra safety */ log_sys->log_group_capacity = smallest_capacity; log_sys->max_modified_age_async = margin - margin / LOG_POOL_PREFLUSH_RATIO_ASYNC; log_sys->max_modified_age_sync = margin - margin / LOG_POOL_PREFLUSH_RATIO_SYNC; log_sys->max_checkpoint_age_async = margin - margin / LOG_POOL_CHECKPOINT_RATIO_ASYNC; log_sys->max_checkpoint_age = margin; #ifdef UNIV_LOG_ARCHIVE log_sys->max_archived_lsn_age = smallest_archive_margin; log_sys->max_archived_lsn_age_async = smallest_archive_margin - smallest_archive_margin / LOG_ARCHIVE_RATIO_ASYNC; #endif /* UNIV_LOG_ARCHIVE */ failure: mutex_exit(&(log_sys->mutex)); if (!success) { fprintf(stderr, "InnoDB: Error: ib_logfiles are too small" " for innodb_thread_concurrency %lu.\n" "InnoDB: The combined size of ib_logfiles" " should be bigger than\n" "InnoDB: 200 kB * innodb_thread_concurrency.\n" "InnoDB: To get mysqld to start up, set" " innodb_thread_concurrency in my.cnf\n" "InnoDB: to a lower value, for example, to 8." " After an ERROR-FREE shutdown\n" "InnoDB: of mysqld you can adjust the size of" " ib_logfiles, as explained in\n" "InnoDB: " REFMAN "adding-and-removing.html\n" "InnoDB: Cannot continue operation." " Calling exit(1).\n", (ulong) srv_thread_concurrency); exit(1); } return(success); } /******************************************************//** Initializes the log. */ UNIV_INTERN void log_init(void) /*==========*/ { log_sys = static_cast(mem_alloc(sizeof(log_t))); mutex_create(log_sys_mutex_key, &log_sys->mutex, SYNC_LOG); mutex_create(log_flush_order_mutex_key, &log_sys->log_flush_order_mutex, SYNC_LOG_FLUSH_ORDER); mutex_enter(&(log_sys->mutex)); /* Start the lsn from one log block from zero: this way every log record has a start lsn != zero, a fact which we will use */ log_sys->lsn = LOG_START_LSN; ut_a(LOG_BUFFER_SIZE >= 16 * OS_FILE_LOG_BLOCK_SIZE); ut_a(LOG_BUFFER_SIZE >= 4 * UNIV_PAGE_SIZE); log_sys->buf_ptr = static_cast( mem_zalloc(LOG_BUFFER_SIZE + OS_FILE_LOG_BLOCK_SIZE)); log_sys->buf = static_cast( ut_align(log_sys->buf_ptr, OS_FILE_LOG_BLOCK_SIZE)); log_sys->buf_size = LOG_BUFFER_SIZE; log_sys->is_extending = false; log_sys->max_buf_free = log_sys->buf_size / LOG_BUF_FLUSH_RATIO - LOG_BUF_FLUSH_MARGIN; log_sys->check_flush_or_checkpoint = TRUE; UT_LIST_INIT(log_sys->log_groups); log_sys->n_log_ios = 0; log_sys->n_log_ios_old = log_sys->n_log_ios; log_sys->last_printout_time = time(NULL); /*----------------------------*/ log_sys->buf_next_to_write = 0; log_sys->write_lsn = 0; log_sys->current_flush_lsn = 0; log_sys->flushed_to_disk_lsn = 0; log_sys->written_to_some_lsn = log_sys->lsn; log_sys->written_to_all_lsn = log_sys->lsn; log_sys->n_pending_writes = 0; log_sys->no_flush_event = os_event_create(); os_event_set(log_sys->no_flush_event); log_sys->one_flushed_event = os_event_create(); os_event_set(log_sys->one_flushed_event); /*----------------------------*/ log_sys->next_checkpoint_no = 0; log_sys->redo_log_crypt_ver = UNENCRYPTED_KEY_VER; log_sys->last_checkpoint_lsn = log_sys->lsn; log_sys->n_pending_checkpoint_writes = 0; rw_lock_create(checkpoint_lock_key, &log_sys->checkpoint_lock, SYNC_NO_ORDER_CHECK); log_sys->checkpoint_buf_ptr = static_cast( mem_zalloc(2 * OS_FILE_LOG_BLOCK_SIZE)); log_sys->checkpoint_buf = static_cast( ut_align(log_sys->checkpoint_buf_ptr, OS_FILE_LOG_BLOCK_SIZE)); /*----------------------------*/ #ifdef UNIV_LOG_ARCHIVE /* Under MySQL, log archiving is always off */ log_sys->archiving_state = LOG_ARCH_OFF; log_sys->archived_lsn = log_sys->lsn; log_sys->next_archived_lsn = 0; log_sys->n_pending_archive_ios = 0; rw_lock_create(archive_lock_key, &log_sys->archive_lock, SYNC_NO_ORDER_CHECK); log_sys->archive_buf_ptr = static_cast( mem_zalloc(LOG_ARCHIVE_BUF_SIZE + OS_FILE_LOG_BLOCK_SIZE)); log_sys->archive_buf = static_cast( ut_align(log_sys->archive_buf_ptr, OS_FILE_LOG_BLOCK_SIZE)); log_sys->archive_buf_size = LOG_ARCHIVE_BUF_SIZE; log_sys->archiving_on = os_event_create(); #endif /* UNIV_LOG_ARCHIVE */ log_sys->tracked_lsn = 0; /*----------------------------*/ log_block_init(log_sys->buf, log_sys->lsn); log_block_set_first_rec_group(log_sys->buf, LOG_BLOCK_HDR_SIZE); log_sys->buf_free = LOG_BLOCK_HDR_SIZE; log_sys->lsn = LOG_START_LSN + LOG_BLOCK_HDR_SIZE; // TODO(minliz): ensure various LOG_START_LSN? MONITOR_SET(MONITOR_LSN_CHECKPOINT_AGE, log_sys->lsn - log_sys->last_checkpoint_lsn); mutex_exit(&(log_sys->mutex)); #ifdef UNIV_LOG_DEBUG recv_sys_create(); recv_sys_init(buf_pool_get_curr_size()); recv_sys->parse_start_lsn = log_sys->lsn; recv_sys->scanned_lsn = log_sys->lsn; recv_sys->scanned_checkpoint_no = 0; recv_sys->recovered_lsn = log_sys->lsn; recv_sys->limit_lsn = LSN_MAX; #endif } /******************************************************************//** Inits a log group to the log system. */ UNIV_INTERN void log_group_init( /*===========*/ ulint id, /*!< in: group id */ ulint n_files, /*!< in: number of log files */ lsn_t file_size, /*!< in: log file size in bytes */ ulint space_id, /*!< in: space id of the file space which contains the log files of this group */ ulint archive_space_id __attribute__((unused))) /*!< in: space id of the file space which contains some archived log files for this group; currently, only for the first log group this is used */ { ulint i; log_group_t* group; group = static_cast(mem_alloc(sizeof(log_group_t))); group->id = id; group->n_files = n_files; group->file_size = file_size; group->space_id = space_id; group->state = LOG_GROUP_OK; group->lsn = LOG_START_LSN; group->lsn_offset = LOG_FILE_HDR_SIZE; group->n_pending_writes = 0; group->file_header_bufs_ptr = static_cast( mem_zalloc(sizeof(byte*) * n_files)); group->file_header_bufs = static_cast( mem_zalloc(sizeof(byte**) * n_files)); #ifdef UNIV_LOG_ARCHIVE group->archive_file_header_bufs_ptr = static_cast( mem_zalloc( sizeof(byte*) * n_files)); group->archive_file_header_bufs = static_cast( mem_zalloc(sizeof(byte*) * n_files)); #endif /* UNIV_LOG_ARCHIVE */ for (i = 0; i < n_files; i++) { group->file_header_bufs_ptr[i] = static_cast( mem_zalloc(LOG_FILE_HDR_SIZE + OS_FILE_LOG_BLOCK_SIZE)); group->file_header_bufs[i] = static_cast( ut_align(group->file_header_bufs_ptr[i], OS_FILE_LOG_BLOCK_SIZE)); #ifdef UNIV_LOG_ARCHIVE group->archive_file_header_bufs_ptr[i] = static_cast( mem_zalloc(LOG_FILE_HDR_SIZE + OS_FILE_LOG_BLOCK_SIZE)); group->archive_file_header_bufs[i] = static_cast( ut_align(group->archive_file_header_bufs_ptr[i], OS_FILE_LOG_BLOCK_SIZE)); #endif /* UNIV_LOG_ARCHIVE */ } #ifdef UNIV_LOG_ARCHIVE group->archive_space_id = archive_space_id; group->archived_file_no = LOG_START_LSN; group->archived_offset = 0; #endif /* UNIV_LOG_ARCHIVE */ group->checkpoint_buf_ptr = static_cast( mem_zalloc(2 * OS_FILE_LOG_BLOCK_SIZE)); group->checkpoint_buf = static_cast( ut_align(group->checkpoint_buf_ptr,OS_FILE_LOG_BLOCK_SIZE)); UT_LIST_ADD_LAST(log_groups, log_sys->log_groups, group); ut_a(log_calc_max_ages()); } /******************************************************************//** Does the unlockings needed in flush i/o completion. */ UNIV_INLINE void log_flush_do_unlocks( /*=================*/ ulint code) /*!< in: any ORed combination of LOG_UNLOCK_FLUSH_LOCK and LOG_UNLOCK_NONE_FLUSHED_LOCK */ { ut_ad(mutex_own(&(log_sys->mutex))); /* NOTE that we must own the log mutex when doing the setting of the events: this is because transactions will wait for these events to be set, and at that moment the log flush they were waiting for must have ended. If the log mutex were not reserved here, the i/o-thread calling this function might be preempted for a while, and when it resumed execution, it might be that a new flush had been started, and this function would erroneously signal the NEW flush as completed. Thus, the changes in the state of these events are performed atomically in conjunction with the changes in the state of log_sys->n_pending_writes etc. */ if (code & LOG_UNLOCK_NONE_FLUSHED_LOCK) { os_event_set(log_sys->one_flushed_event); } if (code & LOG_UNLOCK_FLUSH_LOCK) { os_event_set(log_sys->no_flush_event); } } /******************************************************************//** Checks if a flush is completed for a log group and does the completion routine if yes. @return LOG_UNLOCK_NONE_FLUSHED_LOCK or 0 */ UNIV_INLINE ulint log_group_check_flush_completion( /*=============================*/ log_group_t* group) /*!< in: log group */ { ut_ad(mutex_own(&(log_sys->mutex))); if (!log_sys->one_flushed && group->n_pending_writes == 0) { #ifdef UNIV_DEBUG if (log_debug_writes) { fprintf(stderr, "Log flushed first to group %lu\n", (ulong) group->id); } #endif /* UNIV_DEBUG */ log_sys->written_to_some_lsn = log_sys->write_lsn; log_sys->one_flushed = TRUE; return(LOG_UNLOCK_NONE_FLUSHED_LOCK); } #ifdef UNIV_DEBUG if (log_debug_writes && (group->n_pending_writes == 0)) { fprintf(stderr, "Log flushed to group %lu\n", (ulong) group->id); } #endif /* UNIV_DEBUG */ return(0); } /******************************************************//** Checks if a flush is completed and does the completion routine if yes. @return LOG_UNLOCK_FLUSH_LOCK or 0 */ static ulint log_sys_check_flush_completion(void) /*================================*/ { ulint move_start; ulint move_end; ut_ad(mutex_own(&(log_sys->mutex))); if (log_sys->n_pending_writes == 0) { log_sys->written_to_all_lsn = log_sys->write_lsn; log_sys->buf_next_to_write = log_sys->write_end_offset; if (log_sys->write_end_offset > log_sys->max_buf_free / 2) { /* Move the log buffer content to the start of the buffer */ move_start = ut_calc_align_down( log_sys->write_end_offset, OS_FILE_LOG_BLOCK_SIZE); move_end = ut_calc_align(log_sys->buf_free, OS_FILE_LOG_BLOCK_SIZE); ut_memmove(log_sys->buf, log_sys->buf + move_start, move_end - move_start); log_sys->buf_free -= move_start; log_sys->buf_next_to_write -= move_start; } return(LOG_UNLOCK_FLUSH_LOCK); } return(0); } /******************************************************//** Completes an i/o to a log file. */ UNIV_INTERN void log_io_complete( /*============*/ log_group_t* group) /*!< in: log group or a dummy pointer */ { ulint unlock; #ifdef UNIV_LOG_ARCHIVE if ((byte*) group == &log_archive_io) { /* It was an archive write */ log_io_complete_archive(); return; } #endif /* UNIV_LOG_ARCHIVE */ if ((ulint) group & 0x1UL) { /* It was a checkpoint write */ group = (log_group_t*)((ulint) group - 1); if (srv_unix_file_flush_method != SRV_UNIX_O_DSYNC && srv_unix_file_flush_method != SRV_UNIX_ALL_O_DIRECT && srv_unix_file_flush_method != SRV_UNIX_NOSYNC) { fil_flush(group->space_id); } #ifdef UNIV_DEBUG if (log_debug_writes) { fprintf(stderr, "Checkpoint info written to group %lu\n", group->id); } #endif /* UNIV_DEBUG */ log_io_complete_checkpoint(); return; } ut_error; /*!< We currently use synchronous writing of the logs and cannot end up here! */ if (srv_unix_file_flush_method != SRV_UNIX_O_DSYNC && srv_unix_file_flush_method != SRV_UNIX_ALL_O_DIRECT && srv_unix_file_flush_method != SRV_UNIX_NOSYNC && thd_flush_log_at_trx_commit(NULL) != 2) { fil_flush(group->space_id); } mutex_enter(&(log_sys->mutex)); ut_ad(!recv_no_log_write); ut_a(group->n_pending_writes > 0); ut_a(log_sys->n_pending_writes > 0); group->n_pending_writes--; log_sys->n_pending_writes--; MONITOR_DEC(MONITOR_PENDING_LOG_WRITE); unlock = log_group_check_flush_completion(group); unlock = unlock | log_sys_check_flush_completion(); log_flush_do_unlocks(unlock); mutex_exit(&(log_sys->mutex)); } /******************************************************//** Writes a log file header to a log file space. */ static void log_group_file_header_flush( /*========================*/ log_group_t* group, /*!< in: log group */ ulint nth_file, /*!< in: header to the nth file in the log file space */ lsn_t start_lsn) /*!< in: log file data starts at this lsn */ { byte* buf; lsn_t dest_offset; ut_ad(mutex_own(&(log_sys->mutex))); ut_ad(!recv_no_log_write); ut_a(nth_file < group->n_files); buf = *(group->file_header_bufs + nth_file); mach_write_to_4(buf + LOG_GROUP_ID, group->id); mach_write_to_8(buf + LOG_FILE_START_LSN, start_lsn); /* Wipe over possible label of mysqlbackup --restore */ memcpy(buf + LOG_FILE_WAS_CREATED_BY_HOT_BACKUP, " ", 4); mach_write_to_4(buf + LOG_FILE_OS_FILE_LOG_BLOCK_SIZE, srv_log_block_size); dest_offset = nth_file * group->file_size; #ifdef UNIV_DEBUG if (log_debug_writes) { fprintf(stderr, "Writing log file header to group %lu file %lu\n", (ulong) group->id, (ulong) nth_file); } #endif /* UNIV_DEBUG */ if (log_do_write) { log_sys->n_log_ios++; MONITOR_INC(MONITOR_LOG_IO); srv_stats.os_log_pending_writes.inc(); fil_io(OS_FILE_WRITE | OS_FILE_LOG, true, group->space_id, 0, (ulint) (dest_offset / UNIV_PAGE_SIZE), (ulint) (dest_offset % UNIV_PAGE_SIZE), OS_FILE_LOG_BLOCK_SIZE, buf, group, 0); srv_stats.os_log_pending_writes.dec(); } } /******************************************************//** Stores a 4-byte checksum to the trailer checksum field of a log block before writing it to a log file. This checksum is used in recovery to check the consistency of a log block. */ static void log_block_store_checksum( /*=====================*/ byte* block) /*!< in/out: pointer to a log block */ { log_block_set_checksum(block, log_block_calc_checksum(block)); } /******************************************************//** Encrypt one or more log block before it is flushed to disk @return true if encryption succeeds. */ static bool log_group_encrypt_before_write( /*===========================*/ const log_group_t* group, /*!< in: log group to be flushed */ byte* block, /*!< in/out: pointer to a log block */ const ulint size) /*!< in: size of log blocks */ { Crypt_result result = AES_OK; ut_ad(size % OS_FILE_LOG_BLOCK_SIZE == 0); byte* dst_frame = (byte*)malloc(size); //encrypt log blocks content result = log_blocks_encrypt(block, size, dst_frame); if (result == AES_OK) { ut_ad(block[0] == dst_frame[0]); memcpy(block, dst_frame, size); } free(dst_frame); return (result == AES_OK); } /******************************************************//** Writes a buffer to a log file group. */ UNIV_INTERN void log_group_write_buf( /*================*/ log_group_t* group, /*!< in: log group */ byte* buf, /*!< in: buffer */ ulint len, /*!< in: buffer len; must be divisible by OS_FILE_LOG_BLOCK_SIZE */ lsn_t start_lsn, /*!< in: start lsn of the buffer; must be divisible by OS_FILE_LOG_BLOCK_SIZE */ ulint new_data_offset)/*!< in: start offset of new data in buf: this parameter is used to decide if we have to write a new log file header */ { ulint write_len; ibool write_header; lsn_t next_offset; ulint i; ut_ad(mutex_own(&(log_sys->mutex))); ut_ad(!recv_no_log_write); ut_a(len % OS_FILE_LOG_BLOCK_SIZE == 0); ut_a(start_lsn % OS_FILE_LOG_BLOCK_SIZE == 0); if (new_data_offset == 0) { write_header = TRUE; } else { write_header = FALSE; } loop: if (len == 0) { return; } next_offset = log_group_calc_lsn_offset(start_lsn, group); if ((next_offset % group->file_size == LOG_FILE_HDR_SIZE) && write_header) { /* We start to write a new log file instance in the group */ ut_a(next_offset / group->file_size <= ULINT_MAX); log_group_file_header_flush(group, (ulint) (next_offset / group->file_size), start_lsn); srv_stats.os_log_written.add(OS_FILE_LOG_BLOCK_SIZE); srv_stats.log_writes.inc(); } if ((next_offset % group->file_size) + len > group->file_size) { /* if the above condition holds, then the below expression is < len which is ulint, so the typecast is ok */ write_len = (ulint) (group->file_size - (next_offset % group->file_size)); } else { write_len = len; } #ifdef UNIV_DEBUG if (log_debug_writes) { fprintf(stderr, "Writing log file segment to group %lu" " offset " LSN_PF " len %lu\n" "start lsn " LSN_PF "\n" "First block n:o %lu last block n:o %lu\n", (ulong) group->id, next_offset, write_len, start_lsn, (ulong) log_block_get_hdr_no(buf), (ulong) log_block_get_hdr_no( buf + write_len - OS_FILE_LOG_BLOCK_SIZE)); ut_a(log_block_get_hdr_no(buf) == log_block_convert_lsn_to_no(start_lsn)); for (i = 0; i < write_len / OS_FILE_LOG_BLOCK_SIZE; i++) { ut_a(log_block_get_hdr_no(buf) + i == log_block_get_hdr_no( buf + i * OS_FILE_LOG_BLOCK_SIZE)); } } #endif /* UNIV_DEBUG */ /* Calculate the checksums for each log block and write them to the trailer fields of the log blocks */ for (i = 0; i < write_len / OS_FILE_LOG_BLOCK_SIZE; i++) { log_block_store_checksum(buf + i * OS_FILE_LOG_BLOCK_SIZE); } if (log_do_write) { log_sys->n_log_ios++; MONITOR_INC(MONITOR_LOG_IO); srv_stats.os_log_pending_writes.inc(); ut_a(next_offset / UNIV_PAGE_SIZE <= ULINT_MAX); if (srv_encrypt_log && log_sys->redo_log_crypt_ver != UNENCRYPTED_KEY_VER && !log_group_encrypt_before_write(group, buf, write_len)) { fprintf(stderr, "\nInnodb redo log encryption failed.\n"); abort(); } fil_io(OS_FILE_WRITE | OS_FILE_LOG, true, group->space_id, 0, (ulint) (next_offset / UNIV_PAGE_SIZE), (ulint) (next_offset % UNIV_PAGE_SIZE), write_len, buf, group, 0); srv_stats.os_log_pending_writes.dec(); srv_stats.os_log_written.add(write_len); srv_stats.log_writes.inc(); } if (write_len < len) { start_lsn += write_len; len -= write_len; buf += write_len; write_header = TRUE; goto loop; } } /******************************************************//** This function is called, e.g., when a transaction wants to commit. It checks that the log has been written to the log file up to the last log entry written by the transaction. If there is a flush running, it waits and checks if the flush flushed enough. If not, starts a new flush. */ UNIV_INTERN void log_write_up_to( /*============*/ lsn_t lsn, /*!< in: log sequence number up to which the log should be written, LSN_MAX if not specified */ ulint wait, /*!< in: LOG_NO_WAIT, LOG_WAIT_ONE_GROUP, or LOG_WAIT_ALL_GROUPS */ ibool flush_to_disk) /*!< in: TRUE if we want the written log also to be flushed to disk */ { log_group_t* group; ulint start_offset; ulint end_offset; ulint area_start; ulint area_end; #ifdef UNIV_DEBUG ulint loop_count = 0; #endif /* UNIV_DEBUG */ ulint unlock; ib_uint64_t write_lsn; ib_uint64_t flush_lsn; ut_ad(!srv_read_only_mode); if (recv_no_ibuf_operations) { /* Recovery is running and no operations on the log files are allowed yet (the variable name .._no_ibuf_.. is misleading) */ return; } loop: #ifdef UNIV_DEBUG loop_count++; ut_ad(loop_count < 5); # if 0 if (loop_count > 2) { fprintf(stderr, "Log loop count %lu\n", loop_count); } # endif #endif mutex_enter(&(log_sys->mutex)); ut_ad(!recv_no_log_write); if (flush_to_disk && log_sys->flushed_to_disk_lsn >= lsn) { mutex_exit(&(log_sys->mutex)); return; } if (!flush_to_disk && (log_sys->written_to_all_lsn >= lsn || (log_sys->written_to_some_lsn >= lsn && wait != LOG_WAIT_ALL_GROUPS))) { mutex_exit(&(log_sys->mutex)); return; } if (log_sys->n_pending_writes > 0) { /* A write (+ possibly flush to disk) is running */ if (flush_to_disk && log_sys->current_flush_lsn >= lsn) { /* The write + flush will write enough: wait for it to complete */ goto do_waits; } if (!flush_to_disk && log_sys->write_lsn >= lsn) { /* The write will write enough: wait for it to complete */ goto do_waits; } mutex_exit(&(log_sys->mutex)); /* Wait for the write to complete and try to start a new write */ os_event_wait(log_sys->no_flush_event); goto loop; } if (!flush_to_disk && log_sys->buf_free == log_sys->buf_next_to_write) { /* Nothing to write and no flush to disk requested */ mutex_exit(&(log_sys->mutex)); return; } #ifdef UNIV_DEBUG if (log_debug_writes) { fprintf(stderr, "Writing log from " LSN_PF " up to lsn " LSN_PF "\n", log_sys->written_to_all_lsn, log_sys->lsn); } #endif /* UNIV_DEBUG */ log_sys->n_pending_writes++; MONITOR_INC(MONITOR_PENDING_LOG_WRITE); group = UT_LIST_GET_FIRST(log_sys->log_groups); group->n_pending_writes++; /*!< We assume here that we have only one log group! */ os_event_reset(log_sys->no_flush_event); os_event_reset(log_sys->one_flushed_event); start_offset = log_sys->buf_next_to_write; end_offset = log_sys->buf_free; area_start = ut_calc_align_down(start_offset, OS_FILE_LOG_BLOCK_SIZE); area_end = ut_calc_align(end_offset, OS_FILE_LOG_BLOCK_SIZE); ut_ad(area_end - area_start > 0); log_sys->write_lsn = log_sys->lsn; if (flush_to_disk) { log_sys->current_flush_lsn = log_sys->lsn; } log_sys->one_flushed = FALSE; log_block_set_flush_bit(log_sys->buf + area_start, TRUE); log_block_set_checkpoint_no( log_sys->buf + area_end - OS_FILE_LOG_BLOCK_SIZE, log_sys->next_checkpoint_no); /* Copy the last, incompletely written, log block a log block length up, so that when the flush operation writes from the log buffer, the segment to write will not be changed by writers to the log */ ut_memcpy(log_sys->buf + area_end, log_sys->buf + area_end - OS_FILE_LOG_BLOCK_SIZE, OS_FILE_LOG_BLOCK_SIZE); log_sys->buf_free += OS_FILE_LOG_BLOCK_SIZE; log_sys->write_end_offset = log_sys->buf_free; group = UT_LIST_GET_FIRST(log_sys->log_groups); /* Do the write to the log files */ while (group) { log_group_write_buf( group, log_sys->buf + area_start, area_end - area_start, ut_uint64_align_down(log_sys->written_to_all_lsn, OS_FILE_LOG_BLOCK_SIZE), start_offset - area_start); log_group_set_fields(group, log_sys->write_lsn); group = UT_LIST_GET_NEXT(log_groups, group); } mutex_exit(&(log_sys->mutex)); if (srv_unix_file_flush_method == SRV_UNIX_O_DSYNC || srv_unix_file_flush_method == SRV_UNIX_ALL_O_DIRECT) { /* O_DSYNC or ALL_O_DIRECT means the OS did not buffer the log file at all: so we have also flushed to disk what we have written */ log_sys->flushed_to_disk_lsn = log_sys->write_lsn; } else if (flush_to_disk) { group = UT_LIST_GET_FIRST(log_sys->log_groups); fil_flush(group->space_id); log_sys->flushed_to_disk_lsn = log_sys->write_lsn; } mutex_enter(&(log_sys->mutex)); group = UT_LIST_GET_FIRST(log_sys->log_groups); ut_a(group->n_pending_writes == 1); ut_a(log_sys->n_pending_writes == 1); group->n_pending_writes--; log_sys->n_pending_writes--; MONITOR_DEC(MONITOR_PENDING_LOG_WRITE); unlock = log_group_check_flush_completion(group); unlock = unlock | log_sys_check_flush_completion(); log_flush_do_unlocks(unlock); write_lsn = log_sys->write_lsn; flush_lsn = log_sys->flushed_to_disk_lsn; mutex_exit(&(log_sys->mutex)); innobase_mysql_log_notify(write_lsn, flush_lsn); return; do_waits: mutex_exit(&(log_sys->mutex)); switch (wait) { case LOG_WAIT_ONE_GROUP: os_event_wait(log_sys->one_flushed_event); break; case LOG_WAIT_ALL_GROUPS: os_event_wait(log_sys->no_flush_event); break; #ifdef UNIV_DEBUG case LOG_NO_WAIT: break; default: ut_error; #endif /* UNIV_DEBUG */ } } /****************************************************************//** Does a syncronous flush of the log buffer to disk. */ UNIV_INTERN void log_buffer_flush_to_disk(void) /*==========================*/ { lsn_t lsn; ut_ad(!srv_read_only_mode); mutex_enter(&(log_sys->mutex)); lsn = log_sys->lsn; mutex_exit(&(log_sys->mutex)); log_write_up_to(lsn, LOG_WAIT_ALL_GROUPS, TRUE); } /****************************************************************//** This functions writes the log buffer to the log file and if 'flush' is set it forces a flush of the log file as well. This is meant to be called from background master thread only as it does not wait for the write (+ possible flush) to finish. */ UNIV_INTERN void log_buffer_sync_in_background( /*==========================*/ ibool flush) /*!< in: flush the logs to disk */ { lsn_t lsn; mutex_enter(&(log_sys->mutex)); lsn = log_sys->lsn; mutex_exit(&(log_sys->mutex)); log_write_up_to(lsn, LOG_NO_WAIT, flush); } /******************************************************************** Tries to establish a big enough margin of free space in the log buffer, such that a new log entry can be catenated without an immediate need for a flush. */ static void log_flush_margin(void) /*==================*/ { log_t* log = log_sys; lsn_t lsn = 0; mutex_enter(&(log->mutex)); if (log->buf_free > log->max_buf_free) { if (log->n_pending_writes > 0) { /* A flush is running: hope that it will provide enough free space */ } else { lsn = log->lsn; } } mutex_exit(&(log->mutex)); if (lsn) { log_write_up_to(lsn, LOG_NO_WAIT, FALSE); } } /****************************************************************//** Advances the smallest lsn for which there are unflushed dirty blocks in the buffer pool. NOTE: this function may only be called if the calling thread owns no synchronization objects! @return false if there was a flush batch of the same type running, which means that we could not start this flush batch */ static bool log_preflush_pool_modified_pages( /*=============================*/ lsn_t new_oldest) /*!< in: try to advance oldest_modified_lsn at least to this lsn */ { lsn_t current_oldest; ulint i; if (recv_recovery_on) { /* If the recovery is running, we must first apply all log records to their respective file pages to get the right modify lsn values to these pages: otherwise, there might be pages on disk which are not yet recovered to the current lsn, and even after calling this function, we could not know how up-to-date the disk version of the database is, and we could not make a new checkpoint on the basis of the info on the buffer pool only. */ recv_apply_hashed_log_recs(TRUE); } if (!buf_page_cleaner_is_active || (srv_foreground_preflush == SRV_FOREGROUND_PREFLUSH_SYNC_PREFLUSH) || (new_oldest == LSN_MAX)) { ulint n_pages; bool success = buf_flush_list(ULINT_MAX, new_oldest, &n_pages); buf_flush_wait_batch_end(NULL, BUF_FLUSH_LIST); if (!success) { MONITOR_INC(MONITOR_FLUSH_SYNC_WAITS); } MONITOR_INC_VALUE_CUMULATIVE( MONITOR_FLUSH_SYNC_TOTAL_PAGE, MONITOR_FLUSH_SYNC_COUNT, MONITOR_FLUSH_SYNC_PAGES, n_pages); return(success); } ut_ad(srv_foreground_preflush == SRV_FOREGROUND_PREFLUSH_EXP_BACKOFF); current_oldest = buf_pool_get_oldest_modification(); i = 0; while (current_oldest < new_oldest && current_oldest) { while (!buf_flush_flush_list_in_progress()) { /* If a flush list flush by the cleaner thread is not running, backoff until one is started. */ os_thread_sleep(ut_rnd_interval(0, 1 << i)); i++; i %= 16; } buf_flush_wait_batch_end(NULL, BUF_FLUSH_LIST); current_oldest = buf_pool_get_oldest_modification(); } return(current_oldest >= new_oldest || !current_oldest); } /******************************************************//** Completes a checkpoint. */ static void log_complete_checkpoint(void) /*=========================*/ { ut_ad(mutex_own(&(log_sys->mutex))); ut_ad(log_sys->n_pending_checkpoint_writes == 0); log_sys->next_checkpoint_no++; log_sys->last_checkpoint_lsn = log_sys->next_checkpoint_lsn; MONITOR_SET(MONITOR_LSN_CHECKPOINT_AGE, log_sys->lsn - log_sys->last_checkpoint_lsn); rw_lock_x_unlock_gen(&(log_sys->checkpoint_lock), LOG_CHECKPOINT); } /******************************************************//** Completes an asynchronous checkpoint info write i/o to a log file. */ static void log_io_complete_checkpoint(void) /*============================*/ { mutex_enter(&(log_sys->mutex)); ut_ad(log_sys->n_pending_checkpoint_writes > 0); log_sys->n_pending_checkpoint_writes--; MONITOR_DEC(MONITOR_PENDING_CHECKPOINT_WRITE); if (log_sys->n_pending_checkpoint_writes == 0) { log_complete_checkpoint(); } mutex_exit(&(log_sys->mutex)); /* Wake the redo log watching thread to parse the log up to this checkpoint. */ if (srv_track_changed_pages) { os_event_reset(srv_redo_log_tracked_event); os_event_set(srv_checkpoint_completed_event); } } /*******************************************************************//** Writes info to a checkpoint about a log group. */ static void log_checkpoint_set_nth_group_info( /*==============================*/ byte* buf, /*!< in: buffer for checkpoint info */ ulint n, /*!< in: nth slot */ lsn_t file_no)/*!< in: archived file number */ { ut_ad(n < LOG_MAX_N_GROUPS); mach_write_to_8(buf + LOG_CHECKPOINT_GROUP_ARRAY + 8 * n + LOG_CHECKPOINT_ARCHIVED_FILE_NO, file_no); } /*******************************************************************//** Gets info from a checkpoint about a log group. */ UNIV_INTERN void log_checkpoint_get_nth_group_info( /*==============================*/ const byte* buf, /*!< in: buffer containing checkpoint info */ ulint n, /*!< in: nth slot */ lsn_t* file_no)/*!< out: archived file number */ { ut_ad(n < LOG_MAX_N_GROUPS); *file_no = mach_read_from_8(buf + LOG_CHECKPOINT_GROUP_ARRAY + 8 * n + LOG_CHECKPOINT_ARCHIVED_FILE_NO); } /******************************************************//** Writes the checkpoint info to a log group header. */ static void log_group_checkpoint( /*=================*/ log_group_t* group) /*!< in: log group */ { log_group_t* group2; #ifdef UNIV_LOG_ARCHIVE ib_uint64_t archived_lsn; #endif /* UNIV_LOG_ARCHIVE */ lsn_t lsn_offset; ulint write_offset; ulint fold; byte* buf; ulint i; ut_ad(!srv_read_only_mode); ut_ad(mutex_own(&(log_sys->mutex))); ut_a(LOG_CHECKPOINT_SIZE <= OS_FILE_LOG_BLOCK_SIZE); buf = group->checkpoint_buf; mach_write_to_8(buf + LOG_CHECKPOINT_NO, log_sys->next_checkpoint_no); mach_write_to_8(buf + LOG_CHECKPOINT_LSN, log_sys->next_checkpoint_lsn); log_crypt_write_checkpoint_buf(buf); lsn_offset = log_group_calc_lsn_offset(log_sys->next_checkpoint_lsn, group); mach_write_to_4(buf + LOG_CHECKPOINT_OFFSET_LOW32, lsn_offset & 0xFFFFFFFFUL); mach_write_to_4(buf + LOG_CHECKPOINT_OFFSET_HIGH32, lsn_offset >> 32); mach_write_to_4(buf + LOG_CHECKPOINT_LOG_BUF_SIZE, log_sys->buf_size); #ifdef UNIV_LOG_ARCHIVE if (log_sys->archiving_state == LOG_ARCH_OFF) { archived_lsn = LSN_MAX; } else { archived_lsn = log_sys->archived_lsn; } mach_write_to_8(buf + LOG_CHECKPOINT_ARCHIVED_LSN, archived_lsn); #else /* UNIV_LOG_ARCHIVE */ mach_write_to_8(buf + LOG_CHECKPOINT_ARCHIVED_LSN, LSN_MAX); #endif /* UNIV_LOG_ARCHIVE */ for (i = 0; i < LOG_MAX_N_GROUPS; i++) { log_checkpoint_set_nth_group_info(buf, i, 0); } group2 = UT_LIST_GET_FIRST(log_sys->log_groups); while (group2) { log_checkpoint_set_nth_group_info(buf, group2->id, #ifdef UNIV_LOG_ARCHIVE group2->archived_file_no #else /* UNIV_LOG_ARCHIVE */ 0 #endif /* UNIV_LOG_ARCHIVE */ ); group2 = UT_LIST_GET_NEXT(log_groups, group2); } fold = ut_fold_binary(buf, LOG_CHECKPOINT_CHECKSUM_1); mach_write_to_4(buf + LOG_CHECKPOINT_CHECKSUM_1, fold); fold = ut_fold_binary(buf + LOG_CHECKPOINT_LSN, LOG_CHECKPOINT_CHECKSUM_2 - LOG_CHECKPOINT_LSN); mach_write_to_4(buf + LOG_CHECKPOINT_CHECKSUM_2, fold); /* We alternate the physical place of the checkpoint info in the first log file */ if ((log_sys->next_checkpoint_no & 1) == 0) { write_offset = LOG_CHECKPOINT_1; } else { write_offset = LOG_CHECKPOINT_2; } if (log_do_write) { if (log_sys->n_pending_checkpoint_writes == 0) { rw_lock_x_lock_gen(&(log_sys->checkpoint_lock), LOG_CHECKPOINT); } log_sys->n_pending_checkpoint_writes++; MONITOR_INC(MONITOR_PENDING_CHECKPOINT_WRITE); log_sys->n_log_ios++; MONITOR_INC(MONITOR_LOG_IO); /* We send as the last parameter the group machine address added with 1, as we want to distinguish between a normal log file write and a checkpoint field write */ fil_io(OS_FILE_WRITE | OS_FILE_LOG, false, group->space_id, 0, write_offset / UNIV_PAGE_SIZE, write_offset % UNIV_PAGE_SIZE, OS_FILE_LOG_BLOCK_SIZE, buf, ((byte*) group + 1), 0); ut_ad(((ulint) group & 0x1UL) == 0); } } #endif /* !UNIV_HOTBACKUP */ #ifdef UNIV_HOTBACKUP /******************************************************//** Writes info to a buffer of a log group when log files are created in backup restoration. */ UNIV_INTERN void log_reset_first_header_and_checkpoint( /*==================================*/ byte* hdr_buf,/*!< in: buffer which will be written to the start of the first log file */ ib_uint64_t start) /*!< in: lsn of the start of the first log file; we pretend that there is a checkpoint at start + LOG_BLOCK_HDR_SIZE */ { ulint fold; byte* buf; ib_uint64_t lsn; mach_write_to_4(hdr_buf + LOG_GROUP_ID, 0); mach_write_to_8(hdr_buf + LOG_FILE_START_LSN, start); lsn = start + LOG_BLOCK_HDR_SIZE; /* Write the label of mysqlbackup --restore */ strcpy((char*) hdr_buf + LOG_FILE_WAS_CREATED_BY_HOT_BACKUP, "ibbackup "); ut_sprintf_timestamp((char*) hdr_buf + (LOG_FILE_WAS_CREATED_BY_HOT_BACKUP + (sizeof "ibbackup ") - 1)); buf = hdr_buf + LOG_CHECKPOINT_1; mach_write_to_8(buf + LOG_CHECKPOINT_NO, 0); mach_write_to_8(buf + LOG_CHECKPOINT_LSN, lsn); log_crypt_write_checkpoint_buf(buf); mach_write_to_4(buf + LOG_CHECKPOINT_OFFSET_LOW32, LOG_FILE_HDR_SIZE + LOG_BLOCK_HDR_SIZE); mach_write_to_4(buf + LOG_CHECKPOINT_OFFSET_HIGH32, 0); mach_write_to_4(buf + LOG_CHECKPOINT_LOG_BUF_SIZE, 2 * 1024 * 1024); mach_write_to_8(buf + LOG_CHECKPOINT_ARCHIVED_LSN, LSN_MAX); fold = ut_fold_binary(buf, LOG_CHECKPOINT_CHECKSUM_1); mach_write_to_4(buf + LOG_CHECKPOINT_CHECKSUM_1, fold); fold = ut_fold_binary(buf + LOG_CHECKPOINT_LSN, LOG_CHECKPOINT_CHECKSUM_2 - LOG_CHECKPOINT_LSN); mach_write_to_4(buf + LOG_CHECKPOINT_CHECKSUM_2, fold); /* Starting from InnoDB-3.23.50, we should also write info on allocated size in the tablespace, but unfortunately we do not know it here */ } #endif /* UNIV_HOTBACKUP */ #ifndef UNIV_HOTBACKUP /******************************************************//** Reads a checkpoint info from a log group header to log_sys->checkpoint_buf. */ UNIV_INTERN void log_group_read_checkpoint_info( /*===========================*/ log_group_t* group, /*!< in: log group */ ulint field) /*!< in: LOG_CHECKPOINT_1 or LOG_CHECKPOINT_2 */ { ut_ad(mutex_own(&(log_sys->mutex))); log_sys->n_log_ios++; MONITOR_INC(MONITOR_LOG_IO); fil_io(OS_FILE_READ | OS_FILE_LOG, true, group->space_id, 0, field / UNIV_PAGE_SIZE, field % UNIV_PAGE_SIZE, OS_FILE_LOG_BLOCK_SIZE, log_sys->checkpoint_buf, NULL, 0); } /******************************************************//** Writes checkpoint info to groups. */ UNIV_INTERN void log_groups_write_checkpoint_info(void) /*==================================*/ { log_group_t* group; ut_ad(mutex_own(&(log_sys->mutex))); if (!srv_read_only_mode) { for (group = UT_LIST_GET_FIRST(log_sys->log_groups); group; group = UT_LIST_GET_NEXT(log_groups, group)) { log_group_checkpoint(group); } } } /******************************************************//** Makes a checkpoint. Note that this function does not flush dirty blocks from the buffer pool: it only checks what is lsn of the oldest modification in the pool, and writes information about the lsn in log files. Use log_make_checkpoint_at to flush also the pool. @return TRUE if success, FALSE if a checkpoint write was already running */ UNIV_INTERN ibool log_checkpoint( /*===========*/ ibool sync, /*!< in: TRUE if synchronous operation is desired */ ibool write_always, /*!< in: the function normally checks if the the new checkpoint would have a greater lsn than the previous one: if not, then no physical write is done; by setting this parameter TRUE, a physical write will always be made to log files */ ibool safe_to_ignore) /*!< in: TRUE if checkpoint can be ignored in the case checkpoint's are disabled */ { lsn_t oldest_lsn; ut_ad(!srv_read_only_mode); if (recv_recovery_is_on()) { recv_apply_hashed_log_recs(TRUE); } if (srv_unix_file_flush_method != SRV_UNIX_NOSYNC && srv_unix_file_flush_method != SRV_UNIX_ALL_O_DIRECT) { fil_flush_file_spaces(FIL_TABLESPACE); } mutex_enter(&(log_sys->mutex)); ut_ad(!recv_no_log_write); oldest_lsn = log_buf_pool_get_oldest_modification(); mutex_exit(&(log_sys->mutex)); /* Because log also contains headers and dummy log records, if the buffer pool contains no dirty buffers, oldest_lsn gets the value log_sys->lsn from the previous function, and we must make sure that the log is flushed up to that lsn. If there are dirty buffers in the buffer pool, then our write-ahead-logging algorithm ensures that the log has been flushed up to oldest_lsn. */ log_write_up_to(oldest_lsn, LOG_WAIT_ALL_GROUPS, TRUE); mutex_enter(&(log_sys->mutex)); /* Return if this is not a forced checkpoint and either there is no need for a checkpoint or if checkpoints are disabled */ if (!write_always && (log_sys->last_checkpoint_lsn >= oldest_lsn || (safe_to_ignore && log_disable_checkpoint_active))) { mutex_exit(&(log_sys->mutex)); return(TRUE); } if (log_disable_checkpoint_active) { /* Wait until we are allowed to do a checkpoint */ mutex_exit(&(log_sys->mutex)); rw_lock_s_lock(&(log_sys->checkpoint_lock)); rw_lock_s_unlock(&(log_sys->checkpoint_lock)); mutex_enter(&(log_sys->mutex)); } ut_ad(log_sys->flushed_to_disk_lsn >= oldest_lsn); if (log_sys->n_pending_checkpoint_writes > 0) { /* A checkpoint write is running */ mutex_exit(&(log_sys->mutex)); if (sync) { /* Wait for the checkpoint write to complete */ rw_lock_s_lock(&(log_sys->checkpoint_lock)); rw_lock_s_unlock(&(log_sys->checkpoint_lock)); } return(FALSE); } log_sys->next_checkpoint_lsn = oldest_lsn; #ifdef UNIV_DEBUG if (log_debug_writes) { fprintf(stderr, "Making checkpoint no " LSN_PF " at lsn " LSN_PF "\n", log_sys->next_checkpoint_no, oldest_lsn); } #endif /* UNIV_DEBUG */ log_groups_write_checkpoint_info(); /* generate key version and key used to encrypt next log block */ log_crypt_set_ver_and_key(log_sys->redo_log_crypt_ver, log_sys->redo_log_crypt_key); MONITOR_INC(MONITOR_NUM_CHECKPOINT); mutex_exit(&(log_sys->mutex)); if (sync) { /* Wait for the checkpoint write to complete */ rw_lock_s_lock(&(log_sys->checkpoint_lock)); rw_lock_s_unlock(&(log_sys->checkpoint_lock)); } return(TRUE); } /****************************************************************//** Makes a checkpoint at a given lsn or later. */ UNIV_INTERN void log_make_checkpoint_at( /*===================*/ lsn_t lsn, /*!< in: make a checkpoint at this or a later lsn, if LSN_MAX, makes a checkpoint at the latest lsn */ ibool write_always) /*!< in: the function normally checks if the new checkpoint would have a greater lsn than the previous one: if not, then no physical write is done; by setting this parameter TRUE, a physical write will always be made to log files */ { /* Preflush pages synchronously */ while (!log_preflush_pool_modified_pages(lsn)) { /* Flush as much as we can */ } while (!log_checkpoint(TRUE, write_always, FALSE)) { /* Force a checkpoint */ } } /****************************************************************//** Disable checkpoints. This is used when doing a volumne snapshot to ensure that we don't get checkpoint between snapshoting two different volumes */ UNIV_INTERN ibool log_disable_checkpoint() { mutex_enter(&(log_sys->mutex)); /* Wait if a checkpoint write is running. This is the same code that is used in log_checkpoint() to ensure that two checkpoints are not happening at the same time. */ while (log_sys->n_pending_checkpoint_writes > 0) { mutex_exit(&(log_sys->mutex)); rw_lock_s_lock(&(log_sys->checkpoint_lock)); rw_lock_s_unlock(&(log_sys->checkpoint_lock)); mutex_enter(&(log_sys->mutex)); } /* The following should never be true; It's is here just in case of wrong usage of this function. (Better safe than sorry). */ if (log_disable_checkpoint_active) { mutex_exit(&(log_sys->mutex)); return 1; /* Already disabled */ } /* Take the checkpoint lock to ensure we will not get any checkpoints running */ rw_lock_x_lock_gen(&(log_sys->checkpoint_lock), LOG_CHECKPOINT); log_disable_checkpoint_active= 1; mutex_exit(&(log_sys->mutex)); return 0; } /****************************************************************//** Enable checkpoints that was disabled with log_disable_checkpoint() This lock is called by MariaDB and only when we have done call earlier to log_disable_checkpoint(). Note: We can't take a log->mutex lock here running log_checkpoint() which is waiting (log_sys->checkpoint_lock may already have it. This is however safe to do without a mutex as log_disable_checkpoint is protected by log_sys->checkpoint_lock. */ UNIV_INTERN void log_enable_checkpoint() { ut_ad(log_disable_checkpoint_active); /* Test variable, mostly to protect against wrong usage */ if (log_disable_checkpoint_active) { log_disable_checkpoint_active= 0; rw_lock_x_unlock_gen(&(log_sys->checkpoint_lock), LOG_CHECKPOINT); } } /****************************************************************//** Tries to establish a big enough margin of free space in the log groups, such that a new log entry can be catenated without an immediate need for a checkpoint. NOTE: this function may only be called if the calling thread owns no synchronization objects! */ static void log_checkpoint_margin(void) /*=======================*/ { log_t* log = log_sys; lsn_t age; lsn_t checkpoint_age; ib_uint64_t advance; lsn_t oldest_lsn; ibool checkpoint_sync; ibool do_checkpoint; bool success; loop: checkpoint_sync = FALSE; do_checkpoint = FALSE; advance = 0; mutex_enter(&(log->mutex)); ut_ad(!recv_no_log_write); if (log->check_flush_or_checkpoint == FALSE) { mutex_exit(&(log->mutex)); return; } oldest_lsn = log_buf_pool_get_oldest_modification(); age = log->lsn - oldest_lsn; if (age > log->max_modified_age_sync) { /* A flush is urgent: we have to do a synchronous preflush */ advance = 2 * (age - log->max_modified_age_sync); } checkpoint_age = log->lsn - log->last_checkpoint_lsn; if (checkpoint_age > log->max_checkpoint_age) { /* A checkpoint is urgent: we do it synchronously */ checkpoint_sync = TRUE; do_checkpoint = TRUE; } else if (checkpoint_age > log->max_checkpoint_age_async) { /* A checkpoint is not urgent: do it asynchronously */ do_checkpoint = TRUE; log->check_flush_or_checkpoint = FALSE; } else { log->check_flush_or_checkpoint = FALSE; } mutex_exit(&(log->mutex)); if (advance) { lsn_t new_oldest = oldest_lsn + advance; success = log_preflush_pool_modified_pages(new_oldest); /* If the flush succeeded, this thread has done its part and can proceed. If it did not succeed, there was another thread doing a flush at the same time. */ if (!success) { mutex_enter(&(log->mutex)); log->check_flush_or_checkpoint = TRUE; mutex_exit(&(log->mutex)); goto loop; } } if (do_checkpoint) { log_checkpoint(checkpoint_sync, FALSE, FALSE); if (checkpoint_sync) { goto loop; } } } /******************************************************//** Decrypt a specified log segment after they are read from a log file to a buffer. @return true if decryption succeeds. */ static bool log_group_decrypt_after_read( /*==========================*/ const log_group_t* group, /*!< in: log group to be read from */ byte* frame, /*!< in/out: log segment */ const ulint size) /*!< in: log segment size */ { Crypt_result result; ut_ad(size % OS_FILE_LOG_BLOCK_SIZE == 0); byte* dst_frame = (byte*)malloc(size); // decrypt log blocks content result = log_blocks_decrypt(frame, size, dst_frame); if (result == AES_OK) { memcpy(frame, dst_frame, size); } free(dst_frame); return (result == AES_OK); } /******************************************************//** Reads a specified log segment to a buffer. Optionally releases the log mutex before the I/O. */ UNIV_INTERN void log_group_read_log_seg( /*===================*/ ulint type, /*!< in: LOG_ARCHIVE or LOG_RECOVER */ byte* buf, /*!< in: buffer where to read */ log_group_t* group, /*!< in: log group */ lsn_t start_lsn, /*!< in: read area start */ lsn_t end_lsn, /*!< in: read area end */ ibool release_mutex) /*!< in: whether the log_sys->mutex should be released before the read */ { ulint len; lsn_t source_offset; bool sync; ut_ad(mutex_own(&(log_sys->mutex))); sync = (type == LOG_RECOVER); loop: source_offset = log_group_calc_lsn_offset(start_lsn, group); ut_a(end_lsn - start_lsn <= ULINT_MAX); len = (ulint) (end_lsn - start_lsn); ut_ad(len != 0); if ((source_offset % group->file_size) + len > group->file_size) { /* If the above condition is true then len (which is ulint) is > the expression below, so the typecast is ok */ len = (ulint) (group->file_size - (source_offset % group->file_size)); } #ifdef UNIV_LOG_ARCHIVE if (type == LOG_ARCHIVE) { log_sys->n_pending_archive_ios++; } #endif /* UNIV_LOG_ARCHIVE */ log_sys->n_log_ios++; MONITOR_INC(MONITOR_LOG_IO); ut_a(source_offset / UNIV_PAGE_SIZE <= ULINT_MAX); if (release_mutex) { mutex_exit(&(log_sys->mutex)); } fil_io(OS_FILE_READ | OS_FILE_LOG, sync, group->space_id, 0, (ulint) (source_offset / UNIV_PAGE_SIZE), (ulint) (source_offset % UNIV_PAGE_SIZE), len, buf, (type == LOG_ARCHIVE) ? &log_archive_io : NULL, 0); if (recv_sys->recv_log_crypt_ver != UNENCRYPTED_KEY_VER && !log_group_decrypt_after_read(group, buf, len)) { fprintf(stderr, "Innodb redo log decryption failed.\n"); abort(); } start_lsn += len; buf += len; if (start_lsn != end_lsn) { if (release_mutex) { mutex_enter(&(log_sys->mutex)); } goto loop; } } #ifdef UNIV_LOG_ARCHIVE /******************************************************//** Generates an archived log file name. */ UNIV_INTERN void log_archived_file_name_gen( /*=======================*/ char* buf, /*!< in: buffer where to write */ ulint buf_len,/*!< in: buffer length */ ulint id __attribute__((unused)), /*!< in: group id; currently we only archive the first group */ lsn_t file_no)/*!< in: file number */ { ulint dirnamelen; dirnamelen = strlen(srv_arch_dir); ut_a(buf_len > dirnamelen + IB_ARCHIVED_LOGS_SERIAL_LEN + IB_ARCHIVED_LOGS_PREFIX_LEN + 2); strcpy(buf, srv_arch_dir); if (buf[dirnamelen-1] != SRV_PATH_SEPARATOR) { buf[dirnamelen++] = SRV_PATH_SEPARATOR; } sprintf(buf + dirnamelen, IB_ARCHIVED_LOGS_PREFIX "%0" IB_TO_STR(IB_ARCHIVED_LOGS_SERIAL_LEN) "llu", (unsigned long long)file_no); } /******************************************************//** Get offset within archived log file to continue to write with. */ UNIV_INTERN void log_archived_get_offset( /*=====================*/ log_group_t* group, /*!< in: log group */ lsn_t file_no, /*!< in: archive log file number */ lsn_t archived_lsn, /*!< in: last archived LSN */ lsn_t* offset) /*!< out: offset within archived file */ { char file_name[OS_FILE_MAX_PATH]; ibool exists; os_file_type_t type; log_archived_file_name_gen(file_name, sizeof(file_name), group->id, file_no); ut_a(os_file_status(file_name, &exists, &type)); if (!exists) { *offset = 0; return; } *offset = archived_lsn - file_no + LOG_FILE_HDR_SIZE; if (archived_lsn != LSN_MAX) { *offset = archived_lsn - file_no + LOG_FILE_HDR_SIZE; } else { /* Archiving was OFF prior startup */ *offset = 0; } ut_a(group->file_size >= *offset + LOG_FILE_HDR_SIZE); return; } /******************************************************//** Writes a log file header to a log file space. */ static void log_group_archive_file_header_write( /*================================*/ log_group_t* group, /*!< in: log group */ ulint nth_file, /*!< in: header to the nth file in the archive log file space */ lsn_t file_no, /*!< in: archived file number */ ib_uint64_t start_lsn) /*!< in: log file data starts at this lsn */ { byte* buf; ulint dest_offset; ut_ad(mutex_own(&(log_sys->mutex))); ut_a(nth_file < group->n_files); buf = *(group->archive_file_header_bufs + nth_file); mach_write_to_4(buf + LOG_GROUP_ID, group->id); mach_write_to_8(buf + LOG_FILE_START_LSN, start_lsn); mach_write_to_4(buf + LOG_FILE_NO, file_no); mach_write_to_4(buf + LOG_FILE_ARCH_COMPLETED, FALSE); dest_offset = nth_file * group->file_size; log_sys->n_log_ios++; MONITOR_INC(MONITOR_LOG_IO); fil_io(OS_FILE_WRITE | OS_FILE_LOG, true, group->archive_space_id, 0, dest_offset / UNIV_PAGE_SIZE, dest_offset % UNIV_PAGE_SIZE, 2 * OS_FILE_LOG_BLOCK_SIZE, buf, &log_archive_io, 0); } /******************************************************//** Writes a log file header to a completed archived log file. */ static void log_group_archive_completed_header_write( /*=====================================*/ log_group_t* group, /*!< in: log group */ ulint nth_file, /*!< in: header to the nth file in the archive log file space */ ib_uint64_t end_lsn) /*!< in: end lsn of the file */ { byte* buf; ulint dest_offset; ut_ad(mutex_own(&(log_sys->mutex))); ut_a(nth_file < group->n_files); buf = *(group->archive_file_header_bufs + nth_file); mach_write_to_4(buf + LOG_FILE_ARCH_COMPLETED, TRUE); mach_write_to_8(buf + LOG_FILE_END_LSN, end_lsn); dest_offset = nth_file * group->file_size + LOG_FILE_ARCH_COMPLETED; log_sys->n_log_ios++; MONITOR_INC(MONITOR_LOG_IO); fil_io(OS_FILE_WRITE | OS_FILE_LOG, true, group->archive_space_id, 0, dest_offset / UNIV_PAGE_SIZE, dest_offset % UNIV_PAGE_SIZE, OS_FILE_LOG_BLOCK_SIZE, buf + LOG_FILE_ARCH_COMPLETED, &log_archive_io, 0); } /******************************************************//** Does the archive writes for a single log group. */ static void log_group_archive( /*==============*/ log_group_t* group) /*!< in: log group */ { os_file_t file_handle; lsn_t start_lsn; lsn_t end_lsn; char name[OS_FILE_MAX_PATH]; byte* buf; ulint len; ibool ret; lsn_t next_offset; ulint n_files; ulint open_mode; ut_ad(mutex_own(&(log_sys->mutex))); start_lsn = log_sys->archived_lsn; ut_a(start_lsn % OS_FILE_LOG_BLOCK_SIZE == 0); end_lsn = log_sys->next_archived_lsn; ut_a(end_lsn % OS_FILE_LOG_BLOCK_SIZE == 0); buf = log_sys->archive_buf; n_files = 0; next_offset = group->archived_offset; loop: if ((next_offset % group->file_size == 0) || (fil_space_get_size(group->archive_space_id) == 0)) { /* Add the file to the archive file space; create or open the file */ if (next_offset % group->file_size == 0) { open_mode = OS_FILE_CREATE; if (n_files == 0) { /* Adjust archived_file_no to match start_lsn which is written in file header as well */ group->archived_file_no = start_lsn; } } else { open_mode = OS_FILE_OPEN; } log_archived_file_name_gen(name, sizeof(name), group->id, group->archived_file_no + n_files * (group->file_size - LOG_FILE_HDR_SIZE)); file_handle = os_file_create(innodb_file_log_key, name, open_mode, OS_FILE_AIO, OS_DATA_FILE, &ret, FALSE); if (!ret && (open_mode == OS_FILE_CREATE)) { file_handle = os_file_create( innodb_file_log_key, name, OS_FILE_OPEN, OS_FILE_AIO, OS_DATA_FILE, &ret, FALSE); } if (!ret) { fprintf(stderr, "InnoDB: Cannot create or open" " archive log file %s.\n" "InnoDB: Cannot continue operation.\n" "InnoDB: Check that the log archive" " directory exists,\n" "InnoDB: you have access rights to it, and\n" "InnoDB: there is space available.\n", name); exit(1); } #ifdef UNIV_DEBUG if (log_debug_writes) { fprintf(stderr, "Created archive file %s\n", name); } #endif /* UNIV_DEBUG */ ret = os_file_close(file_handle); ut_a(ret); /* Add the archive file as a node to the space */ ut_a(fil_node_create(name, group->file_size / UNIV_PAGE_SIZE, group->archive_space_id, FALSE)); if (next_offset % group->file_size == 0) { log_group_archive_file_header_write( group, n_files, group->archived_file_no + n_files * (group->file_size - LOG_FILE_HDR_SIZE), start_lsn); next_offset += LOG_FILE_HDR_SIZE; } } len = end_lsn - start_lsn; if (group->file_size < (next_offset % group->file_size) + len) { len = group->file_size - (next_offset % group->file_size); } #ifdef UNIV_DEBUG if (log_debug_writes) { fprintf(stderr, "Archiving starting at lsn " LSN_PF ", len %lu" " to group %lu\n", start_lsn, (ulong) len, (ulong) group->id); } #endif /* UNIV_DEBUG */ log_sys->n_pending_archive_ios++; log_sys->n_log_ios++; MONITOR_INC(MONITOR_LOG_IO); if (srv_encrypt_log && log_sys->redo_log_crypt_ver != UNENCRYPTED_KEY_VER && !log_group_encrypt_before_write(group, buf, len)) { fprintf(stderr, "Innodb redo log encryption failed.\n"); abort(); } fil_io(OS_FILE_WRITE | OS_FILE_LOG, false, group->archive_space_id, 0, (ulint) (next_offset / UNIV_PAGE_SIZE), (ulint) (next_offset % UNIV_PAGE_SIZE), ut_calc_align(len, OS_FILE_LOG_BLOCK_SIZE), buf, &log_archive_io, 0); start_lsn += len; next_offset += len; buf += len; if (next_offset % group->file_size == 0) { n_files++; } if (end_lsn != start_lsn) { goto loop; } group->next_archived_file_no = group->archived_file_no + n_files * (group->file_size - LOG_FILE_HDR_SIZE); group->next_archived_offset = next_offset % group->file_size; ut_a(group->next_archived_offset % OS_FILE_LOG_BLOCK_SIZE == 0); } /*****************************************************//** (Writes to the archive of each log group.) Currently, only the first group is archived. */ static void log_archive_groups(void) /*====================*/ { log_group_t* group; ut_ad(mutex_own(&(log_sys->mutex))); group = UT_LIST_GET_FIRST(log_sys->log_groups); log_group_archive(group); } /*****************************************************//** Completes the archiving write phase for (each log group), currently, the first log group. */ static void log_archive_write_complete_groups(void) /*===================================*/ { log_group_t* group; lsn_t end_offset; ulint trunc_files; ulint n_files; ib_uint64_t start_lsn; ib_uint64_t end_lsn; ulint i; ut_ad(mutex_own(&(log_sys->mutex))); group = UT_LIST_GET_FIRST(log_sys->log_groups); group->archived_file_no = group->next_archived_file_no; group->archived_offset = group->next_archived_offset; /* Truncate from the archive file space all but the last file, or if it has been written full, all files */ n_files = (UNIV_PAGE_SIZE * fil_space_get_size(group->archive_space_id)) / group->file_size; ut_ad(n_files > 0); end_offset = group->archived_offset; if (end_offset % group->file_size == 0) { trunc_files = n_files; } else { trunc_files = n_files - 1; } #ifdef UNIV_DEBUG if (log_debug_writes && trunc_files) { fprintf(stderr, "Complete file(s) archived to group %lu\n", (ulong) group->id); } #endif /* UNIV_DEBUG */ /* Calculate the archive file space start lsn */ start_lsn = log_sys->next_archived_lsn - (end_offset - LOG_FILE_HDR_SIZE + trunc_files * (group->file_size - LOG_FILE_HDR_SIZE)); end_lsn = start_lsn; for (i = 0; i < trunc_files; i++) { end_lsn += group->file_size - LOG_FILE_HDR_SIZE; /* Write a notice to the headers of archived log files that the file write has been completed */ log_group_archive_completed_header_write(group, i, end_lsn); } fil_space_truncate_start(group->archive_space_id, trunc_files * group->file_size); #ifdef UNIV_DEBUG if (log_debug_writes) { fputs("Archiving writes completed\n", stderr); } #endif /* UNIV_DEBUG */ } /******************************************************//** Completes an archiving i/o. */ static void log_archive_check_completion_low(void) /*==================================*/ { ut_ad(mutex_own(&(log_sys->mutex))); if (log_sys->n_pending_archive_ios == 0 && log_sys->archiving_phase == LOG_ARCHIVE_READ) { #ifdef UNIV_DEBUG if (log_debug_writes) { fputs("Archiving read completed\n", stderr); } #endif /* UNIV_DEBUG */ /* Archive buffer has now been read in: start archive writes */ log_sys->archiving_phase = LOG_ARCHIVE_WRITE; log_archive_groups(); } if (log_sys->n_pending_archive_ios == 0 && log_sys->archiving_phase == LOG_ARCHIVE_WRITE) { log_archive_write_complete_groups(); log_sys->archived_lsn = log_sys->next_archived_lsn; rw_lock_x_unlock_gen(&(log_sys->archive_lock), LOG_ARCHIVE); } } /******************************************************//** Completes an archiving i/o. */ static void log_io_complete_archive(void) /*=========================*/ { log_group_t* group; mutex_enter(&(log_sys->mutex)); group = UT_LIST_GET_FIRST(log_sys->log_groups); mutex_exit(&(log_sys->mutex)); fil_flush(group->archive_space_id); mutex_enter(&(log_sys->mutex)); ut_ad(log_sys->n_pending_archive_ios > 0); log_sys->n_pending_archive_ios--; log_archive_check_completion_low(); mutex_exit(&(log_sys->mutex)); } /********************************************************************//** Starts an archiving operation. @return TRUE if succeed, FALSE if an archiving operation was already running */ UNIV_INTERN ibool log_archive_do( /*===========*/ ibool sync, /*!< in: TRUE if synchronous operation is desired */ ulint* n_bytes)/*!< out: archive log buffer size, 0 if nothing to archive */ { ibool calc_new_limit; lsn_t start_lsn; lsn_t limit_lsn = LSN_MAX; calc_new_limit = TRUE; loop: mutex_enter(&(log_sys->mutex)); switch (log_sys->archiving_state) { case LOG_ARCH_OFF: arch_none: mutex_exit(&(log_sys->mutex)); *n_bytes = 0; return(TRUE); case LOG_ARCH_STOPPED: case LOG_ARCH_STOPPING2: mutex_exit(&(log_sys->mutex)); os_event_wait(log_sys->archiving_on); goto loop; } start_lsn = log_sys->archived_lsn; if (calc_new_limit) { ut_a(log_sys->archive_buf_size % OS_FILE_LOG_BLOCK_SIZE == 0); limit_lsn = start_lsn + log_sys->archive_buf_size; *n_bytes = log_sys->archive_buf_size; if (limit_lsn >= log_sys->lsn) { limit_lsn = ut_uint64_align_down( log_sys->lsn, OS_FILE_LOG_BLOCK_SIZE); } } if (log_sys->archived_lsn >= limit_lsn) { goto arch_none; } if (log_sys->written_to_all_lsn < limit_lsn) { mutex_exit(&(log_sys->mutex)); log_write_up_to(limit_lsn, LOG_WAIT_ALL_GROUPS, TRUE); calc_new_limit = FALSE; goto loop; } if (log_sys->n_pending_archive_ios > 0) { /* An archiving operation is running */ mutex_exit(&(log_sys->mutex)); if (sync) { rw_lock_s_lock(&(log_sys->archive_lock)); rw_lock_s_unlock(&(log_sys->archive_lock)); } *n_bytes = log_sys->archive_buf_size; return(FALSE); } rw_lock_x_lock_gen(&(log_sys->archive_lock), LOG_ARCHIVE); log_sys->archiving_phase = LOG_ARCHIVE_READ; log_sys->next_archived_lsn = limit_lsn; #ifdef UNIV_DEBUG if (log_debug_writes) { fprintf(stderr, "Archiving from lsn " LSN_PF " to lsn " LSN_PF "\n", log_sys->archived_lsn, limit_lsn); } #endif /* UNIV_DEBUG */ /* Read the log segment to the archive buffer */ log_group_read_log_seg(LOG_ARCHIVE, log_sys->archive_buf, UT_LIST_GET_FIRST(log_sys->log_groups), start_lsn, limit_lsn, FALSE); mutex_exit(&(log_sys->mutex)); if (sync) { rw_lock_s_lock(&(log_sys->archive_lock)); rw_lock_s_unlock(&(log_sys->archive_lock)); } *n_bytes = log_sys->archive_buf_size; return(TRUE); } /****************************************************************//** Writes the log contents to the archive at least up to the lsn when this function was called. */ static void log_archive_all(void) /*=================*/ { lsn_t present_lsn; mutex_enter(&(log_sys->mutex)); if (log_sys->archiving_state == LOG_ARCH_OFF) { mutex_exit(&(log_sys->mutex)); return; } present_lsn = log_sys->lsn; mutex_exit(&(log_sys->mutex)); log_pad_current_log_block(); for (;;) { ulint archived_bytes; mutex_enter(&(log_sys->mutex)); if (present_lsn <= log_sys->archived_lsn) { mutex_exit(&(log_sys->mutex)); return; } mutex_exit(&(log_sys->mutex)); log_archive_do(TRUE, &archived_bytes); if (archived_bytes == 0) return; } } /*****************************************************//** Closes the possible open archive log file (for each group) the first group, and if it was open, increments the group file count by 2, if desired. */ static void log_archive_close_groups( /*=====================*/ ibool increment_file_count) /*!< in: TRUE if we want to increment the file count */ { log_group_t* group; ulint trunc_len; ut_ad(mutex_own(&(log_sys->mutex))); if (log_sys->archiving_state == LOG_ARCH_OFF) { return; } group = UT_LIST_GET_FIRST(log_sys->log_groups); trunc_len = UNIV_PAGE_SIZE * fil_space_get_size(group->archive_space_id); if (trunc_len > 0) { ut_a(trunc_len == group->file_size); /* Write a notice to the headers of archived log files that the file write has been completed */ log_group_archive_completed_header_write( group, 0, log_sys->archived_lsn); fil_space_truncate_start(group->archive_space_id, trunc_len); if (increment_file_count) { group->archived_offset = 0; } } } /****************************************************************//** Writes the log contents to the archive up to the lsn when this function was called, and stops the archiving. When archiving is started again, the archived log file numbers start from 2 higher, so that the archiving will not write again to the archived log files which exist when this function returns. @return DB_SUCCESS or DB_ERROR */ UNIV_INTERN ulint log_archive_stop(void) /*==================*/ { ibool success; mutex_enter(&(log_sys->mutex)); if (log_sys->archiving_state != LOG_ARCH_ON) { mutex_exit(&(log_sys->mutex)); return(DB_ERROR); } log_sys->archiving_state = LOG_ARCH_STOPPING; mutex_exit(&(log_sys->mutex)); log_archive_all(); mutex_enter(&(log_sys->mutex)); log_sys->archiving_state = LOG_ARCH_STOPPING2; os_event_reset(log_sys->archiving_on); mutex_exit(&(log_sys->mutex)); /* Wait for a possible archiving operation to end */ rw_lock_s_lock(&(log_sys->archive_lock)); rw_lock_s_unlock(&(log_sys->archive_lock)); mutex_enter(&(log_sys->mutex)); /* Close all archived log files, incrementing the file count by 2, if appropriate */ log_archive_close_groups(TRUE); mutex_exit(&(log_sys->mutex)); /* Make a checkpoint, so that if recovery is needed, the file numbers of new archived log files will start from the right value */ success = FALSE; while (!success) { success = log_checkpoint(TRUE, TRUE, FALSE); } mutex_enter(&(log_sys->mutex)); log_sys->archiving_state = LOG_ARCH_STOPPED; mutex_exit(&(log_sys->mutex)); return(DB_SUCCESS); } /****************************************************************//** Starts again archiving which has been stopped. @return DB_SUCCESS or DB_ERROR */ UNIV_INTERN ulint log_archive_start(void) /*===================*/ { mutex_enter(&(log_sys->mutex)); if (log_sys->archiving_state != LOG_ARCH_STOPPED) { mutex_exit(&(log_sys->mutex)); return(DB_ERROR); } log_sys->archiving_state = LOG_ARCH_ON; os_event_set(log_sys->archiving_on); mutex_exit(&(log_sys->mutex)); return(DB_SUCCESS); } /****************************************************************//** Stop archiving the log so that a gap may occur in the archived log files. @return DB_SUCCESS or DB_ERROR */ UNIV_INTERN ulint log_archive_noarchivelog(void) /*==========================*/ { loop: mutex_enter(&(log_sys->mutex)); if (log_sys->archiving_state == LOG_ARCH_STOPPED || log_sys->archiving_state == LOG_ARCH_OFF) { log_sys->archiving_state = LOG_ARCH_OFF; os_event_set(log_sys->archiving_on); mutex_exit(&(log_sys->mutex)); return(DB_SUCCESS); } mutex_exit(&(log_sys->mutex)); log_archive_stop(); os_thread_sleep(500000); goto loop; } /****************************************************************//** Start archiving the log so that a gap may occur in the archived log files. @return DB_SUCCESS or DB_ERROR */ UNIV_INTERN ulint log_archive_archivelog(void) /*========================*/ { mutex_enter(&(log_sys->mutex)); if (log_sys->archiving_state == LOG_ARCH_OFF) { log_sys->archiving_state = LOG_ARCH_ON; log_sys->archived_lsn = ut_uint64_align_down(log_sys->lsn, OS_FILE_LOG_BLOCK_SIZE); mutex_exit(&(log_sys->mutex)); return(DB_SUCCESS); } mutex_exit(&(log_sys->mutex)); return(DB_ERROR); } /****************************************************************//** Tries to establish a big enough margin of free space in the log groups, such that a new log entry can be catenated without an immediate need for archiving. */ static void log_archive_margin(void) /*====================*/ { log_t* log = log_sys; ulint age; ibool sync; ulint dummy; loop: mutex_enter(&(log->mutex)); if (log->archiving_state == LOG_ARCH_OFF) { mutex_exit(&(log->mutex)); return; } age = log->lsn - log->archived_lsn; if (age > log->max_archived_lsn_age) { /* An archiving is urgent: we have to do synchronous i/o */ sync = TRUE; } else if (age > log->max_archived_lsn_age_async) { /* An archiving is not urgent: we do asynchronous i/o */ sync = FALSE; } else { /* No archiving required yet */ mutex_exit(&(log->mutex)); return; } mutex_exit(&(log->mutex)); log_archive_do(sync, &dummy); if (sync == TRUE) { /* Check again that enough was written to the archive */ goto loop; } } #endif /* UNIV_LOG_ARCHIVE */ /********************************************************************//** Checks that there is enough free space in the log to start a new query step. Flushes the log buffer or makes a new checkpoint if necessary. NOTE: this function may only be called if the calling thread owns no synchronization objects! */ UNIV_INTERN void log_check_margins(void) /*===================*/ { loop: log_flush_margin(); log_checkpoint_margin(); mutex_enter(&(log_sys->mutex)); if (log_check_tracking_margin(0)) { mutex_exit(&(log_sys->mutex)); os_thread_sleep(10000); goto loop; } mutex_exit(&(log_sys->mutex)); #ifdef UNIV_LOG_ARCHIVE log_archive_margin(); #endif /* UNIV_LOG_ARCHIVE */ mutex_enter(&(log_sys->mutex)); ut_ad(!recv_no_log_write); if (log_sys->check_flush_or_checkpoint) { mutex_exit(&(log_sys->mutex)); goto loop; } mutex_exit(&(log_sys->mutex)); } /****************************************************************//** Makes a checkpoint at the latest lsn and writes it to first page of each data file in the database, so that we know that the file spaces contain all modifications up to that lsn. This can only be called at database shutdown. This function also writes all log in log files to the log archive. */ UNIV_INTERN void logs_empty_and_mark_files_at_shutdown(void) /*=======================================*/ { lsn_t lsn; lsn_t tracked_lsn; ulint count = 0; ulint total_trx; ulint pending_io; enum srv_thread_type active_thd; const char* thread_name; ibool server_busy; ib_logf(IB_LOG_LEVEL_INFO, "Starting shutdown..."); /* Enable checkpoints if someone had turned them off */ if (log_disable_checkpoint_active) log_enable_checkpoint(); /* Wait until the master thread and all other operations are idle: our algorithm only works if the server is idle at shutdown */ srv_shutdown_state = SRV_SHUTDOWN_CLEANUP; loop: os_thread_sleep(100000); count++; /* We need the monitor threads to stop before we proceed with a shutdown. */ thread_name = srv_any_background_threads_are_active(); if (thread_name != NULL) { /* Print a message every 60 seconds if we are waiting for the monitor thread to exit. Master and worker threads check will be done later. */ if (srv_print_verbose_log && count > 600) { ib_logf(IB_LOG_LEVEL_INFO, "Waiting for %s to exit", thread_name); count = 0; } goto loop; } /* Check that there are no longer transactions, except for PREPARED ones. We need this wait even for the 'very fast' shutdown, because the InnoDB layer may have committed or prepared transactions and we don't want to lose them. */ total_trx = trx_sys_any_active_transactions(); if (total_trx > 0) { if (srv_print_verbose_log && count > 600) { ib_logf(IB_LOG_LEVEL_INFO, "Waiting for %lu active transactions to finish", (ulong) total_trx); count = 0; } goto loop; } /* Check that the background threads are suspended */ active_thd = srv_get_active_thread_type(); if (active_thd != SRV_NONE) { if (active_thd == SRV_PURGE) { srv_purge_wakeup(); } /* The srv_lock_timeout_thread, srv_error_monitor_thread and srv_monitor_thread should already exit by now. The only threads to be suspended are the master threads and worker threads (purge threads). Print the thread type if any of such threads not in suspended mode */ if (srv_print_verbose_log && count > 600) { const char* thread_type = ""; switch (active_thd) { case SRV_NONE: /* This shouldn't happen because we've already checked for this case before entering the if(). We handle it here to avoid a compiler warning. */ ut_error; case SRV_WORKER: thread_type = "worker threads"; break; case SRV_MASTER: thread_type = "master thread"; break; case SRV_PURGE: thread_type = "purge thread"; break; } ib_logf(IB_LOG_LEVEL_INFO, "Waiting for %s to be suspended", thread_type); count = 0; } goto loop; } /* At this point only page_cleaner should be active. We wait here to let it complete the flushing of the buffer pools before proceeding further. */ srv_shutdown_state = SRV_SHUTDOWN_FLUSH_PHASE; count = 0; while (buf_page_cleaner_is_active) { ++count; os_thread_sleep(100000); if (srv_print_verbose_log && count > 600) { ib_logf(IB_LOG_LEVEL_INFO, "Waiting for page_cleaner to " "finish flushing of buffer pool"); count = 0; } } mutex_enter(&log_sys->mutex); server_busy = log_sys->n_pending_checkpoint_writes #ifdef UNIV_LOG_ARCHIVE || log_sys->n_pending_archive_ios #endif /* UNIV_LOG_ARCHIVE */ || log_sys->n_pending_writes; mutex_exit(&log_sys->mutex); if (server_busy) { if (srv_print_verbose_log && count > 600) { ib_logf(IB_LOG_LEVEL_INFO, "Pending checkpoint_writes: %lu. " "Pending log flush writes: %lu", (ulong) log_sys->n_pending_checkpoint_writes, (ulong) log_sys->n_pending_writes); count = 0; } goto loop; } pending_io = buf_pool_check_no_pending_io(); if (pending_io) { if (srv_print_verbose_log && count > 600) { ib_logf(IB_LOG_LEVEL_INFO, "Waiting for %lu buffer page I/Os to complete", (ulong) pending_io); count = 0; } goto loop; } #ifdef UNIV_LOG_ARCHIVE log_archive_all(); #endif /* UNIV_LOG_ARCHIVE */ if (srv_fast_shutdown == 2) { if (!srv_read_only_mode) { ib_logf(IB_LOG_LEVEL_INFO, "MySQL has requested a very fast shutdown " "without flushing the InnoDB buffer pool to " "data files. At the next mysqld startup " "InnoDB will do a crash recovery!"); /* In this fastest shutdown we do not flush the buffer pool: it is essentially a 'crash' of the InnoDB server. Make sure that the log is all flushed to disk, so that we can recover all committed transactions in a crash recovery. We must not write the lsn stamps to the data files, since at a startup InnoDB deduces from the stamps if the previous shutdown was clean. */ log_buffer_flush_to_disk(); /* Check that the background threads stay suspended */ thread_name = srv_any_background_threads_are_active(); if (thread_name != NULL) { ib_logf(IB_LOG_LEVEL_WARN, "Background thread %s woke up " "during shutdown", thread_name); goto loop; } } srv_shutdown_state = SRV_SHUTDOWN_LAST_PHASE; /* Wake the log tracking thread which will then immediatelly quit because of srv_shutdown_state value */ if (srv_track_changed_pages) { os_event_reset(srv_redo_log_tracked_event); os_event_set(srv_checkpoint_completed_event); } fil_close_all_files(); thread_name = srv_any_background_threads_are_active(); ut_a(!thread_name); return; } if (!srv_read_only_mode) { log_make_checkpoint_at(LSN_MAX, TRUE); } mutex_enter(&log_sys->mutex); tracked_lsn = log_get_tracked_lsn(); lsn = log_sys->lsn; ut_ad(srv_force_recovery != SRV_FORCE_NO_LOG_REDO || lsn == log_sys->last_checkpoint_lsn + LOG_BLOCK_HDR_SIZE); if ((srv_force_recovery != SRV_FORCE_NO_LOG_REDO && lsn != log_sys->last_checkpoint_lsn) || (srv_track_changed_pages && (tracked_lsn != log_sys->last_checkpoint_lsn)) #ifdef UNIV_LOG_ARCHIVE || (srv_log_archive_on && lsn != log_sys->archived_lsn + LOG_BLOCK_HDR_SIZE) #endif /* UNIV_LOG_ARCHIVE */ ) { mutex_exit(&log_sys->mutex); goto loop; } #ifdef UNIV_LOG_ARCHIVE log_archive_close_groups(TRUE); #endif /* UNIV_LOG_ARCHIVE */ mutex_exit(&log_sys->mutex); /* Check that the background threads stay suspended */ thread_name = srv_any_background_threads_are_active(); if (thread_name != NULL) { ib_logf(IB_LOG_LEVEL_WARN, "Background thread %s woke up during shutdown", thread_name); goto loop; } if (!srv_read_only_mode) { fil_flush_file_spaces(FIL_TABLESPACE); fil_flush_file_spaces(FIL_LOG); } /* The call fil_write_flushed_lsn_to_data_files() will pass the buffer pool: therefore it is essential that the buffer pool has been completely flushed to disk! (We do not call fil_write... if the 'very fast' shutdown is enabled.) */ if (!buf_all_freed()) { if (srv_print_verbose_log && count > 600) { ib_logf(IB_LOG_LEVEL_INFO, "Waiting for dirty buffer pages to be flushed"); count = 0; } goto loop; } srv_shutdown_state = SRV_SHUTDOWN_LAST_PHASE; /* Signal the log following thread to quit */ if (srv_track_changed_pages) { os_event_reset(srv_redo_log_tracked_event); os_event_set(srv_checkpoint_completed_event); } /* Make some checks that the server really is quiet */ srv_thread_type type = srv_get_active_thread_type(); ut_a(type == SRV_NONE); bool freed = buf_all_freed(); ut_a(freed); ut_a(lsn == log_sys->lsn); if (lsn < srv_start_lsn) { ib_logf(IB_LOG_LEVEL_ERROR, "Log sequence number at shutdown " LSN_PF " " "is lower than at startup " LSN_PF "!", lsn, srv_start_lsn); } srv_shutdown_lsn = lsn; if (!srv_read_only_mode) { fil_write_flushed_lsn_to_data_files(lsn, 0); fil_flush_file_spaces(FIL_TABLESPACE); } fil_close_all_files(); /* Make some checks that the server really is quiet */ type = srv_get_active_thread_type(); ut_a(type == SRV_NONE); freed = buf_all_freed(); ut_a(freed); ut_a(lsn == log_sys->lsn); } #ifdef UNIV_LOG_DEBUG /******************************************************//** Checks by parsing that the catenated log segment for a single mtr is consistent. */ UNIV_INTERN ibool log_check_log_recs( /*===============*/ const byte* buf, /*!< in: pointer to the start of the log segment in the log_sys->buf log buffer */ ulint len, /*!< in: segment length in bytes */ ib_uint64_t buf_start_lsn) /*!< in: buffer start lsn */ { ib_uint64_t contiguous_lsn; ib_uint64_t scanned_lsn; const byte* start; const byte* end; byte* buf1; byte* scan_buf; ut_ad(mutex_own(&(log_sys->mutex))); if (len == 0) { return(TRUE); } start = ut_align_down(buf, OS_FILE_LOG_BLOCK_SIZE); end = ut_align(buf + len, OS_FILE_LOG_BLOCK_SIZE); buf1 = mem_alloc((end - start) + OS_FILE_LOG_BLOCK_SIZE); scan_buf = ut_align(buf1, OS_FILE_LOG_BLOCK_SIZE); ut_memcpy(scan_buf, start, end - start); recv_scan_log_recs((buf_pool_get_n_pages() - (recv_n_pool_free_frames * srv_buf_pool_instances)) * UNIV_PAGE_SIZE, FALSE, scan_buf, end - start, ut_uint64_align_down(buf_start_lsn, OS_FILE_LOG_BLOCK_SIZE), &contiguous_lsn, &scanned_lsn); ut_a(scanned_lsn == buf_start_lsn + len); ut_a(recv_sys->recovered_lsn == scanned_lsn); mem_free(buf1); return(TRUE); } #endif /* UNIV_LOG_DEBUG */ /******************************************************//** Peeks the current lsn. @return TRUE if success, FALSE if could not get the log system mutex */ UNIV_INTERN ibool log_peek_lsn( /*=========*/ lsn_t* lsn) /*!< out: if returns TRUE, current lsn is here */ { if (0 == mutex_enter_nowait(&(log_sys->mutex))) { *lsn = log_sys->lsn; mutex_exit(&(log_sys->mutex)); return(TRUE); } return(FALSE); } /******************************************************//** Prints info of the log. */ UNIV_INTERN void log_print( /*======*/ FILE* file) /*!< in: file where to print */ { double time_elapsed; time_t current_time; // mutex_enter(&(log_sys->mutex)); fprintf(file, "Log sequence number " LSN_PF "\n" "Log flushed up to " LSN_PF "\n" "Pages flushed up to " LSN_PF "\n" "Last checkpoint at " LSN_PF "\n", log_sys->lsn, log_sys->flushed_to_disk_lsn, log_buf_pool_get_oldest_modification_peek(), log_sys->last_checkpoint_lsn); fprintf(file, "Max checkpoint age " LSN_PF "\n" "Checkpoint age target " LSN_PF "\n" "Modified age " LSN_PF "\n" "Checkpoint age " LSN_PF "\n", log_sys->max_checkpoint_age, log_sys->max_checkpoint_age_async, log_sys->lsn -log_buf_pool_get_oldest_modification_peek(), log_sys->lsn - log_sys->last_checkpoint_lsn); current_time = time(NULL); time_elapsed = difftime(current_time, log_sys->last_printout_time); if (time_elapsed <= 0) { time_elapsed = 1; } fprintf(file, "%lu pending log writes, %lu pending chkp writes\n" "%lu log i/o's done, %.2f log i/o's/second\n", (ulong) log_sys->n_pending_writes, (ulong) log_sys->n_pending_checkpoint_writes, (ulong) log_sys->n_log_ios, ((double)(log_sys->n_log_ios - log_sys->n_log_ios_old) / time_elapsed)); if (srv_track_changed_pages) { /* The maximum tracked LSN age is equal to the maximum checkpoint age */ fprintf(file, "Log tracking enabled\n" "Log tracked up to " LSN_PF "\n" "Max tracked LSN age " LSN_PF "\n", log_get_tracked_lsn_peek(), log_sys->max_checkpoint_age); } log_sys->n_log_ios_old = log_sys->n_log_ios; log_sys->last_printout_time = current_time; //mutex_exit(&(log_sys->mutex)); } /**********************************************************************//** Refreshes the statistics used to print per-second averages. */ UNIV_INTERN void log_refresh_stats(void) /*===================*/ { log_sys->n_log_ios_old = log_sys->n_log_ios; log_sys->last_printout_time = time(NULL); } /********************************************************//** Closes a log group. */ static void log_group_close( /*===========*/ log_group_t* group) /* in,own: log group to close */ { ulint i; for (i = 0; i < group->n_files; i++) { mem_free(group->file_header_bufs_ptr[i]); #ifdef UNIV_LOG_ARCHIVE mem_free(group->archive_file_header_bufs_ptr[i]); #endif /* UNIV_LOG_ARCHIVE */ } mem_free(group->file_header_bufs_ptr); mem_free(group->file_header_bufs); #ifdef UNIV_LOG_ARCHIVE mem_free(group->archive_file_header_bufs_ptr); mem_free(group->archive_file_header_bufs); #endif /* UNIV_LOG_ARCHIVE */ mem_free(group->checkpoint_buf_ptr); mem_free(group); } /********************************************************//** Closes all log groups. */ UNIV_INTERN void log_group_close_all(void) /*=====================*/ { log_group_t* group; group = UT_LIST_GET_FIRST(log_sys->log_groups); while (UT_LIST_GET_LEN(log_sys->log_groups) > 0) { log_group_t* prev_group = group; group = UT_LIST_GET_NEXT(log_groups, group); UT_LIST_REMOVE(log_groups, log_sys->log_groups, prev_group); log_group_close(prev_group); } } /********************************************************//** Shutdown the log system but do not release all the memory. */ UNIV_INTERN void log_shutdown(void) /*==============*/ { log_group_close_all(); mem_free(log_sys->buf_ptr); log_sys->buf_ptr = NULL; log_sys->buf = NULL; mem_free(log_sys->checkpoint_buf_ptr); log_sys->checkpoint_buf_ptr = NULL; log_sys->checkpoint_buf = NULL; mem_free(log_sys->archive_buf_ptr); log_sys->archive_buf_ptr = NULL; log_sys->archive_buf = NULL; os_event_free(log_sys->no_flush_event); os_event_free(log_sys->one_flushed_event); rw_lock_free(&log_sys->checkpoint_lock); mutex_free(&log_sys->mutex); #ifdef UNIV_LOG_ARCHIVE rw_lock_free(&log_sys->archive_lock); os_event_free(log_sys->archiving_on); #endif /* UNIV_LOG_ARCHIVE */ #ifdef UNIV_LOG_DEBUG recv_sys_debug_free(); #endif recv_sys_close(); } /********************************************************//** Free the log system data structures. */ UNIV_INTERN void log_mem_free(void) /*==============*/ { if (log_sys != NULL) { recv_sys_mem_free(); mem_free(log_sys); log_sys = NULL; } } /** Event to wake up the log scrub thread */ UNIV_INTERN os_event_t log_scrub_event = NULL; UNIV_INTERN ibool srv_log_scrub_thread_active = FALSE; /*****************************************************************//* If no log record has been written for a while, fill current log block with dummy records. */ static void log_scrub() /*=========*/ { ulint cur_lbn = log_block_convert_lsn_to_no(log_sys->lsn); if (next_lbn_to_pad == cur_lbn) { log_pad_current_log_block(); } next_lbn_to_pad = log_block_convert_lsn_to_no(log_sys->lsn); } /* log scrubbing interval in ms. */ UNIV_INTERN ulonglong innodb_scrub_log_interval; /*****************************************************************//** This is the main thread for log scrub. It waits for an event and when waked up fills current log block with dummy records and sleeps again. @return this function does not return, it calls os_thread_exit() */ extern "C" UNIV_INTERN os_thread_ret_t DECLARE_THREAD(log_scrub_thread)( /*===============================*/ void* arg __attribute__((unused))) /*!< in: a dummy parameter required by os_thread_create */ { ut_ad(!srv_read_only_mode); srv_log_scrub_thread_active = TRUE; while(srv_shutdown_state == SRV_SHUTDOWN_NONE) { os_event_wait_time(log_scrub_event, innodb_scrub_log_interval * 1000); log_scrub(); os_event_reset(log_scrub_event); } srv_log_scrub_thread_active = FALSE; /* We count the number of threads in os_thread_exit(). A created thread should always use that to exit and not use return() to exit. */ os_thread_exit(NULL); OS_THREAD_DUMMY_RETURN; } #endif /* !UNIV_HOTBACKUP */