diff options
Diffstat (limited to 'storage/innobase/include/buf0flu.ic')
-rw-r--r-- | storage/innobase/include/buf0flu.ic | 106 |
1 files changed, 0 insertions, 106 deletions
diff --git a/storage/innobase/include/buf0flu.ic b/storage/innobase/include/buf0flu.ic deleted file mode 100644 index ae873c42088..00000000000 --- a/storage/innobase/include/buf0flu.ic +++ /dev/null @@ -1,106 +0,0 @@ -/****************************************************** -The database buffer pool flush algorithm - -(c) 1995 Innobase Oy - -Created 11/5/1995 Heikki Tuuri -*******************************************************/ - -#include "buf0buf.h" -#include "mtr0mtr.h" - -/************************************************************************ -Inserts a modified block into the flush list. */ - -void -buf_flush_insert_into_flush_list( -/*=============================*/ - buf_block_t* block); /* in: block which is modified */ -/************************************************************************ -Inserts a modified block into the flush list in the right sorted position. -This function is used by recovery, because there the modifications do not -necessarily come in the order of lsn's. */ - -void -buf_flush_insert_sorted_into_flush_list( -/*====================================*/ - buf_block_t* block); /* in: block which is modified */ - -/************************************************************************ -This function should be called at a mini-transaction commit, if a page was -modified in it. Puts the block to the list of modified blocks, if it is not -already in it. */ -UNIV_INLINE -void -buf_flush_note_modification( -/*========================*/ - buf_block_t* block, /* in: block which is modified */ - mtr_t* mtr) /* in: mtr */ -{ - ut_ad(block); - ut_ad(block->state == BUF_BLOCK_FILE_PAGE); - ut_ad(block->buf_fix_count > 0); -#ifdef UNIV_SYNC_DEBUG - ut_ad(rw_lock_own(&(block->lock), RW_LOCK_EX)); -#endif /* UNIV_SYNC_DEBUG */ - ut_ad(mutex_own(&(buf_pool->mutex))); - - ut_ad(ut_dulint_cmp(mtr->start_lsn, ut_dulint_zero) != 0); - ut_ad(mtr->modifications); - ut_ad(ut_dulint_cmp(block->newest_modification, mtr->end_lsn) <= 0); - - block->newest_modification = mtr->end_lsn; - - if (ut_dulint_is_zero(block->oldest_modification)) { - - block->oldest_modification = mtr->start_lsn; - ut_ad(!ut_dulint_is_zero(block->oldest_modification)); - - buf_flush_insert_into_flush_list(block); - } else { - ut_ad(ut_dulint_cmp(block->oldest_modification, - mtr->start_lsn) <= 0); - } - - ++srv_buf_pool_write_requests; -} - -/************************************************************************ -This function should be called when recovery has modified a buffer page. */ -UNIV_INLINE -void -buf_flush_recv_note_modification( -/*=============================*/ - buf_block_t* block, /* in: block which is modified */ - dulint start_lsn, /* in: start lsn of the first mtr in a - set of mtr's */ - dulint end_lsn) /* in: end lsn of the last mtr in the - set of mtr's */ -{ - ut_ad(block); - ut_ad(block->state == BUF_BLOCK_FILE_PAGE); - ut_ad(block->buf_fix_count > 0); -#ifdef UNIV_SYNC_DEBUG - ut_ad(rw_lock_own(&(block->lock), RW_LOCK_EX)); -#endif /* UNIV_SYNC_DEBUG */ - - mutex_enter(&(buf_pool->mutex)); - - ut_ad(ut_dulint_cmp(block->newest_modification, end_lsn) <= 0); - - block->newest_modification = end_lsn; - - if (ut_dulint_is_zero(block->oldest_modification)) { - - block->oldest_modification = start_lsn; - - ut_ad(!ut_dulint_is_zero(block->oldest_modification)); - - buf_flush_insert_sorted_into_flush_list(block); - } else { - ut_ad(ut_dulint_cmp(block->oldest_modification, - start_lsn) <= 0); - } - - mutex_exit(&(buf_pool->mutex)); -} |