Commit 203c3eeb authored by unknown's avatar unknown

Merge work:/home/bk/mysql into donna.mysql.fi:/home/my/bk/mysql


Docs/manual.texi:
  Auto merged
parents 0f716142 10f86945
...@@ -6,3 +6,4 @@ monty@work.mysql.com ...@@ -6,3 +6,4 @@ monty@work.mysql.com
sasha@mysql.sashanet.com sasha@mysql.sashanet.com
serg@serg.mysql.com serg@serg.mysql.com
paul@central.snake.net paul@central.snake.net
jcole@main.burghcom.com
...@@ -22530,11 +22530,11 @@ non-transactional table will not change. ...@@ -22530,11 +22530,11 @@ non-transactional table will not change.
If you are using @code{BEGIN} or @code{SET AUTOCOMMIT=0}, you If you are using @code{BEGIN} or @code{SET AUTOCOMMIT=0}, you
should use the @strong{MySQL} binary log for backups instead of the should use the @strong{MySQL} binary log for backups instead of the
old update log; The transaction is stored in the binary log older update log. Transactions are stored in the binary log
in one chunk, during @code{COMMIT}, the to ensure and @code{ROLLBACK}:ed in one chunk, upon @code{COMMIT}, to ensure that transactions which are
transactions are not stored. @xref{Binary log}. rolled back are not stored. @xref{Binary log}.
The following commands automatically ends an transaction (as if you had done The following commands automatically end a transaction (as if you had done
a @code{COMMIT} before executing the command): a @code{COMMIT} before executing the command):
@multitable @columnfractions .33 .33 .33 @multitable @columnfractions .33 .33 .33
...@@ -204,7 +204,28 @@ ulint buf_dbg_counter = 0; /* This is used to insert validation ...@@ -204,7 +204,28 @@ ulint buf_dbg_counter = 0; /* This is used to insert validation
ibool buf_debug_prints = FALSE; /* If this is set TRUE, ibool buf_debug_prints = FALSE; /* If this is set TRUE,
the program prints info whenever the program prints info whenever
read-ahead or flush occurs */ read-ahead or flush occurs */
/************************************************************************
Calculates a page checksum which is stored to the page when it is written
to a file. Note that we must be careful to calculate the same value
on 32-bit and 64-bit architectures. */
ulint
buf_calc_page_checksum(
/*===================*/
/* out: checksum */
byte* page) /* in: buffer page */
{
ulint checksum;
checksum = ut_fold_binary(page, FIL_PAGE_FILE_FLUSH_LSN);
+ ut_fold_binary(page + FIL_PAGE_DATA, UNIV_PAGE_SIZE - FIL_PAGE_DATA
- FIL_PAGE_END_LSN);
checksum = checksum & 0xFFFFFFFF;
return(checksum);
}
/************************************************************************ /************************************************************************
Initializes a buffer control block when the buf_pool is created. */ Initializes a buffer control block when the buf_pool is created. */
static static
...@@ -1171,12 +1192,36 @@ buf_page_io_complete( ...@@ -1171,12 +1192,36 @@ buf_page_io_complete(
dulint id; dulint id;
dict_index_t* index; dict_index_t* index;
ulint io_type; ulint io_type;
ulint checksum;
ut_ad(block); ut_ad(block);
io_type = block->io_fix; io_type = block->io_fix;
if (io_type == BUF_IO_READ) { if (io_type == BUF_IO_READ) {
checksum = buf_calc_page_checksum(block->frame);
/* From version 3.23.38 up we store the page checksum
to the 4 upper bytes of the page end lsn field */
if ((mach_read_from_4(block->frame + FIL_PAGE_LSN + 4)
!= mach_read_from_4(block->frame + UNIV_PAGE_SIZE
- FIL_PAGE_END_LSN + 4))
|| (checksum != mach_read_from_4(block->frame
+ UNIV_PAGE_SIZE
- FIL_PAGE_END_LSN)
&& mach_read_from_4(block->frame + FIL_PAGE_LSN)
!= mach_read_from_4(block->frame
+ UNIV_PAGE_SIZE
- FIL_PAGE_END_LSN))) {
fprintf(stderr,
"InnoDB: Database page corruption or a failed\n"
"InnoDB: file read of page %lu.\n", block->offset);
fprintf(stderr,
"InnoDB: You may have to recover from a backup.\n");
exit(1);
}
if (recv_recovery_is_on()) { if (recv_recovery_is_on()) {
recv_recover_page(TRUE, block->frame, block->space, recv_recover_page(TRUE, block->frame, block->space,
block->offset); block->offset);
...@@ -1208,17 +1253,8 @@ buf_page_io_complete( ...@@ -1208,17 +1253,8 @@ buf_page_io_complete(
ut_ad(buf_pool->n_pend_reads > 0); ut_ad(buf_pool->n_pend_reads > 0);
buf_pool->n_pend_reads--; buf_pool->n_pend_reads--;
buf_pool->n_pages_read++; buf_pool->n_pages_read++;
/*
if (0 != ut_dulint_cmp(
mach_read_from_8(block->frame + FIL_PAGE_LSN),
mach_read_from_8(block->frame + UNIV_PAGE_SIZE
- FIL_PAGE_END_LSN))) {
printf("DB error: file page corrupted!\n");
ut_error;
}
*/
rw_lock_x_unlock_gen(&(block->lock), BUF_IO_READ); rw_lock_x_unlock_gen(&(block->lock), BUF_IO_READ);
rw_lock_x_unlock_gen(&(block->read_lock), BUF_IO_READ); rw_lock_x_unlock_gen(&(block->read_lock), BUF_IO_READ);
......
...@@ -222,6 +222,12 @@ buf_flush_write_block_low( ...@@ -222,6 +222,12 @@ buf_flush_write_block_low(
mach_write_to_8(block->frame + UNIV_PAGE_SIZE - FIL_PAGE_END_LSN, mach_write_to_8(block->frame + UNIV_PAGE_SIZE - FIL_PAGE_END_LSN,
block->newest_modification); block->newest_modification);
/* We overwrite the first 4 bytes of the end lsn field to store
a page checksum */
mach_write_to_4(block->frame + UNIV_PAGE_SIZE - FIL_PAGE_END_LSN,
buf_calc_page_checksum(block->frame));
fil_io(OS_FILE_WRITE | OS_AIO_SIMULATED_WAKE_LATER, fil_io(OS_FILE_WRITE | OS_AIO_SIMULATED_WAKE_LATER,
FALSE, block->space, block->offset, 0, UNIV_PAGE_SIZE, FALSE, block->space, block->offset, 0, UNIV_PAGE_SIZE,
(void*)block->frame, (void*)block); (void*)block->frame, (void*)block);
......
...@@ -342,6 +342,16 @@ buf_frame_get_modify_clock( ...@@ -342,6 +342,16 @@ buf_frame_get_modify_clock(
/*=======================*/ /*=======================*/
/* out: value */ /* out: value */
buf_frame_t* frame); /* in: pointer to a frame */ buf_frame_t* frame); /* in: pointer to a frame */
/************************************************************************
Calculates a page checksum which is stored to the page when it is written
to a file. Note that we must be careful to calculate the same value
on 32-bit and 64-bit architectures. */
ulint
buf_calc_page_checksum(
/*===================*/
/* out: checksum */
byte* page); /* in: buffer page */
/************************************************************************** /**************************************************************************
Gets the page number of a pointer pointing within a buffer frame containing Gets the page number of a pointer pointing within a buffer frame containing
a file page. */ a file page. */
......
...@@ -882,12 +882,6 @@ recv_recover_page( ...@@ -882,12 +882,6 @@ recv_recover_page(
recv = UT_LIST_GET_NEXT(rec_list, recv); recv = UT_LIST_GET_NEXT(rec_list, recv);
} }
/* If the following assert fails, the file page is incompletely
written, and a recovery from a backup is required */
ut_a(0 == ut_dulint_cmp(mach_read_from_8(page + FIL_PAGE_LSN),
mach_read_from_8(page + UNIV_PAGE_SIZE
- FIL_PAGE_END_LSN)));
mutex_enter(&(recv_sys->mutex)); mutex_enter(&(recv_sys->mutex));
recv_addr->state = RECV_PROCESSED; recv_addr->state = RECV_PROCESSED;
......
...@@ -70,7 +70,7 @@ row_sel_sec_rec_is_for_clust_rec( ...@@ -70,7 +70,7 @@ row_sel_sec_rec_is_for_clust_rec(
n = dict_index_get_n_ordering_defined_by_user(sec_index); n = dict_index_get_n_ordering_defined_by_user(sec_index);
for (i = 0; i++; i < n) { for (i = 0; i < n; i++) {
col = dict_field_get_col( col = dict_field_get_col(
dict_index_get_nth_field(sec_index, i)); dict_index_get_nth_field(sec_index, i));
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment