← Back to branch summary

~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to storage/innobase/include/buf0flu.ic

  • Committer: brian
  • Date: 2008-06-25 05:29:13 UTC
  • Revision ID: brian@localhost.localdomain-20080625052913-6upwo0jsrl4lnapl
clean slate

Show diffs side-by-side

added added

removed removed

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