buf0flu.ic
上传用户:romrleung
上传日期:2022-05-23
资源大小:18897k
文件大小:3k
源码类别:

MySQL数据库

开发平台:

Visual C++

  1. /******************************************************
  2. The database buffer pool flush algorithm
  3. (c) 1995 Innobase Oy
  4. Created 11/5/1995 Heikki Tuuri
  5. *******************************************************/
  6. #include "buf0buf.h"
  7. #include "mtr0mtr.h"
  8. /************************************************************************
  9. Inserts a modified block into the flush list. */
  10. void
  11. buf_flush_insert_into_flush_list(
  12. /*=============================*/
  13. buf_block_t* block); /* in: block which is modified */
  14. /************************************************************************
  15. Inserts a modified block into the flush list in the right sorted position.
  16. This function is used by recovery, because there the modifications do not
  17. necessarily come in the order of lsn's. */
  18. void
  19. buf_flush_insert_sorted_into_flush_list(
  20. /*====================================*/
  21. buf_block_t* block); /* in: block which is modified */
  22. /************************************************************************
  23. This function should be called at a mini-transaction commit, if a page was
  24. modified in it. Puts the block to the list of modified blocks, if it is not
  25. already in it. */
  26. UNIV_INLINE
  27. void
  28. buf_flush_note_modification(
  29. /*========================*/
  30. buf_block_t* block, /* in: block which is modified */
  31. mtr_t* mtr) /* in: mtr */
  32. {
  33. ut_ad(block);
  34. ut_ad(block->state == BUF_BLOCK_FILE_PAGE);
  35. ut_ad(block->buf_fix_count > 0);
  36. #ifdef UNIV_SYNC_DEBUG
  37. ut_ad(rw_lock_own(&(block->lock), RW_LOCK_EX));
  38. ut_ad(mutex_own(&(buf_pool->mutex)));
  39. #endif /* UNIV_SYNC_DEBUG */
  40. ut_ad(ut_dulint_cmp(mtr->start_lsn, ut_dulint_zero) != 0);
  41. ut_ad(mtr->modifications);
  42. ut_ad(ut_dulint_cmp(block->newest_modification, mtr->end_lsn) <= 0);
  43. block->newest_modification = mtr->end_lsn;
  44. if (ut_dulint_is_zero(block->oldest_modification)) {
  45. block->oldest_modification = mtr->start_lsn;
  46. ut_ad(!ut_dulint_is_zero(block->oldest_modification));
  47. buf_flush_insert_into_flush_list(block);
  48. } else {
  49. ut_ad(ut_dulint_cmp(block->oldest_modification,
  50. mtr->start_lsn) <= 0);
  51. }
  52. }
  53. /************************************************************************
  54. This function should be called when recovery has modified a buffer page. */
  55. UNIV_INLINE
  56. void
  57. buf_flush_recv_note_modification(
  58. /*=============================*/
  59. buf_block_t* block, /* in: block which is modified */
  60. dulint start_lsn, /* in: start lsn of the first mtr in a
  61. set of mtr's */
  62. dulint end_lsn) /* in: end lsn of the last mtr in the
  63. set of mtr's */
  64. {
  65. ut_ad(block);
  66. ut_ad(block->state == BUF_BLOCK_FILE_PAGE);
  67. ut_ad(block->buf_fix_count > 0);
  68. #ifdef UNIV_SYNC_DEBUG
  69. ut_ad(rw_lock_own(&(block->lock), RW_LOCK_EX));
  70. #endif /* UNIV_SYNC_DEBUG */
  71. mutex_enter(&(buf_pool->mutex));
  72. ut_ad(ut_dulint_cmp(block->newest_modification, end_lsn) <= 0);
  73. block->newest_modification = end_lsn;
  74. if (ut_dulint_is_zero(block->oldest_modification)) {
  75. block->oldest_modification = start_lsn;
  76. ut_ad(!ut_dulint_is_zero(block->oldest_modification));
  77. buf_flush_insert_sorted_into_flush_list(block);
  78. } else {
  79. ut_ad(ut_dulint_cmp(block->oldest_modification,
  80. start_lsn) <= 0);
  81. }
  82. mutex_exit(&(buf_pool->mutex));
  83. }