diff options
| author | Jeff Mahoney <jeffm@suse.com> | 2009-03-30 14:02:45 -0400 |
|---|---|---|
| committer | Linus Torvalds <torvalds@linux-foundation.org> | 2009-03-30 15:16:39 -0400 |
| commit | a9dd364358fbdc68faee5d20c2d648c320dc3cf0 (patch) | |
| tree | effcf61e5e198083faff82dc1e0bd6071639fca8 | |
| parent | 0222e6571c332563a48d4cf5487b67feabe60b5e (diff) | |
reiserfs: rename p_s_sb to sb
This patch is a simple s/p_s_sb/sb/g to the reiserfs code. This is the
first in a series of patches to rip out some of the awful variable
naming in reiserfs.
Signed-off-by: Jeff Mahoney <jeffm@suse.com>
Signed-off-by: Linus Torvalds <torvalds@linux-foundation.org>
| -rw-r--r-- | fs/reiserfs/fix_node.c | 46 | ||||
| -rw-r--r-- | fs/reiserfs/journal.c | 735 | ||||
| -rw-r--r-- | fs/reiserfs/stree.c | 126 | ||||
| -rw-r--r-- | fs/reiserfs/tail_conversion.c | 16 | ||||
| -rw-r--r-- | include/linux/reiserfs_fs.h | 14 |
5 files changed, 468 insertions, 469 deletions
diff --git a/fs/reiserfs/fix_node.c b/fs/reiserfs/fix_node.c index a3be7da3e2b9..799c0ce24291 100644 --- a/fs/reiserfs/fix_node.c +++ b/fs/reiserfs/fix_node.c | |||
| @@ -785,7 +785,7 @@ static int get_empty_nodes(struct tree_balance *p_s_tb, int n_h) | |||
| 785 | b_blocknr_t *p_n_blocknr, a_n_blocknrs[MAX_AMOUNT_NEEDED] = { 0, }; | 785 | b_blocknr_t *p_n_blocknr, a_n_blocknrs[MAX_AMOUNT_NEEDED] = { 0, }; |
| 786 | int n_counter, n_number_of_freeblk, n_amount_needed, /* number of needed empty blocks */ | 786 | int n_counter, n_number_of_freeblk, n_amount_needed, /* number of needed empty blocks */ |
| 787 | n_retval = CARRY_ON; | 787 | n_retval = CARRY_ON; |
| 788 | struct super_block *p_s_sb = p_s_tb->tb_sb; | 788 | struct super_block *sb = p_s_tb->tb_sb; |
| 789 | 789 | ||
| 790 | /* number_of_freeblk is the number of empty blocks which have been | 790 | /* number_of_freeblk is the number of empty blocks which have been |
| 791 | acquired for use by the balancing algorithm minus the number of | 791 | acquired for use by the balancing algorithm minus the number of |
| @@ -830,7 +830,7 @@ static int get_empty_nodes(struct tree_balance *p_s_tb, int n_h) | |||
| 830 | RFALSE(!*p_n_blocknr, | 830 | RFALSE(!*p_n_blocknr, |
| 831 | "PAP-8135: reiserfs_new_blocknrs failed when got new blocks"); | 831 | "PAP-8135: reiserfs_new_blocknrs failed when got new blocks"); |
| 832 | 832 | ||
| 833 | p_s_new_bh = sb_getblk(p_s_sb, *p_n_blocknr); | 833 | p_s_new_bh = sb_getblk(sb, *p_n_blocknr); |
| 834 | RFALSE(buffer_dirty(p_s_new_bh) || | 834 | RFALSE(buffer_dirty(p_s_new_bh) || |
| 835 | buffer_journaled(p_s_new_bh) || | 835 | buffer_journaled(p_s_new_bh) || |
| 836 | buffer_journal_dirty(p_s_new_bh), | 836 | buffer_journal_dirty(p_s_new_bh), |
| @@ -899,7 +899,7 @@ static int get_rfree(struct tree_balance *tb, int h) | |||
| 899 | static int is_left_neighbor_in_cache(struct tree_balance *p_s_tb, int n_h) | 899 | static int is_left_neighbor_in_cache(struct tree_balance *p_s_tb, int n_h) |
| 900 | { | 900 | { |
| 901 | struct buffer_head *p_s_father, *left; | 901 | struct buffer_head *p_s_father, *left; |
| 902 | struct super_block *p_s_sb = p_s_tb->tb_sb; | 902 | struct super_block *sb = p_s_tb->tb_sb; |
| 903 | b_blocknr_t n_left_neighbor_blocknr; | 903 | b_blocknr_t n_left_neighbor_blocknr; |
| 904 | int n_left_neighbor_position; | 904 | int n_left_neighbor_position; |
| 905 | 905 | ||
| @@ -924,7 +924,7 @@ static int is_left_neighbor_in_cache(struct tree_balance *p_s_tb, int n_h) | |||
| 924 | n_left_neighbor_blocknr = | 924 | n_left_neighbor_blocknr = |
| 925 | B_N_CHILD_NUM(p_s_tb->FL[n_h], n_left_neighbor_position); | 925 | B_N_CHILD_NUM(p_s_tb->FL[n_h], n_left_neighbor_position); |
| 926 | /* Look for the left neighbor in the cache. */ | 926 | /* Look for the left neighbor in the cache. */ |
| 927 | if ((left = sb_find_get_block(p_s_sb, n_left_neighbor_blocknr))) { | 927 | if ((left = sb_find_get_block(sb, n_left_neighbor_blocknr))) { |
| 928 | 928 | ||
| 929 | RFALSE(buffer_uptodate(left) && !B_IS_IN_TREE(left), | 929 | RFALSE(buffer_uptodate(left) && !B_IS_IN_TREE(left), |
| 930 | "vs-8170: left neighbor (%b %z) is not in the tree", | 930 | "vs-8170: left neighbor (%b %z) is not in the tree", |
| @@ -1942,14 +1942,14 @@ static int get_neighbors(struct tree_balance *p_s_tb, int n_h) | |||
| 1942 | int n_child_position, | 1942 | int n_child_position, |
| 1943 | n_path_offset = PATH_H_PATH_OFFSET(p_s_tb->tb_path, n_h + 1); | 1943 | n_path_offset = PATH_H_PATH_OFFSET(p_s_tb->tb_path, n_h + 1); |
| 1944 | unsigned long n_son_number; | 1944 | unsigned long n_son_number; |
| 1945 | struct super_block *p_s_sb = p_s_tb->tb_sb; | 1945 | struct super_block *sb = p_s_tb->tb_sb; |
| 1946 | struct buffer_head *p_s_bh; | 1946 | struct buffer_head *p_s_bh; |
| 1947 | 1947 | ||
| 1948 | PROC_INFO_INC(p_s_sb, get_neighbors[n_h]); | 1948 | PROC_INFO_INC(sb, get_neighbors[n_h]); |
| 1949 | 1949 | ||
| 1950 | if (p_s_tb->lnum[n_h]) { | 1950 | if (p_s_tb->lnum[n_h]) { |
| 1951 | /* We need left neighbor to balance S[n_h]. */ | 1951 | /* We need left neighbor to balance S[n_h]. */ |
| 1952 | PROC_INFO_INC(p_s_sb, need_l_neighbor[n_h]); | 1952 | PROC_INFO_INC(sb, need_l_neighbor[n_h]); |
| 1953 | p_s_bh = PATH_OFFSET_PBUFFER(p_s_tb->tb_path, n_path_offset); | 1953 | p_s_bh = PATH_OFFSET_PBUFFER(p_s_tb->tb_path, n_path_offset); |
| 1954 | 1954 | ||
| 1955 | RFALSE(p_s_bh == p_s_tb->FL[n_h] && | 1955 | RFALSE(p_s_bh == p_s_tb->FL[n_h] && |
| @@ -1961,12 +1961,12 @@ static int get_neighbors(struct tree_balance *p_s_tb, int n_h) | |||
| 1961 | p_s_tb->FL[n_h]) ? p_s_tb->lkey[n_h] : B_NR_ITEMS(p_s_tb-> | 1961 | p_s_tb->FL[n_h]) ? p_s_tb->lkey[n_h] : B_NR_ITEMS(p_s_tb-> |
| 1962 | FL[n_h]); | 1962 | FL[n_h]); |
| 1963 | n_son_number = B_N_CHILD_NUM(p_s_tb->FL[n_h], n_child_position); | 1963 | n_son_number = B_N_CHILD_NUM(p_s_tb->FL[n_h], n_child_position); |
| 1964 | p_s_bh = sb_bread(p_s_sb, n_son_number); | 1964 | p_s_bh = sb_bread(sb, n_son_number); |
| 1965 | if (!p_s_bh) | 1965 | if (!p_s_bh) |
| 1966 | return IO_ERROR; | 1966 | return IO_ERROR; |
| 1967 | if (FILESYSTEM_CHANGED_TB(p_s_tb)) { | 1967 | if (FILESYSTEM_CHANGED_TB(p_s_tb)) { |
| 1968 | brelse(p_s_bh); | 1968 | brelse(p_s_bh); |
| 1969 | PROC_INFO_INC(p_s_sb, get_neighbors_restart[n_h]); | 1969 | PROC_INFO_INC(sb, get_neighbors_restart[n_h]); |
| 1970 | return REPEAT_SEARCH; | 1970 | return REPEAT_SEARCH; |
| 1971 | } | 1971 | } |
| 1972 | 1972 | ||
| @@ -1986,7 +1986,7 @@ static int get_neighbors(struct tree_balance *p_s_tb, int n_h) | |||
| 1986 | } | 1986 | } |
| 1987 | 1987 | ||
| 1988 | if (p_s_tb->rnum[n_h]) { /* We need right neighbor to balance S[n_path_offset]. */ | 1988 | if (p_s_tb->rnum[n_h]) { /* We need right neighbor to balance S[n_path_offset]. */ |
| 1989 | PROC_INFO_INC(p_s_sb, need_r_neighbor[n_h]); | 1989 | PROC_INFO_INC(sb, need_r_neighbor[n_h]); |
| 1990 | p_s_bh = PATH_OFFSET_PBUFFER(p_s_tb->tb_path, n_path_offset); | 1990 | p_s_bh = PATH_OFFSET_PBUFFER(p_s_tb->tb_path, n_path_offset); |
| 1991 | 1991 | ||
| 1992 | RFALSE(p_s_bh == p_s_tb->FR[n_h] && | 1992 | RFALSE(p_s_bh == p_s_tb->FR[n_h] && |
| @@ -1998,12 +1998,12 @@ static int get_neighbors(struct tree_balance *p_s_tb, int n_h) | |||
| 1998 | n_child_position = | 1998 | n_child_position = |
| 1999 | (p_s_bh == p_s_tb->FR[n_h]) ? p_s_tb->rkey[n_h] + 1 : 0; | 1999 | (p_s_bh == p_s_tb->FR[n_h]) ? p_s_tb->rkey[n_h] + 1 : 0; |
| 2000 | n_son_number = B_N_CHILD_NUM(p_s_tb->FR[n_h], n_child_position); | 2000 | n_son_number = B_N_CHILD_NUM(p_s_tb->FR[n_h], n_child_position); |
| 2001 | p_s_bh = sb_bread(p_s_sb, n_son_number); | 2001 | p_s_bh = sb_bread(sb, n_son_number); |
| 2002 | if (!p_s_bh) | 2002 | if (!p_s_bh) |
| 2003 | return IO_ERROR; | 2003 | return IO_ERROR; |
| 2004 | if (FILESYSTEM_CHANGED_TB(p_s_tb)) { | 2004 | if (FILESYSTEM_CHANGED_TB(p_s_tb)) { |
| 2005 | brelse(p_s_bh); | 2005 | brelse(p_s_bh); |
| 2006 | PROC_INFO_INC(p_s_sb, get_neighbors_restart[n_h]); | 2006 | PROC_INFO_INC(sb, get_neighbors_restart[n_h]); |
| 2007 | return REPEAT_SEARCH; | 2007 | return REPEAT_SEARCH; |
| 2008 | } | 2008 | } |
| 2009 | brelse(p_s_tb->R[n_h]); | 2009 | brelse(p_s_tb->R[n_h]); |
| @@ -2089,51 +2089,51 @@ static int get_mem_for_virtual_node(struct tree_balance *tb) | |||
| 2089 | } | 2089 | } |
| 2090 | 2090 | ||
| 2091 | #ifdef CONFIG_REISERFS_CHECK | 2091 | #ifdef CONFIG_REISERFS_CHECK |
| 2092 | static void tb_buffer_sanity_check(struct super_block *p_s_sb, | 2092 | static void tb_buffer_sanity_check(struct super_block *sb, |
| 2093 | struct buffer_head *p_s_bh, | 2093 | struct buffer_head *p_s_bh, |
| 2094 | const char *descr, int level) | 2094 | const char *descr, int level) |
| 2095 | { | 2095 | { |
| 2096 | if (p_s_bh) { | 2096 | if (p_s_bh) { |
| 2097 | if (atomic_read(&(p_s_bh->b_count)) <= 0) { | 2097 | if (atomic_read(&(p_s_bh->b_count)) <= 0) { |
| 2098 | 2098 | ||
| 2099 | reiserfs_panic(p_s_sb, "jmacd-1", "negative or zero " | 2099 | reiserfs_panic(sb, "jmacd-1", "negative or zero " |
| 2100 | "reference counter for buffer %s[%d] " | 2100 | "reference counter for buffer %s[%d] " |
| 2101 | "(%b)", descr, level, p_s_bh); | 2101 | "(%b)", descr, level, p_s_bh); |
| 2102 | } | 2102 | } |
| 2103 | 2103 | ||
| 2104 | if (!buffer_uptodate(p_s_bh)) { | 2104 | if (!buffer_uptodate(p_s_bh)) { |
| 2105 | reiserfs_panic(p_s_sb, "jmacd-2", "buffer is not up " | 2105 | reiserfs_panic(sb, "jmacd-2", "buffer is not up " |
| 2106 | "to date %s[%d] (%b)", | 2106 | "to date %s[%d] (%b)", |
| 2107 | descr, level, p_s_bh); | 2107 | descr, level, p_s_bh); |
| 2108 | } | 2108 | } |
| 2109 | 2109 | ||
| 2110 | if (!B_IS_IN_TREE(p_s_bh)) { | 2110 | if (!B_IS_IN_TREE(p_s_bh)) { |
| 2111 | reiserfs_panic(p_s_sb, "jmacd-3", "buffer is not " | 2111 | reiserfs_panic(sb, "jmacd-3", "buffer is not " |
| 2112 | "in tree %s[%d] (%b)", | 2112 | "in tree %s[%d] (%b)", |
| 2113 | descr, level, p_s_bh); | 2113 | descr, level, p_s_bh); |
| 2114 | } | 2114 | } |
| 2115 | 2115 | ||
| 2116 | if (p_s_bh->b_bdev != p_s_sb->s_bdev) { | 2116 | if (p_s_bh->b_bdev != sb->s_bdev) { |
| 2117 | reiserfs_panic(p_s_sb, "jmacd-4", "buffer has wrong " | 2117 | reiserfs_panic(sb, "jmacd-4", "buffer has wrong " |
| 2118 | "device %s[%d] (%b)", | 2118 | "device %s[%d] (%b)", |
| 2119 | descr, level, p_s_bh); | 2119 | descr, level, p_s_bh); |
| 2120 | } | 2120 | } |
| 2121 | 2121 | ||
| 2122 | if (p_s_bh->b_size != p_s_sb->s_blocksize) { | 2122 | if (p_s_bh->b_size != sb->s_blocksize) { |
| 2123 | reiserfs_panic(p_s_sb, "jmacd-5", "buffer has wrong " | 2123 | reiserfs_panic(sb, "jmacd-5", "buffer has wrong " |
| 2124 | "blocksize %s[%d] (%b)", | 2124 | "blocksize %s[%d] (%b)", |
| 2125 | descr, level, p_s_bh); | 2125 | descr, level, p_s_bh); |
| 2126 | } | 2126 | } |
| 2127 | 2127 | ||
| 2128 | if (p_s_bh->b_blocknr > SB_BLOCK_COUNT(p_s_sb)) { | 2128 | if (p_s_bh->b_blocknr > SB_BLOCK_COUNT(sb)) { |
| 2129 | reiserfs_panic(p_s_sb, "jmacd-6", "buffer block " | 2129 | reiserfs_panic(sb, "jmacd-6", "buffer block " |
| 2130 | "number too high %s[%d] (%b)", | 2130 | "number too high %s[%d] (%b)", |
| 2131 | descr, level, p_s_bh); | 2131 | descr, level, p_s_bh); |
| 2132 | } | 2132 | } |
| 2133 | } | 2133 | } |
| 2134 | } | 2134 | } |
| 2135 | #else | 2135 | #else |
| 2136 | static void tb_buffer_sanity_check(struct super_block *p_s_sb, | 2136 | static void tb_buffer_sanity_check(struct super_block *sb, |
| 2137 | struct buffer_head *p_s_bh, | 2137 | struct buffer_head *p_s_bh, |
| 2138 | const char *descr, int level) | 2138 | const char *descr, int level) |
| 2139 | {; | 2139 | {; |
diff --git a/fs/reiserfs/journal.c b/fs/reiserfs/journal.c index 4f787462becc..77f5bb746bf0 100644 --- a/fs/reiserfs/journal.c +++ b/fs/reiserfs/journal.c | |||
| @@ -97,7 +97,7 @@ static int flush_commit_list(struct super_block *s, | |||
| 97 | struct reiserfs_journal_list *jl, int flushall); | 97 | struct reiserfs_journal_list *jl, int flushall); |
| 98 | static int can_dirty(struct reiserfs_journal_cnode *cn); | 98 | static int can_dirty(struct reiserfs_journal_cnode *cn); |
| 99 | static int journal_join(struct reiserfs_transaction_handle *th, | 99 | static int journal_join(struct reiserfs_transaction_handle *th, |
| 100 | struct super_block *p_s_sb, unsigned long nblocks); | 100 | struct super_block *sb, unsigned long nblocks); |
| 101 | static int release_journal_dev(struct super_block *super, | 101 | static int release_journal_dev(struct super_block *super, |
| 102 | struct reiserfs_journal *journal); | 102 | struct reiserfs_journal *journal); |
| 103 | static int dirty_one_transaction(struct super_block *s, | 103 | static int dirty_one_transaction(struct super_block *s, |
| @@ -113,12 +113,12 @@ enum { | |||
| 113 | }; | 113 | }; |
| 114 | 114 | ||
| 115 | static int do_journal_begin_r(struct reiserfs_transaction_handle *th, | 115 | static int do_journal_begin_r(struct reiserfs_transaction_handle *th, |
| 116 | struct super_block *p_s_sb, | 116 | struct super_block *sb, |
| 117 | unsigned long nblocks, int join); | 117 | unsigned long nblocks, int join); |
| 118 | 118 | ||
| 119 | static void init_journal_hash(struct super_block *p_s_sb) | 119 | static void init_journal_hash(struct super_block *sb) |
| 120 | { | 120 | { |
| 121 | struct reiserfs_journal *journal = SB_JOURNAL(p_s_sb); | 121 | struct reiserfs_journal *journal = SB_JOURNAL(sb); |
| 122 | memset(journal->j_hash_table, 0, | 122 | memset(journal->j_hash_table, 0, |
| 123 | JOURNAL_HASH_SIZE * sizeof(struct reiserfs_journal_cnode *)); | 123 | JOURNAL_HASH_SIZE * sizeof(struct reiserfs_journal_cnode *)); |
| 124 | } | 124 | } |
| @@ -145,7 +145,7 @@ static void disable_barrier(struct super_block *s) | |||
| 145 | } | 145 | } |
| 146 | 146 | ||
| 147 | static struct reiserfs_bitmap_node *allocate_bitmap_node(struct super_block | 147 | static struct reiserfs_bitmap_node *allocate_bitmap_node(struct super_block |
| 148 | *p_s_sb) | 148 | *sb) |
| 149 | { | 149 | { |
| 150 | struct reiserfs_bitmap_node *bn; | 150 | struct reiserfs_bitmap_node *bn; |
| 151 | static int id; | 151 | static int id; |
| @@ -154,7 +154,7 @@ static struct reiserfs_bitmap_node *allocate_bitmap_node(struct super_block | |||
| 154 | if (!bn) { | 154 | if (!bn) { |
| 155 | return NULL; | 155 | return NULL; |
| 156 | } | 156 | } |
| 157 | bn->data = kzalloc(p_s_sb->s_blocksize, GFP_NOFS); | 157 | bn->data = kzalloc(sb->s_blocksize, GFP_NOFS); |
| 158 | if (!bn->data) { | 158 | if (!bn->data) { |
| 159 | kfree(bn); | 159 | kfree(bn); |
| 160 | return NULL; | 160 | return NULL; |
| @@ -164,9 +164,9 @@ static struct reiserfs_bitmap_node *allocate_bitmap_node(struct super_block | |||
| 164 | return bn; | 164 | return bn; |
| 165 | } | 165 | } |
| 166 | 166 | ||
| 167 | static struct reiserfs_bitmap_node *get_bitmap_node(struct super_block *p_s_sb) | 167 | static struct reiserfs_bitmap_node *get_bitmap_node(struct super_block *sb) |
| 168 | { | 168 | { |
| 169 | struct reiserfs_journal *journal = SB_JOURNAL(p_s_sb); | 169 | struct reiserfs_journal *journal = SB_JOURNAL(sb); |
| 170 | struct reiserfs_bitmap_node *bn = NULL; | 170 | struct reiserfs_bitmap_node *bn = NULL; |
| 171 | struct list_head *entry = journal->j_bitmap_nodes.next; | 171 | struct list_head *entry = journal->j_bitmap_nodes.next; |
| 172 | 172 | ||
| @@ -176,21 +176,21 @@ static struct reiserfs_bitmap_node *get_bitmap_node(struct super_block *p_s_sb) | |||
| 176 | if (entry != &journal->j_bitmap_nodes) { | 176 | if (entry != &journal->j_bitmap_nodes) { |
| 177 | bn = list_entry(entry, struct reiserfs_bitmap_node, list); | 177 | bn = list_entry(entry, struct reiserfs_bitmap_node, list); |
| 178 | list_del(entry); | 178 | list_del(entry); |
| 179 | memset(bn->data, 0, p_s_sb->s_blocksize); | 179 | memset(bn->data, 0, sb->s_blocksize); |
| 180 | journal->j_free_bitmap_nodes--; | 180 | journal->j_free_bitmap_nodes--; |
| 181 | return bn; | 181 | return bn; |
| 182 | } | 182 | } |
| 183 | bn = allocate_bitmap_node(p_s_sb); | 183 | bn = allocate_bitmap_node(sb); |
| 184 | if (!bn) { | 184 | if (!bn) { |
| 185 | yield(); | 185 | yield(); |
| 186 | goto repeat; | 186 | goto repeat; |
| 187 | } | 187 | } |
| 188 | return bn; | 188 | return bn; |
| 189 | } | 189 | } |
| 190 | static inline void free_bitmap_node(struct super_block *p_s_sb, | 190 | static inline void free_bitmap_node(struct super_block *sb, |
| 191 | struct reiserfs_bitmap_node *bn) | 191 | struct reiserfs_bitmap_node *bn) |
| 192 | { | 192 | { |
| 193 | struct reiserfs_journal *journal = SB_JOURNAL(p_s_sb); | 193 | struct reiserfs_journal *journal = SB_JOURNAL(sb); |
| 194 | journal->j_used_bitmap_nodes--; | 194 | journal->j_used_bitmap_nodes--; |
| 195 | if (journal->j_free_bitmap_nodes > REISERFS_MAX_BITMAP_NODES) { | 195 | if (journal->j_free_bitmap_nodes > REISERFS_MAX_BITMAP_NODES) { |
| 196 | kfree(bn->data); | 196 | kfree(bn->data); |
| @@ -201,13 +201,13 @@ static inline void free_bitmap_node(struct super_block *p_s_sb, | |||
| 201 | } | 201 | } |
| 202 | } | 202 | } |
| 203 | 203 | ||
| 204 | static void allocate_bitmap_nodes(struct super_block *p_s_sb) | 204 | static void allocate_bitmap_nodes(struct super_block *sb) |
| 205 | { | 205 | { |
| 206 | int i; | 206 | int i; |
| 207 | struct reiserfs_journal *journal = SB_JOURNAL(p_s_sb); | 207 | struct reiserfs_journal *journal = SB_JOURNAL(sb); |
| 208 | struct reiserfs_bitmap_node *bn = NULL; | 208 | struct reiserfs_bitmap_node *bn = NULL; |
| 209 | for (i = 0; i < REISERFS_MIN_BITMAP_NODES; i++) { | 209 | for (i = 0; i < REISERFS_MIN_BITMAP_NODES; i++) { |
| 210 | bn = allocate_bitmap_node(p_s_sb); | 210 | bn = allocate_bitmap_node(sb); |
| 211 | if (bn) { | 211 | if (bn) { |
| 212 | list_add(&bn->list, &journal->j_bitmap_nodes); | 212 | list_add(&bn->list, &journal->j_bitmap_nodes); |
| 213 | journal->j_free_bitmap_nodes++; | 213 | journal->j_free_bitmap_nodes++; |
| @@ -217,30 +217,30 @@ static void allocate_bitmap_nodes(struct super_block *p_s_sb) | |||
| 217 | } | 217 | } |
| 218 | } | 218 | } |
| 219 | 219 | ||
| 220 | static int set_bit_in_list_bitmap(struct super_block *p_s_sb, | 220 | static int set_bit_in_list_bitmap(struct super_block *sb, |
| 221 | b_blocknr_t block, | 221 | b_blocknr_t block, |
| 222 | struct reiserfs_list_bitmap *jb) | 222 | struct reiserfs_list_bitmap *jb) |
| 223 | { | 223 | { |
| 224 | unsigned int bmap_nr = block / (p_s_sb->s_blocksize << 3); | 224 | unsigned int bmap_nr = block / (sb->s_blocksize << 3); |
| 225 | unsigned int bit_nr = block % (p_s_sb->s_blocksize << 3); | 225 | unsigned int bit_nr = block % (sb->s_blocksize << 3); |
| 226 | 226 | ||
| 227 | if (!jb->bitmaps[bmap_nr]) { | 227 | if (!jb->bitmaps[bmap_nr]) { |
| 228 | jb->bitmaps[bmap_nr] = get_bitmap_node(p_s_sb); | 228 | jb->bitmaps[bmap_nr] = get_bitmap_node(sb); |
| 229 | } | 229 | } |
| 230 | set_bit(bit_nr, (unsigned long *)jb->bitmaps[bmap_nr]->data); | 230 | set_bit(bit_nr, (unsigned long *)jb->bitmaps[bmap_nr]->data); |
| 231 | return 0; | 231 | return 0; |
| 232 | } | 232 | } |
| 233 | 233 | ||
| 234 | static void cleanup_bitmap_list(struct super_block *p_s_sb, | 234 | static void cleanup_bitmap_list(struct super_block *sb, |
| 235 | struct reiserfs_list_bitmap *jb) | 235 | struct reiserfs_list_bitmap *jb) |
| 236 | { | 236 | { |
| 237 | int i; | 237 | int i; |
| 238 | if (jb->bitmaps == NULL) | 238 | if (jb->bitmaps == NULL) |
| 239 | return; | 239 | return; |
| 240 | 240 | ||
| 241 | for (i = 0; i < reiserfs_bmap_count(p_s_sb); i++) { | 241 | for (i = 0; i < reiserfs_bmap_count(sb); i++) { |
| 242 | if (jb->bitmaps[i]) { | 242 | if (jb->bitmaps[i]) { |
| 243 | free_bitmap_node(p_s_sb, jb->bitmaps[i]); | 243 | free_bitmap_node(sb, jb->bitmaps[i]); |
| 244 | jb->bitmaps[i] = NULL; | 244 | jb->bitmaps[i] = NULL; |
| 245 | } | 245 | } |
| 246 | } | 246 | } |
| @@ -249,7 +249,7 @@ static void cleanup_bitmap_list(struct super_block *p_s_sb, | |||
| 249 | /* | 249 | /* |
| 250 | ** only call this on FS unmount. | 250 | ** only call this on FS unmount. |
| 251 | */ | 251 | */ |
| 252 | static int free_list_bitmaps(struct super_block *p_s_sb, | 252 | static int free_list_bitmaps(struct super_block *sb, |
| 253 | struct reiserfs_list_bitmap *jb_array) | 253 | struct reiserfs_list_bitmap *jb_array) |
| 254 | { | 254 | { |
| 255 | int i; | 255 | int i; |
| @@ -257,16 +257,16 @@ static int free_list_bitmaps(struct super_block *p_s_sb, | |||
| 257 | for (i = 0; i < JOURNAL_NUM_BITMAPS; i++) { | 257 | for (i = 0; i < JOURNAL_NUM_BITMAPS; i++) { |
| 258 | jb = jb_array + i; | 258 | jb = jb_array + i; |
| 259 | jb->journal_list = NULL; | 259 | jb->journal_list = NULL; |
| 260 | cleanup_bitmap_list(p_s_sb, jb); | 260 | cleanup_bitmap_list(sb, jb); |
| 261 | vfree(jb->bitmaps); | 261 | vfree(jb->bitmaps); |
| 262 | jb->bitmaps = NULL; | 262 | jb->bitmaps = NULL; |
| 263 | } | 263 | } |
| 264 | return 0; | 264 | return 0; |
| 265 | } | 265 | } |
| 266 | 266 | ||
| 267 | static int free_bitmap_nodes(struct super_block *p_s_sb) | 267 | static int free_bitmap_nodes(struct super_block *sb) |
| 268 | { | 268 | { |
| 269 | struct reiserfs_journal *journal = SB_JOURNAL(p_s_sb); | 269 | struct reiserfs_journal *journal = SB_JOURNAL(sb); |
| 270 | struct list_head *next = journal->j_bitmap_nodes.next; | 270 | struct list_head *next = journal->j_bitmap_nodes.next; |
| 271 | struct reiserfs_bitmap_node *bn; | 271 | struct reiserfs_bitmap_node *bn; |
| 272 | 272 | ||
| @@ -286,7 +286,7 @@ static int free_bitmap_nodes(struct super_block *p_s_sb) | |||
| 286 | ** get memory for JOURNAL_NUM_BITMAPS worth of bitmaps. | 286 | ** get memory for JOURNAL_NUM_BITMAPS worth of bitmaps. |
| 287 | ** jb_array is the array to be filled in. | 287 | ** jb_array is the array to be filled in. |
| 288 | */ | 288 | */ |
| 289 | int reiserfs_allocate_list_bitmaps(struct super_block *p_s_sb, | 289 | int reiserfs_allocate_list_bitmaps(struct super_block *sb, |
| 290 | struct reiserfs_list_bitmap *jb_array, | 290 | struct reiserfs_list_bitmap *jb_array, |
| 291 | unsigned int bmap_nr) | 291 | unsigned int bmap_nr) |
| 292 | { | 292 | { |
| @@ -300,7 +300,7 @@ int reiserfs_allocate_list_bitmaps(struct super_block *p_s_sb, | |||
| 300 | jb->journal_list = NULL; | 300 | jb->journal_list = NULL; |
| 301 | jb->bitmaps = vmalloc(mem); | 301 | jb->bitmaps = vmalloc(mem); |
| 302 | if (!jb->bitmaps) { | 302 | if (!jb->bitmaps) { |
| 303 | reiserfs_warning(p_s_sb, "clm-2000", "unable to " | 303 | reiserfs_warning(sb, "clm-2000", "unable to " |
| 304 | "allocate bitmaps for journal lists"); | 304 | "allocate bitmaps for journal lists"); |
| 305 | failed = 1; | 305 | failed = 1; |
| 306 | break; | 306 | break; |
| @@ -308,7 +308,7 @@ int reiserfs_allocate_list_bitmaps(struct super_block *p_s_sb, | |||
| 308 | memset(jb->bitmaps, 0, mem); | 308 | memset(jb->bitmaps, 0, mem); |
| 309 | } | 309 | } |
| 310 | if (failed) { | 310 | if (failed) { |
| 311 | free_list_bitmaps(p_s_sb, jb_array); | 311 | free_list_bitmaps(sb, jb_array); |
| 312 | return -1; | 312 | return -1; |
| 313 | } | 313 | } |
| 314 | return 0; | 314 | return 0; |
| @@ -318,12 +318,12 @@ int reiserfs_allocate_list_bitmaps(struct super_block *p_s_sb, | |||
| 318 | ** find an available list bitmap. If you can't find one, flush a commit list | 318 | ** find an available list bitmap. If you can't find one, flush a commit list |
| 319 | ** and try again | 319 | ** and try again |
| 320 | */ | 320 | */ |
| 321 | static struct reiserfs_list_bitmap *get_list_bitmap(struct super_block *p_s_sb, | 321 | static struct reiserfs_list_bitmap *get_list_bitmap(struct super_block *sb, |
| 322 | struct reiserfs_journal_list | 322 | struct reiserfs_journal_list |
| 323 | *jl) | 323 | *jl) |
| 324 | { | 324 | { |
| 325 | int i, j; | 325 | int i, j; |
| 326 | struct reiserfs_journal *journal = SB_JOURNAL(p_s_sb); | 326 | struct reiserfs_journal *journal = SB_JOURNAL(sb); |
| 327 | struct reiserfs_list_bitmap *jb = NULL; | 327 | struct reiserfs_list_bitmap *jb = NULL; |
| 328 | 328 | ||
| 329 | for (j = 0; j < (JOURNAL_NUM_BITMAPS * 3); j++) { | 329 | for (j = 0; j < (JOURNAL_NUM_BITMAPS * 3); j++) { |
| @@ -331,7 +331,7 @@ static struct reiserfs_list_bitmap *get_list_bitmap(struct super_block *p_s_sb, | |||
| 331 | journal->j_list_bitmap_index = (i + 1) % JOURNAL_NUM_BITMAPS; | 331 | journal->j_list_bitmap_index = (i + 1) % JOURNAL_NUM_BITMAPS; |
| 332 | jb = journal->j_list_bitmap + i; | 332 | jb = journal->j_list_bitmap + i; |
| 333 | if (journal->j_list_bitmap[i].journal_list) { | 333 | if (journal->j_list_bitmap[i].journal_list) { |
| 334 | flush_commit_list(p_s_sb, | 334 | flush_commit_list(sb, |
| 335 | journal->j_list_bitmap[i]. | 335 | journal->j_list_bitmap[i]. |
| 336 | journal_list, 1); | 336 | journal_list, 1); |
| 337 | if (!journal->j_list_bitmap[i].journal_list) { | 337 | if (!journal->j_list_bitmap[i].journal_list) { |
| @@ -378,12 +378,12 @@ static struct reiserfs_journal_cnode *allocate_cnodes(int num_cnodes) | |||
| 378 | /* | 378 | /* |
| 379 | ** pulls a cnode off the free list, or returns NULL on failure | 379 | ** pulls a cnode off the free list, or returns NULL on failure |
| 380 | */ | 380 | */ |
| 381 | static struct reiserfs_journal_cnode *get_cnode(struct super_block *p_s_sb) | 381 | static struct reiserfs_journal_cnode *get_cnode(struct super_block *sb) |
| 382 | { | 382 | { |
| 383 | struct reiserfs_journal_cnode *cn; | 383 | struct reiserfs_journal_cnode *cn; |
| 384 | struct reiserfs_journal *journal = SB_JOURNAL(p_s_sb); | 384 | struct reiserfs_journal *journal = SB_JOURNAL(sb); |
| 385 | 385 | ||
| 386 | reiserfs_check_lock_depth(p_s_sb, "get_cnode"); | 386 | reiserfs_check_lock_depth(sb, "get_cnode"); |
| 387 | 387 | ||
| 388 | if (journal->j_cnode_free <= 0) { | 388 | if (journal->j_cnode_free <= 0) { |
| 389 | return NULL; | 389 | return NULL; |
| @@ -405,12 +405,12 @@ static struct reiserfs_journal_cnode *get_cnode(struct super_block *p_s_sb) | |||
| 405 | /* | 405 | /* |
| 406 | ** returns a cnode to the free list | 406 | ** returns a cnode to the free list |
| 407 | */ | 407 | */ |
| 408 | static void free_cnode(struct super_block *p_s_sb, | 408 | static void free_cnode(struct super_block *sb, |
| 409 | struct reiserfs_journal_cnode *cn) | 409 | struct reiserfs_journal_cnode *cn) |
| 410 | { | 410 | { |
| 411 | struct reiserfs_journal *journal = SB_JOURNAL(p_s_sb); | 411 | struct reiserfs_journal *journal = SB_JOURNAL(sb); |
| 412 | 412 | ||
| 413 | reiserfs_check_lock_depth(p_s_sb, "free_cnode"); | 413 | reiserfs_check_lock_depth(sb, "free_cnode"); |
| 414 | 414 | ||
| 415 | journal->j_cnode_used--; | 415 | journal->j_cnode_used--; |
| 416 | journal->j_cnode_free++; | 416 | journal->j_cnode_free++; |
| @@ -481,11 +481,11 @@ static inline struct reiserfs_journal_cnode *get_journal_hash_dev(struct | |||
| 481 | ** reject it on the next call to reiserfs_in_journal | 481 | ** reject it on the next call to reiserfs_in_journal |
| 482 | ** | 482 | ** |
| 483 | */ | 483 | */ |
| 484 | int reiserfs_in_journal(struct super_block *p_s_sb, | 484 | int reiserfs_in_journal(struct super_block *sb, |
| 485 | unsigned int bmap_nr, int bit_nr, int search_all, | 485 | unsigned int bmap_nr, int bit_nr, int search_all, |
| 486 | b_blocknr_t * next_zero_bit) | 486 | b_blocknr_t * next_zero_bit) |
| 487 | { | 487 | { |
| 488 | struct reiserfs_journal *journal = SB_JOURNAL(p_s_sb); | 488 | struct reiserfs_journal *journal = SB_JOURNAL(sb); |
| 489 | struct reiserfs_journal_cnode *cn; | 489 | struct reiserfs_journal_cnode *cn; |
| 490 | struct reiserfs_list_bitmap *jb; | 490 | struct reiserfs_list_bitmap *jb; |
| 491 | int i; | 491 | int i; |
| @@ -493,14 +493,14 @@ int reiserfs_in_journal(struct super_block *p_s_sb, | |||
| 493 | 493 | ||
| 494 | *next_zero_bit = 0; /* always start this at zero. */ | 494 | *next_zero_bit = 0; /* always start this at zero. */ |
| 495 | 495 | ||
| 496 | PROC_INFO_INC(p_s_sb, journal.in_journal); | 496 | PROC_INFO_INC(sb, journal.in_journal); |
| 497 | /* If we aren't doing a search_all, this is a metablock, and it will be logged before use. | 497 | /* If we aren't doing a search_all, this is a metablock, and it will be logged before use. |
| 498 | ** if we crash before the transaction that freed it commits, this transaction won't | 498 | ** if we crash before the transaction that freed it commits, this transaction won't |
| 499 | ** have committed either, and the block will never be written | 499 | ** have committed either, and the block will never be written |
| 500 | */ | 500 | */ |
| 501 | if (search_all) { | 501 | if (search_all) { |
| 502 | for (i = 0; i < JOURNAL_NUM_BITMAPS; i++) { | 502 | for (i = 0; i < JOURNAL_NUM_BITMAPS; i++) { |
| 503 | PROC_INFO_INC(p_s_sb, journal.in_journal_bitmap); | 503 | PROC_INFO_INC(sb, journal.in_journal_bitmap); |
| 504 | jb = journal->j_list_bitmap + i; | 504 | jb = journal->j_list_bitmap + i; |
| 505 | if (jb->journal_list && jb->bitmaps[bmap_nr] && | 505 | if (jb->journal_list && jb->bitmaps[bmap_nr] && |
| 506 | test_bit(bit_nr, | 506 | test_bit(bit_nr, |
| @@ -510,28 +510,28 @@ int reiserfs_in_journal(struct super_block *p_s_sb, | |||
| 510 | find_next_zero_bit((unsigned long *) | 510 | find_next_zero_bit((unsigned long *) |
| 511 | (jb->bitmaps[bmap_nr]-> | 511 | (jb->bitmaps[bmap_nr]-> |
| 512 | data), | 512 | data), |
| 513 | p_s_sb->s_blocksize << 3, | 513 | sb->s_blocksize << 3, |
| 514 | bit_nr + 1); | 514 | bit_nr + 1); |
| 515 | return 1; | 515 | return 1; |
| 516 | } | 516 | } |
| 517 | } | 517 | } |
| 518 | } | 518 | } |
| 519 | 519 | ||
| 520 | bl = bmap_nr * (p_s_sb->s_blocksize << 3) + bit_nr; | 520 | bl = bmap_nr * (sb->s_blocksize << 3) + bit_nr; |
| 521 | /* is it in any old transactions? */ | 521 | /* is it in any old transactions? */ |
| 522 | if (search_all | 522 | if (search_all |
| 523 | && (cn = | 523 | && (cn = |
| 524 | get_journal_hash_dev(p_s_sb, journal->j_list_hash_table, bl))) { | 524 | get_journal_hash_dev(sb, journal->j_list_hash_table, bl))) { |
| 525 | return 1; | 525 | return 1; |
| 526 | } | 526 | } |
| 527 | 527 | ||
| 528 | /* is it in the current transaction. This should never happen */ | 528 | /* is it in the current transaction. This should never happen */ |
| 529 | if ((cn = get_journal_hash_dev(p_s_sb, journal->j_hash_table, bl))) { | 529 | if ((cn = get_journal_hash_dev(sb, journal->j_hash_table, bl))) { |
| 530 | BUG(); | 530 | BUG(); |
| 531 | return 1; | 531 | return 1; |
| 532 | } | 532 | } |
| 533 | 533 | ||
| 534 | PROC_INFO_INC(p_s_sb, journal.in_journal_reusable); | 534 | PROC_INFO_INC(sb, journal.in_journal_reusable); |
| 535 | /* safe for reuse */ | 535 | /* safe for reuse */ |
| 536 | return 0; | 536 | return 0; |
| 537 | } | 537 | } |
| @@ -553,16 +553,16 @@ static inline void insert_journal_hash(struct reiserfs_journal_cnode **table, | |||
| 553 | } | 553 | } |
| 554 | 554 | ||
| 555 | /* lock the current transaction */ | 555 | /* lock the current transaction */ |
| 556 | static inline void lock_journal(struct super_block *p_s_sb) | 556 | static inline void lock_journal(struct super_block *sb) |
| 557 | { | 557 | { |
| 558 | PROC_INFO_INC(p_s_sb, journal.lock_journal); | 558 | PROC_INFO_INC(sb, journal.lock_journal); |
| 559 | mutex_lock(&SB_JOURNAL(p_s_sb)->j_mutex); | 559 | mutex_lock(&SB_JOURNAL(sb)->j_mutex); |
| 560 | } | 560 | } |
| 561 | 561 | ||
| 562 | /* unlock the current transaction */ | 562 | /* unlock the current transaction */ |
| 563 | static inline void unlock_journal(struct super_block *p_s_sb) | 563 | static inline void unlock_journal(struct super_block *sb) |
| 564 | { | 564 | { |
| 565 | mutex_unlock(&SB_JOURNAL(p_s_sb)->j_mutex); | 565 | mutex_unlock(&SB_JOURNAL(sb)->j_mutex); |
| 566 | } | 566 | } |
| 567 | 567 | ||
| 568 | static inline void get_journal_list(struct reiserfs_journal_list *jl) | 568 | static inline void get_journal_list(struct reiserfs_journal_list *jl) |
| @@ -586,13 +586,13 @@ static inline void put_journal_list(struct super_block *s, | |||
| 586 | ** it gets called by flush_commit_list, and cleans up any data stored about blocks freed during a | 586 | ** it gets called by flush_commit_list, and cleans up any data stored about blocks freed during a |
| 587 | ** transaction. | 587 | ** transaction. |
| 588 | */ | 588 | */ |
| 589 | static void cleanup_freed_for_journal_list(struct super_block *p_s_sb, | 589 | static void cleanup_freed_for_journal_list(struct super_block *sb, |
| 590 | struct reiserfs_journal_list *jl) | 590 | struct reiserfs_journal_list *jl) |
| 591 | { | 591 | { |
| 592 | 592 | ||
| 593 | struct reiserfs_list_bitmap *jb = jl->j_list_bitmap; | 593 | struct reiserfs_list_bitmap *jb = jl->j_list_bitmap; |
| 594 | if (jb) { | 594 | if (jb) { |
| 595 | cleanup_bitmap_list(p_s_sb, jb); | 595 | cleanup_bitmap_list(sb, jb); |
| 596 | } | 596 | } |
| 597 | jl->j_list_bitmap->journal_list = NULL; | 597 | jl->j_list_bitmap->journal_list = NULL; |
| 598 | jl->j_list_bitmap = NULL; | 598 | jl->j_list_bitmap = NULL; |
| @@ -1237,11 +1237,11 @@ static void remove_journal_hash(struct super_block *, | |||
| 1237 | ** journal list for this transaction. Aside from freeing the cnode, this also allows the | 1237 | ** journal list for this transaction. Aside from freeing the cnode, this also allows the |
| 1238 | ** block to be reallocated for data blocks if it had been deleted. | 1238 | ** block to be reallocated for data blocks if it had been deleted. |
| 1239 | */ | 1239 | */ |
| 1240 | static void remove_all_from_journal_list(struct super_block *p_s_sb, | 1240 | static void remove_all_from_journal_list(struct super_block *sb, |
| 1241 | struct reiserfs_journal_list *jl, | 1241 | struct reiserfs_journal_list *jl, |
| 1242 | int debug) | 1242 | int debug) |
| 1243 | { | 1243 | { |
| 1244 | struct reiserfs_journal *journal = SB_JOURNAL(p_s_sb); | 1244 | struct reiserfs_journal *journal = SB_JOURNAL(sb); |
| 1245 | struct reiserfs_journal_cnode *cn, *last; | 1245 | struct reiserfs_journal_cnode *cn, *last; |
| 1246 | cn = jl->j_realblock; | 1246 | cn = jl->j_realblock; |
| 1247 | 1247 | ||
| @@ -1251,18 +1251,18 @@ static void remove_all_from_journal_list(struct super_block *p_s_sb, | |||
| 1251 | while (cn) { | 1251 | while (cn) { |
| 1252 | if (cn->blocknr != 0) { | 1252 | if (cn->blocknr != 0) { |
| 1253 | if (debug) { | 1253 | if (debug) { |
| 1254 | reiserfs_warning(p_s_sb, "reiserfs-2201", | 1254 | reiserfs_warning(sb, "reiserfs-2201", |
| 1255 | "block %u, bh is %d, state %ld", | 1255 | "block %u, bh is %d, state %ld", |
| 1256 | cn->blocknr, cn->bh ? 1 : 0, | 1256 | cn->blocknr, cn->bh ? 1 : 0, |
| 1257 | cn->state); | 1257 | cn->state); |
| 1258 | } | 1258 | } |
| 1259 | cn->state = 0; | 1259 | cn->state = 0; |
| 1260 | remove_journal_hash(p_s_sb, journal->j_list_hash_table, | 1260 | remove_journal_hash(sb, journal->j_list_hash_table, |
| 1261 | jl, cn->blocknr, 1); | 1261 | jl, cn->blocknr, 1); |
| 1262 | } | 1262 | } |
| 1263 | last = cn; | 1263 | last = cn; |
| 1264 | cn = cn->next; | 1264 | cn = cn->next; |
| 1265 | free_cnode(p_s_sb, last); | 1265 | free_cnode(sb, last); |
| 1266 | } | 1266 | } |
| 1267 | jl->j_realblock = NULL; | 1267 | jl->j_realblock = NULL; |
| 1268 | } | 1268 | } |
| @@ -1274,12 +1274,12 @@ static void remove_all_from_journal_list(struct super_block *p_s_sb, | |||
| 1274 | ** called by flush_journal_list, before it calls remove_all_from_journal_list | 1274 | ** called by flush_journal_list, before it calls remove_all_from_journal_list |
| 1275 | ** | 1275 | ** |
| 1276 | */ | 1276 | */ |
| 1277 | static int _update_journal_header_block(struct super_block *p_s_sb, | 1277 | static int _update_journal_header_block(struct super_block *sb, |
| 1278 | unsigned long offset, | 1278 | unsigned long offset, |
| 1279 | unsigned int trans_id) | 1279 | unsigned int trans_id) |
| 1280 | { | 1280 | { |
| 1281 | struct reiserfs_journal_header *jh; | 1281 | struct reiserfs_journal_header *jh; |
| 1282 | struct reiserfs_journal *journal = SB_JOURNAL(p_s_sb); | 1282 | struct reiserfs_journal *journal = SB_JOURNAL(sb); |
| 1283 | 1283 | ||
| 1284 | if (reiserfs_is_journal_aborted(journal)) | 1284 | if (reiserfs_is_journal_aborted(journal)) |
| 1285 | return -EIO; | 1285 | return -EIO; |
| @@ -1289,7 +1289,7 @@ static int _update_journal_header_block(struct super_block *p_s_sb, | |||
| 1289 | wait_on_buffer((journal->j_header_bh)); | 1289 | wait_on_buffer((journal->j_header_bh)); |
| 1290 | if (unlikely(!buffer_uptodate(journal->j_header_bh))) { | 1290 | if (unlikely(!buffer_uptodate(journal->j_header_bh))) { |
| 1291 | #ifdef CONFIG_REISERFS_CHECK | 1291 | #ifdef CONFIG_REISERFS_CHECK |
| 1292 | reiserfs_warning(p_s_sb, "journal-699", | 1292 | reiserfs_warning(sb, "journal-699", |
| 1293 | "buffer write failed"); | 1293 | "buffer write failed"); |
| 1294 | #endif | 1294 | #endif |
| 1295 | return -EIO; | 1295 | return -EIO; |
| @@ -1303,24 +1303,24 @@ static int _update_journal_header_block(struct super_block *p_s_sb, | |||
| 1303 | jh->j_first_unflushed_offset = cpu_to_le32(offset); | 1303 | jh->j_first_unflushed_offset = cpu_to_le32(offset); |
| 1304 | jh->j_mount_id = cpu_to_le32(journal->j_mount_id); | 1304 | jh->j_mount_id = cpu_to_le32(journal->j_mount_id); |
| 1305 | 1305 | ||
| 1306 | if (reiserfs_barrier_flush(p_s_sb)) { | 1306 | if (reiserfs_barrier_flush(sb)) { |
| 1307 | int ret; | 1307 | int ret; |
| 1308 | lock_buffer(journal->j_header_bh); | 1308 | lock_buffer(journal->j_header_bh); |
| 1309 | ret = submit_barrier_buffer(journal->j_header_bh); | 1309 | ret = submit_barrier_buffer(journal->j_header_bh); |
| 1310 | if (ret == -EOPNOTSUPP) { | 1310 | if (ret == -EOPNOTSUPP) { |
| 1311 | set_buffer_uptodate(journal->j_header_bh); | 1311 | set_buffer_uptodate(journal->j_header_bh); |
| 1312 | disable_barrier(p_s_sb); | 1312 | disable_barrier(sb); |
| 1313 | goto sync; | 1313 | goto sync; |
| 1314 | } | 1314 | } |
| 1315 | wait_on_buffer(journal->j_header_bh); | 1315 | wait_on_buffer(journal->j_header_bh); |
| 1316 | check_barrier_completion(p_s_sb, journal->j_header_bh); | 1316 | check_barrier_completion(sb, journal->j_header_bh); |
| 1317 | } else { | 1317 | } else { |
| 1318 | sync: | 1318 | sync: |
| 1319 | set_buffer_dirty(journal->j_header_bh); | 1319 | set_buffer_dirty(journal->j_header_bh); |
| 1320 | sync_dirty_buffer(journal->j_header_bh); | 1320 | sync_dirty_buffer(journal->j_header_bh); |
| 1321 | } | 1321 | } |
| 1322 | if (!buffer_uptodate(journal->j_header_bh)) { | 1322 | if (!buffer_uptodate(journal->j_header_bh)) { |
| 1323 | reiserfs_warning(p_s_sb, "journal-837", | 1323 | reiserfs_warning(sb, "journal-837", |
| 1324 | "IO error during journal replay"); | 1324 | "IO error during journal replay"); |
| 1325 | return -EIO; | 1325 | return -EIO; |
| 1326 | } | 1326 | } |
| @@ -1328,23 +1328,23 @@ static int _update_journal_header_block(struct super_block *p_s_sb, | |||
| 1328 | return 0; | 1328 | return 0; |
| 1329 | } | 1329 | } |
| 1330 | 1330 | ||
| 1331 | static int update_journal_header_block(struct super_block *p_s_sb, | 1331 | static int update_journal_header_block(struct super_block *sb, |
| 1332 | unsigned long offset, | 1332 | unsigned long offset, |
| 1333 | unsigned int trans_id) | 1333 | unsigned int trans_id) |
| 1334 | { | 1334 | { |
| 1335 | return _update_journal_header_block(p_s_sb, offset, trans_id); | 1335 | return _update_journal_header_block(sb, offset, trans_id); |
| 1336 | } | 1336 | } |
| 1337 | 1337 | ||
| 1338 | /* | 1338 | /* |
| 1339 | ** flush any and all journal lists older than you are | 1339 | ** flush any and all journal lists older than you are |
| 1340 | ** can only be called from flush_journal_list | 1340 | ** can only be called from flush_journal_list |
| 1341 | */ | 1341 | */ |
| 1342 | static int flush_older_journal_lists(struct super_block *p_s_sb, | 1342 | static int flush_older_journal_lists(struct super_block *sb, |
| 1343 | struct reiserfs_journal_list *jl) | 1343 | struct reiserfs_journal_list *jl) |
| 1344 | { | 1344 | { |
| 1345 | struct list_head *entry; | 1345 | struct list_head *entry; |
| 1346 | struct reiserfs_journal_list *other_jl; | 1346 | struct reiserfs_journal_list *other_jl; |
| 1347 | struct reiserfs_journal *journal = SB_JOURNAL(p_s_sb); | 1347 | struct reiserfs_journal *journal = SB_JOURNAL(sb); |
| 1348 | unsigned int trans_id = jl->j_trans_id; | 1348 | unsigned int trans_id = jl->j_trans_id; |
| 1349 | 1349 | ||
| 1350 | /* we know we are the only ones flushing things, no extra race | 1350 | /* we know we are the only ones flushing things, no extra race |
| @@ -1359,7 +1359,7 @@ static int flush_older_journal_lists(struct super_block *p_s_sb, | |||
| 1359 | if (other_jl->j_trans_id < trans_id) { | 1359 | if (other_jl->j_trans_id < trans_id) { |
| 1360 | BUG_ON(other_jl->j_refcount <= 0); | 1360 | BUG_ON(other_jl->j_refcount <= 0); |
| 1361 | /* do not flush all */ | 1361 | /* do not flush all */ |
| 1362 | flush_journal_list(p_s_sb, other_jl, 0); | 1362 | flush_journal_list(sb, other_jl, 0); |
| 1363 | 1363 | ||
| 1364 | /* other_jl is now deleted from the list */ | 1364 | /* other_jl is now deleted from the list */ |
| 1365 | goto restart; | 1365 | goto restart; |
| @@ -1908,22 +1908,22 @@ void remove_journal_hash(struct super_block *sb, | |||
| 1908 | } | 1908 | } |
| 1909 | } | 1909 | } |
| 1910 | 1910 | ||
| 1911 | static void free_journal_ram(struct super_block *p_s_sb) | 1911 | static void free_journal_ram(struct super_block *sb) |
| 1912 | { | 1912 | { |
| 1913 | struct reiserfs_journal *journal = SB_JOURNAL(p_s_sb); | 1913 | struct reiserfs_journal *journal = SB_JOURNAL(sb); |
| 1914 | kfree(journal->j_current_jl); | 1914 | kfree(journal->j_current_jl); |
| 1915 | journal->j_num_lists--; | 1915 | journal->j_num_lists--; |
| 1916 | 1916 | ||
| 1917 | vfree(journal->j_cnode_free_orig); | 1917 | vfree(journal->j_cnode_free_orig); |
| 1918 | free_list_bitmaps(p_s_sb, journal->j_list_bitmap); | 1918 | free_list_bitmaps(sb, journal->j_list_bitmap); |
| 1919 | free_bitmap_nodes(p_s_sb); /* must be after free_list_bitmaps */ | 1919 | free_bitmap_nodes(sb); /* must be after free_list_bitmaps */ |
| 1920 | if (journal->j_header_bh) { | 1920 | if (journal->j_header_bh) { |
| 1921 | brelse(journal->j_header_bh); | 1921 | brelse(journal->j_header_bh); |
| 1922 | } | 1922 | } |
| 1923 | /* j_header_bh is on the journal dev, make sure not to release the journal | 1923 | /* j_header_bh is on the journal dev, make sure not to release the journal |
| 1924 | * dev until we brelse j_header_bh | 1924 | * dev until we brelse j_header_bh |
| 1925 | */ | 1925 | */ |
| 1926 | release_journal_dev(p_s_sb, journal); | 1926 | release_journal_dev(sb, journal); |
| 1927 | vfree(journal); | 1927 | vfree(journal); |
| 1928 | } | 1928 | } |
| 1929 | 1929 | ||
| @@ -1932,27 +1932,27 @@ static void free_journal_ram(struct super_block *p_s_sb) | |||
| 1932 | ** of read_super() yet. Any other caller must keep error at 0. | 1932 | ** of read_super() yet. Any other caller must keep error at 0. |
| 1933 | */ | 1933 | */ |
| 1934 | static int do_journal_release(struct reiserfs_transaction_handle *th, | 1934 | static int do_journal_release(struct reiserfs_transaction_handle *th, |
| 1935 | struct super_block *p_s_sb, int error) | 1935 | struct super_block *sb, int error) |
| 1936 | { | 1936 | { |
| 1937 | struct reiserfs_transaction_handle myth; | 1937 | struct reiserfs_transaction_handle myth; |
| 1938 | int flushed = 0; | 1938 | int flushed = 0; |
| 1939 | struct reiserfs_journal *journal = SB_JOURNAL(p_s_sb); | 1939 | struct reiserfs_journal *journal = SB_JOURNAL(sb); |
| 1940 | 1940 | ||
| 1941 | /* we only want to flush out transactions if we were called with error == 0 | 1941 | /* we only want to flush out transactions if we were called with error == 0 |
| 1942 | */ | 1942 | */ |
| 1943 | if (!error && !(p_s_sb->s_flags & MS_RDONLY)) { | 1943 | if (!error && !(sb->s_flags & MS_RDONLY)) { |
| 1944 | /* end the current trans */ | 1944 | /* end the current trans */ |
| 1945 | BUG_ON(!th->t_trans_id); | 1945 | BUG_ON(!th->t_trans_id); |
| 1946 | do_journal_end(th, p_s_sb, 10, FLUSH_ALL); | 1946 | do_journal_end(th, sb, 10, FLUSH_ALL); |
| 1947 | 1947 | ||
| 1948 | /* make sure something gets logged to force our way into the flush code */ | 1948 | /* make sure something gets logged to force our way into the flush code */ |
| 1949 | if (!journal_join(&myth, p_s_sb, 1)) { | 1949 | if (!journal_join(&myth, sb, 1)) { |
| 1950 | reiserfs_prepare_for_journal(p_s_sb, | 1950 | reiserfs_prepare_for_journal(sb, |
| 1951 | SB_BUFFER_WITH_SB(p_s_sb), | 1951 | SB_BUFFER_WITH_SB(sb), |
| 1952 | 1); | 1952 | 1); |
| 1953 | journal_mark_dirty(&myth, p_s_sb, | 1953 | journal_mark_dirty(&myth, sb, |
| 1954 | SB_BUFFER_WITH_SB(p_s_sb)); | 1954 | SB_BUFFER_WITH_SB(sb)); |
| 1955 | do_journal_end(&myth, p_s_sb, 1, FLUSH_ALL); | 1955 | do_journal_end(&myth, sb, 1, FLUSH_ALL); |
| 1956 | flushed = 1; | 1956 | flushed = 1; |
| 1957 | } | 1957 | } |
| 1958 | } | 1958 | } |
| @@ -1960,26 +1960,26 @@ static int do_journal_release(struct reiserfs_transaction_handle *th, | |||
| 1960 | /* this also catches errors during the do_journal_end above */ | 1960 | /* this also catches errors during the do_journal_end above */ |
| 1961 | if (!error && reiserfs_is_journal_aborted(journal)) { | 1961 | if (!error && reiserfs_is_journal_aborted(journal)) { |
| 1962 | memset(&myth, 0, sizeof(myth)); | 1962 | memset(&myth, 0, sizeof(myth)); |
| 1963 | if (!journal_join_abort(&myth, p_s_sb, 1)) { | 1963 | if (!journal_join_abort(&myth, sb, 1)) { |
| 1964 | reiserfs_prepare_for_journal(p_s_sb, | 1964 | reiserfs_prepare_for_journal(sb, |
| 1965 | SB_BUFFER_WITH_SB(p_s_sb), | 1965 | SB_BUFFER_WITH_SB(sb), |
| 1966 | 1); | 1966 | 1); |
| 1967 | journal_mark_dirty(&myth, p_s_sb, | 1967 | journal_mark_dirty(&myth, sb, |
| 1968 | SB_BUFFER_WITH_SB(p_s_sb)); | 1968 | SB_BUFFER_WITH_SB(sb)); |
| 1969 | do_journal_end(&myth, p_s_sb, 1, FLUSH_ALL); | 1969 | do_journal_end(&myth, sb, 1, FLUSH_ALL); |
| 1970 | } | 1970 | } |
| 1971 | } | 1971 | } |
| 1972 | 1972 | ||
| 1973 | reiserfs_mounted_fs_count--; | 1973 | reiserfs_mounted_fs_count--; |
| 1974 | /* wait for all commits to finish */ | 1974 | /* wait for all commits to finish */ |
| 1975 | cancel_delayed_work(&SB_JOURNAL(p_s_sb)->j_work); | 1975 | cancel_delayed_work(&SB_JOURNAL(sb)->j_work); |
| 1976 | flush_workqueue(commit_wq); | 1976 | flush_workqueue(commit_wq); |
| 1977 | if (!reiserfs_mounted_fs_count) { | 1977 | if (!reiserfs_mounted_fs_count) { |
| 1978 | destroy_workqueue(commit_wq); | 1978 | destroy_workqueue(commit_wq); |
| 1979 | commit_wq = NULL; | 1979 | commit_wq = NULL; |
| 1980 | } | 1980 | } |
| 1981 | 1981 | ||
| 1982 | free_journal_ram(p_s_sb); | 1982 | free_journal_ram(sb); |
| 1983 | 1983 | ||
| 1984 | return 0; | 1984 | return 0; |
| 1985 | } | 1985 | } |
| @@ -1988,28 +1988,28 @@ static int do_journal_release(struct reiserfs_transaction_handle *th, | |||
| 1988 | ** call on unmount. flush all journal trans, release all alloc'd ram | 1988 | ** call on unmount. flush all journal trans, release all alloc'd ram |
| 1989 | */ | 1989 | */ |
| 1990 | int journal_release(struct reiserfs_transaction_handle *th, | 1990 | int journal_release(struct reiserfs_transaction_handle *th, |
| 1991 | struct super_block *p_s_sb) | 1991 | struct super_block *sb) |
| 1992 | { | 1992 | { |
| 1993 | return do_journal_release(th, p_s_sb, 0); | 1993 | return do_journal_release(th, sb, 0); |
| 1994 | } | 1994 | } |
| 1995 | 1995 | ||
| 1996 | /* | 1996 | /* |
| 1997 | ** only call from an error condition inside reiserfs_read_super! | 1997 | ** only call from an error condition inside reiserfs_read_super! |
| 1998 | */ | 1998 | */ |
| 1999 | int journal_release_error(struct reiserfs_transaction_handle *th, | 1999 | int journal_release_error(struct reiserfs_transaction_handle *th, |
| 2000 | struct super_block *p_s_sb) | 2000 | struct super_block *sb) |
| 2001 | { | 2001 | { |
| 2002 | return do_journal_release(th, p_s_sb, 1); | 2002 | return do_journal_release(th, sb, 1); |
| 2003 | } | 2003 | } |
| 2004 | 2004 | ||
| 2005 | /* compares description block with commit block. returns 1 if they differ, 0 if they are the same */ | 2005 | /* compares description block with commit block. returns 1 if they differ, 0 if they are the same */ |
| 2006 | static int journal_compare_desc_commit(struct super_block *p_s_sb, | 2006 | static int journal_compare_desc_commit(struct super_block *sb, |
| 2007 | struct reiserfs_journal_desc *desc, | 2007 | struct reiserfs_journal_desc *desc, |
| 2008 | struct reiserfs_journal_commit *commit) | 2008 | struct reiserfs_journal_commit *commit) |
| 2009 | { | 2009 | { |
| 2010 | if (get_commit_trans_id(commit) != get_desc_trans_id(desc) || | 2010 | if (get_commit_trans_id(commit) != get_desc_trans_id(desc) || |
| 2011 | get_commit_trans_len(commit) != get_desc_trans_len(desc) || | 2011 | get_commit_trans_len(commit) != get_desc_trans_len(desc) || |
| 2012 | get_commit_trans_len(commit) > SB_JOURNAL(p_s_sb)->j_trans_max || | 2012 | get_commit_trans_len(commit) > SB_JOURNAL(sb)->j_trans_max || |
| 2013 | get_commit_trans_len(commit) <= 0) { | 2013 | get_commit_trans_len(commit) <= 0) { |
| 2014 | return 1; | 2014 | return 1; |
| 2015 | } | 2015 | } |
| @@ -2020,7 +2020,7 @@ static int journal_compare_desc_commit(struct super_block *p_s_sb, | |||
| 2020 | ** returns -1 if it found a corrupt commit block | 2020 | ** returns -1 if it found a corrupt commit block |
| 2021 | ** returns 1 if both desc and commit were valid | 2021 | ** returns 1 if both desc and commit were valid |
| 2022 | */ | 2022 | */ |
| 2023 | static int journal_transaction_is_valid(struct super_block *p_s_sb, | 2023 | static int journal_transaction_is_valid(struct super_block *sb, |
| 2024 | struct buffer_head *d_bh, | 2024 | struct buffer_head *d_bh, |
| 2025 | unsigned int *oldest_invalid_trans_id, | 2025 | unsigned int *oldest_invalid_trans_id, |
| 2026 | unsigned long *newest_mount_id) | 2026 | unsigned long *newest_mount_id) |
| @@ -2038,7 +2038,7 @@ static int journal_transaction_is_valid(struct super_block *p_s_sb, | |||
| 2038 | && !memcmp(get_journal_desc_magic(d_bh), JOURNAL_DESC_MAGIC, 8)) { | 2038 | && !memcmp(get_journal_desc_magic(d_bh), JOURNAL_DESC_MAGIC, 8)) { |
| 2039 | if (oldest_invalid_trans_id && *oldest_invalid_trans_id | 2039 | if (oldest_invalid_trans_id && *oldest_invalid_trans_id |
| 2040 | && get_desc_trans_id(desc) > *oldest_invalid_trans_id) { | 2040 | && get_desc_trans_id(desc) > *oldest_invalid_trans_id) { |
| 2041 | reiserfs_debug(p_s_sb, REISERFS_DEBUG_CODE, | 2041 | reiserfs_debug(sb, REISERFS_DEBUG_CODE, |
| 2042 | "journal-986: transaction " | 2042 | "journal-986: transaction " |
| 2043 | "is valid returning because trans_id %d is greater than " | 2043 | "is valid returning because trans_id %d is greater than " |
| 2044 | "oldest_invalid %lu", | 2044 | "oldest_invalid %lu", |
| @@ -2048,7 +2048,7 @@ static int journal_transaction_is_valid(struct super_block *p_s_sb, | |||
| 2048 | } | 2048 | } |
| 2049 | if (newest_mount_id | 2049 | if (newest_mount_id |
| 2050 | && *newest_mount_id > get_desc_mount_id(desc)) { | 2050 | && *newest_mount_id > get_desc_mount_id(desc)) { |
| 2051 | reiserfs_debug(p_s_sb, REISERFS_DEBUG_CODE, | 2051 | reiserfs_debug(sb, REISERFS_DEBUG_CODE, |
| 2052 | "journal-1087: transaction " | 2052 | "journal-1087: transaction " |
| 2053 | "is valid returning because mount_id %d is less than " | 2053 | "is valid returning because mount_id %d is less than " |
| 2054 | "newest_mount_id %lu", | 2054 | "newest_mount_id %lu", |
| @@ -2056,37 +2056,37 @@ static int journal_transaction_is_valid(struct super_block *p_s_sb, | |||
| 2056 | *newest_mount_id); | 2056 | *newest_mount_id); |
| 2057 | return -1; | 2057 | return -1; |
| 2058 | } | 2058 | } |
| 2059 | if (get_desc_trans_len(desc) > SB_JOURNAL(p_s_sb)->j_trans_max) { | 2059 | if (get_desc_trans_len(desc) > SB_JOURNAL(sb)->j_trans_max) { |
| 2060 | reiserfs_warning(p_s_sb, "journal-2018", | 2060 | reiserfs_warning(sb, "journal-2018", |
| 2061 | "Bad transaction length %d " | 2061 | "Bad transaction length %d " |
| 2062 | "encountered, ignoring transaction", | 2062 | "encountered, ignoring transaction", |
| 2063 | get_desc_trans_len(desc)); | 2063 | get_desc_trans_len(desc)); |
| 2064 | return -1; | 2064 | return -1; |
| 2065 | } | 2065 | } |
| 2066 | offset = d_bh->b_blocknr - SB_ONDISK_JOURNAL_1st_BLOCK(p_s_sb); | 2066 | offset = d_bh->b_blocknr - SB_ONDISK_JOURNAL_1st_BLOCK(sb); |
| 2067 | 2067 | ||
| 2068 | /* ok, we have a journal description block, lets see if the transaction was valid */ | 2068 | /* ok, we have a journal description block, lets see if the transaction was valid */ |
| 2069 | c_bh = | 2069 | c_bh = |
| 2070 | journal_bread(p_s_sb, | 2070 | journal_bread(sb, |
| 2071 | SB_ONDISK_JOURNAL_1st_BLOCK(p_s_sb) + | 2071 | SB_ONDISK_JOURNAL_1st_BLOCK(sb) + |
| 2072 | ((offset + get_desc_trans_len(desc) + | 2072 | ((offset + get_desc_trans_len(desc) + |
| 2073 | 1) % SB_ONDISK_JOURNAL_SIZE(p_s_sb))); | 2073 | 1) % SB_ONDISK_JOURNAL_SIZE(sb))); |
| 2074 | if (!c_bh) | 2074 | if (!c_bh) |
| 2075 | return 0; | 2075 | return 0; |
| 2076 | commit = (struct reiserfs_journal_commit *)c_bh->b_data; | 2076 | commit = (struct reiserfs_journal_commit *)c_bh->b_data; |
| 2077 | if (journal_compare_desc_commit(p_s_sb, desc, commit)) { | 2077 | if (journal_compare_desc_commit(sb, desc, commit)) { |
| 2078 | reiserfs_debug(p_s_sb, REISERFS_DEBUG_CODE, | 2078 | reiserfs_debug(sb, REISERFS_DEBUG_CODE, |
| 2079 | "journal_transaction_is_valid, commit offset %ld had bad " | 2079 | "journal_transaction_is_valid, commit offset %ld had bad " |
| 2080 | "time %d or length %d", | 2080 | "time %d or length %d", |
| 2081 | c_bh->b_blocknr - | 2081 | c_bh->b_blocknr - |
| 2082 | SB_ONDISK_JOURNAL_1st_BLOCK(p_s_sb), | 2082 | SB_ONDISK_JOURNAL_1st_BLOCK(sb), |
| 2083 | get_commit_trans_id(commit), | 2083 | get_commit_trans_id(commit), |
| 2084 | get_commit_trans_len(commit)); | 2084 | get_commit_trans_len(commit)); |
| 2085 | brelse(c_bh); | 2085 | brelse(c_bh); |
| 2086 | if (oldest_invalid_trans_id) { | 2086 | if (oldest_invalid_trans_id) { |
| 2087 | *oldest_invalid_trans_id = | 2087 | *oldest_invalid_trans_id = |
| 2088 | get_desc_trans_id(desc); | 2088 | get_desc_trans_id(desc); |
| 2089 | reiserfs_debug(p_s_sb, REISERFS_DEBUG_CODE, | 2089 | reiserfs_debug(sb, REISERFS_DEBUG_CODE, |
| 2090 | "journal-1004: " | 2090 | "journal-1004: " |
| 2091 | "transaction_is_valid setting oldest invalid trans_id " | 2091 | "transaction_is_valid setting oldest invalid trans_id " |
| 2092 | "to %d", | 2092 | "to %d", |
| @@ -2095,11 +2095,11 @@ static int journal_transaction_is_valid(struct super_block *p_s_sb, | |||
| 2095 | return -1; | 2095 | return -1; |
| 2096 | } | 2096 | } |
| 2097 | brelse(c_bh); | 2097 | brelse(c_bh); |
| 2098 | reiserfs_debug(p_s_sb, REISERFS_DEBUG_CODE, | 2098 | reiserfs_debug(sb, REISERFS_DEBUG_CODE, |
| 2099 | "journal-1006: found valid " | 2099 | "journal-1006: found valid " |
| 2100 | "transaction start offset %llu, len %d id %d", | 2100 | "transaction start offset %llu, len %d id %d", |
| 2101 | d_bh->b_blocknr - | 2101 | d_bh->b_blocknr - |
| 2102 | SB_ONDISK_JOURNAL_1st_BLOCK(p_s_sb), | 2102 | SB_ONDISK_JOURNAL_1st_BLOCK(sb), |
| 2103 | get_desc_trans_len(desc), | 2103 | get_desc_trans_len(desc), |
| 2104 | get_desc_trans_id(desc)); | 2104 | get_desc_trans_id(desc)); |
| 2105 | return 1; | 2105 | return 1; |
| @@ -2121,13 +2121,13 @@ static void brelse_array(struct buffer_head **heads, int num) | |||
| 2121 | ** this either reads in a replays a transaction, or returns because the transaction | 2121 | ** this either reads in a replays a transaction, or returns because the transaction |
| 2122 | ** is invalid, or too old. | 2122 | ** is invalid, or too old. |
| 2123 | */ | 2123 | */ |
| 2124 | static int journal_read_transaction(struct super_block *p_s_sb, | 2124 | static int journal_read_transaction(struct super_block *sb, |
| 2125 | unsigned long cur_dblock, | 2125 | unsigned long cur_dblock, |
| 2126 | unsigned long oldest_start, | 2126 | unsigned long oldest_start, |
| 2127 | unsigned int oldest_trans_id, | 2127 | unsigned int oldest_trans_id, |
| 2128 | unsigned long newest_mount_id) | 2128 | unsigned long newest_mount_id) |
| 2129 | { | 2129 | { |
| 2130 | struct reiserfs_journal *journal = SB_JOURNAL(p_s_sb); | 2130 | struct reiserfs_journal *journal = SB_JOURNAL(sb); |
| 2131 | struct reiserfs_journal_desc *desc; | 2131 | struct reiserfs_journal_desc *desc; |
| 2132 | struct reiserfs_journal_commit *commit; | 2132 | struct reiserfs_journal_commit *commit; |
| 2133 | unsigned int trans_id = 0; | 2133 | unsigned int trans_id = 0; |
| @@ -2139,45 +2139,45 @@ static int journal_read_transaction(struct super_block *p_s_sb, | |||
| 2139 | int i; | 2139 | int i; |
| 2140 | int trans_half; | 2140 | int trans_half; |
| 2141 | 2141 | ||
| 2142 | d_bh = journal_bread(p_s_sb, cur_dblock); | 2142 | d_bh = journal_bread(sb, cur_dblock); |
| 2143 | if (!d_bh) | 2143 | if (!d_bh) |
| 2144 | return 1; | 2144 | return 1; |
| 2145 | desc = (struct reiserfs_journal_desc *)d_bh->b_data; | 2145 | desc = (struct reiserfs_journal_desc *)d_bh->b_data; |
| 2146 | trans_offset = d_bh->b_blocknr - SB_ONDISK_JOURNAL_1st_BLOCK(p_s_sb); | 2146 | trans_offset = d_bh->b_blocknr - SB_ONDISK_JOURNAL_1st_BLOCK(sb); |
| 2147 | reiserfs_debug(p_s_sb, REISERFS_DEBUG_CODE, "journal-1037: " | 2147 | reiserfs_debug(sb, REISERFS_DEBUG_CODE, "journal-1037: " |
| 2148 | "journal_read_transaction, offset %llu, len %d mount_id %d", | 2148 | "journal_read_transaction, offset %llu, len %d mount_id %d", |
| 2149 | d_bh->b_blocknr - SB_ONDISK_JOURNAL_1st_BLOCK(p_s_sb), | 2149 | d_bh->b_blocknr - SB_ONDISK_JOURNAL_1st_BLOCK(sb), |
| 2150 | get_desc_trans_len(desc), get_desc_mount_id(desc)); | 2150 | get_desc_trans_len(desc), get_desc_mount_id(desc)); |
| 2151 | if (get_desc_trans_id(desc) < oldest_trans_id) { | 2151 | if (get_desc_trans_id(desc) < oldest_trans_id) { |
| 2152 | reiserfs_debug(p_s_sb, REISERFS_DEBUG_CODE, "journal-1039: " | 2152 | reiserfs_debug(sb, REISERFS_DEBUG_CODE, "journal-1039: " |
| 2153 | "journal_read_trans skipping because %lu is too old", | 2153 | "journal_read_trans skipping because %lu is too old", |
| 2154 | cur_dblock - | 2154 | cur_dblock - |
| 2155 | SB_ONDISK_JOURNAL_1st_BLOCK(p_s_sb)); | 2155 | SB_ONDISK_JOURNAL_1st_BLOCK(sb)); |
| 2156 | brelse(d_bh); | 2156 | brelse(d_bh); |
| 2157 | return 1; | 2157 | return 1; |
| 2158 | } | 2158 | } |
| 2159 | if (get_desc_mount_id(desc) != newest_mount_id) { | 2159 | if (get_desc_mount_id(desc) != newest_mount_id) { |
| 2160 | reiserfs_debug(p_s_sb, REISERFS_DEBUG_CODE, "journal-1146: " | 2160 | reiserfs_debug(sb, REISERFS_DEBUG_CODE, "journal-1146: " |
| 2161 | "journal_read_trans skipping because %d is != " | 2161 | "journal_read_trans skipping because %d is != " |
| 2162 | "newest_mount_id %lu", get_desc_mount_id(desc), | 2162 | "newest_mount_id %lu", get_desc_mount_id(desc), |
| 2163 | newest_mount_id); | 2163 | newest_mount_id); |
| 2164 | brelse(d_bh); | 2164 | brelse(d_bh); |
| 2165 | return 1; | 2165 | return 1; |
| 2166 | } | 2166 | } |
| 2167 | c_bh = journal_bread(p_s_sb, SB_ONDISK_JOURNAL_1st_BLOCK(p_s_sb) + | 2167 | c_bh = journal_bread(sb, SB_ONDISK_JOURNAL_1st_BLOCK(sb) + |
| 2168 | ((trans_offset + get_desc_trans_len(desc) + 1) % | 2168 | ((trans_offset + get_desc_trans_len(desc) + 1) % |
| 2169 | SB_ONDISK_JOURNAL_SIZE(p_s_sb))); | 2169 | SB_ONDISK_JOURNAL_SIZE(sb))); |
| 2170 | if (!c_bh) { | 2170 | if (!c_bh) { |
| 2171 | brelse(d_bh); | 2171 | brelse(d_bh); |
| 2172 | return 1; | 2172 | return 1; |
| 2173 | } | 2173 | } |
| 2174 | commit = (struct reiserfs_journal_commit *)c_bh->b_data; | 2174 | commit = (struct reiserfs_journal_commit *)c_bh->b_data; |
| 2175 | if (journal_compare_desc_commit(p_s_sb, desc, commit)) { | 2175 | if (journal_compare_desc_commit(sb, desc, commit)) { |
| 2176 | reiserfs_debug(p_s_sb, REISERFS_DEBUG_CODE, | 2176 | reiserfs_debug(sb, REISERFS_DEBUG_CODE, |
| 2177 | "journal_read_transaction, " | 2177 | "journal_read_transaction, " |
| 2178 | "commit offset %llu had bad time %d or length %d", | 2178 | "commit offset %llu had bad time %d or length %d", |
| 2179 | c_bh->b_blocknr - | 2179 | c_bh->b_blocknr - |
| 2180 | SB_ONDISK_JOURNAL_1st_BLOCK(p_s_sb), | 2180 | SB_ONDISK_JOURNAL_1st_BLOCK(sb), |
| 2181 | get_commit_trans_id(commit), | 2181 | get_commit_trans_id(commit), |
| 2182 | get_commit_trans_len(commit)); | 2182 | get_commit_trans_len(commit)); |
| 2183 | brelse(c_bh); | 2183 | brelse(c_bh); |
| @@ -2195,30 +2195,30 @@ static int journal_read_transaction(struct super_block *p_s_sb, | |||
| 2195 | brelse(d_bh); | 2195 | brelse(d_bh); |
| 2196 | kfree(log_blocks); | 2196 | kfree(log_blocks); |
| 2197 | kfree(real_blocks); | 2197 | kfree(real_blocks); |
| 2198 | reiserfs_warning(p_s_sb, "journal-1169", | 2198 | reiserfs_warning(sb, "journal-1169", |
| 2199 | "kmalloc failed, unable to mount FS"); | 2199 | "kmalloc failed, unable to mount FS"); |
| 2200 | return -1; | 2200 | return -1; |
| 2201 | } | 2201 | } |
| 2202 | /* get all the buffer heads */ | 2202 | /* get all the buffer heads */ |
| 2203 | trans_half = journal_trans_half(p_s_sb->s_blocksize); | 2203 | trans_half = journal_trans_half(sb->s_blocksize); |
| 2204 | for (i = 0; i < get_desc_trans_len(desc); i++) { | 2204 | for (i = 0; i < get_desc_trans_len(desc); i++) { |
| 2205 | log_blocks[i] = | 2205 | log_blocks[i] = |
| 2206 | journal_getblk(p_s_sb, | 2206 | journal_getblk(sb, |
| 2207 | SB_ONDISK_JOURNAL_1st_BLOCK(p_s_sb) + | 2207 | SB_ONDISK_JOURNAL_1st_BLOCK(sb) + |
| 2208 | (trans_offset + 1 + | 2208 | (trans_offset + 1 + |
| 2209 | i) % SB_ONDISK_JOURNAL_SIZE(p_s_sb)); | 2209 | i) % SB_ONDISK_JOURNAL_SIZE(sb)); |
| 2210 | if (i < trans_half) { | 2210 | if (i < trans_half) { |
| 2211 | real_blocks[i] = | 2211 | real_blocks[i] = |
| 2212 | sb_getblk(p_s_sb, | 2212 | sb_getblk(sb, |
| 2213 | le32_to_cpu(desc->j_realblock[i])); | 2213 | le32_to_cpu(desc->j_realblock[i])); |
| 2214 | } else { | 2214 | } else { |
| 2215 | real_blocks[i] = | 2215 | real_blocks[i] = |
| 2216 | sb_getblk(p_s_sb, | 2216 | sb_getblk(sb, |
| 2217 | le32_to_cpu(commit-> | 2217 | le32_to_cpu(commit-> |
| 2218 | j_realblock[i - trans_half])); | 2218 | j_realblock[i - trans_half])); |
| 2219 | } | 2219 | } |
| 2220 | if (real_blocks[i]->b_blocknr > SB_BLOCK_COUNT(p_s_sb)) { | 2220 | if (real_blocks[i]->b_blocknr > SB_BLOCK_COUNT(sb)) { |
| 2221 | reiserfs_warning(p_s_sb, "journal-1207", | 2221 | reiserfs_warning(sb, "journal-1207", |
| 2222 | "REPLAY FAILURE fsck required! " | 2222 | "REPLAY FAILURE fsck required! " |
| 2223 | "Block to replay is outside of " | 2223 | "Block to replay is outside of " |
| 2224 | "filesystem"); | 2224 | "filesystem"); |
| @@ -2226,8 +2226,8 @@ static int journal_read_transaction(struct super_block *p_s_sb, | |||
| 2226 | } | 2226 | } |
| 2227 | /* make sure we don't try to replay onto log or reserved area */ | 2227 | /* make sure we don't try to replay onto log or reserved area */ |
| 2228 | if (is_block_in_log_or_reserved_area | 2228 | if (is_block_in_log_or_reserved_area |
| 2229 | (p_s_sb, real_blocks[i]->b_blocknr)) { | 2229 | (sb, real_blocks[i]->b_blocknr)) { |
| 2230 | reiserfs_warning(p_s_sb, "journal-1204", | 2230 | reiserfs_warning(sb, "journal-1204", |
| 2231 | "REPLAY FAILURE fsck required! " | 2231 | "REPLAY FAILURE fsck required! " |
| 2232 | "Trying to replay onto a log block"); | 2232 | "Trying to replay onto a log block"); |
| 2233 | abort_replay: | 2233 | abort_replay: |
| @@ -2245,7 +2245,7 @@ static int journal_read_transaction(struct super_block *p_s_sb, | |||
| 2245 | for (i = 0; i < get_desc_trans_len(desc); i++) { | 2245 | for (i = 0; i < get_desc_trans_len(desc); i++) { |
| 2246 | wait_on_buffer(log_blocks[i]); | 2246 | wait_on_buffer(log_blocks[i]); |
| 2247 | if (!buffer_uptodate(log_blocks[i])) { | 2247 | if (!buffer_uptodate(log_blocks[i])) { |
| 2248 | reiserfs_warning(p_s_sb, "journal-1212", | 2248 | reiserfs_warning(sb, "journal-1212", |
| 2249 | "REPLAY FAILURE fsck required! " | 2249 | "REPLAY FAILURE fsck required! " |
| 2250 | "buffer write failed"); | 2250 | "buffer write failed"); |
| 2251 | brelse_array(log_blocks + i, | 2251 | brelse_array(log_blocks + i, |
| @@ -2270,7 +2270,7 @@ static int journal_read_transaction(struct super_block *p_s_sb, | |||
| 2270 | for (i = 0; i < get_desc_trans_len(desc); i++) { | 2270 | for (i = 0; i < get_desc_trans_len(desc); i++) { |
| 2271 | wait_on_buffer(real_blocks[i]); | 2271 | wait_on_buffer(real_blocks[i]); |
| 2272 | if (!buffer_uptodate(real_blocks[i])) { | 2272 | if (!buffer_uptodate(real_blocks[i])) { |
| 2273 | reiserfs_warning(p_s_sb, "journal-1226", | 2273 | reiserfs_warning(sb, "journal-1226", |
| 2274 | "REPLAY FAILURE, fsck required! " | 2274 | "REPLAY FAILURE, fsck required! " |
| 2275 | "buffer write failed"); | 2275 | "buffer write failed"); |
| 2276 | brelse_array(real_blocks + i, | 2276 | brelse_array(real_blocks + i, |
| @@ -2284,15 +2284,15 @@ static int journal_read_transaction(struct super_block *p_s_sb, | |||
| 2284 | brelse(real_blocks[i]); | 2284 | brelse(real_blocks[i]); |
| 2285 | } | 2285 | } |
| 2286 | cur_dblock = | 2286 | cur_dblock = |
| 2287 | SB_ONDISK_JOURNAL_1st_BLOCK(p_s_sb) + | 2287 | SB_ONDISK_JOURNAL_1st_BLOCK(sb) + |
| 2288 | ((trans_offset + get_desc_trans_len(desc) + | 2288 | ((trans_offset + get_desc_trans_len(desc) + |
| 2289 | 2) % SB_ONDISK_JOURNAL_SIZE(p_s_sb)); | 2289 | 2) % SB_ONDISK_JOURNAL_SIZE(sb)); |
| 2290 | reiserfs_debug(p_s_sb, REISERFS_DEBUG_CODE, | 2290 | reiserfs_debug(sb, REISERFS_DEBUG_CODE, |
| 2291 | "journal-1095: setting journal " "start to offset %ld", | 2291 | "journal-1095: setting journal " "start to offset %ld", |
| 2292 | cur_dblock - SB_ONDISK_JOURNAL_1st_BLOCK(p_s_sb)); | 2292 | cur_dblock - SB_ONDISK_JOURNAL_1st_BLOCK(sb)); |
| 2293 | 2293 | ||
| 2294 | /* init starting values for the first transaction, in case this is the last transaction to be replayed. */ | 2294 | /* init starting values for the first transaction, in case this is the last transaction to be replayed. */ |
| 2295 | journal->j_start = cur_dblock - SB_ONDISK_JOURNAL_1st_BLOCK(p_s_sb); | 2295 | journal->j_start = cur_dblock - SB_ONDISK_JOURNAL_1st_BLOCK(sb); |
| 2296 | journal->j_last_flush_trans_id = trans_id; | 2296 | journal->j_last_flush_trans_id = trans_id; |
| 2297 | journal->j_trans_id = trans_id + 1; | 2297 | journal->j_trans_id = trans_id + 1; |
| 2298 | /* check for trans_id overflow */ | 2298 | /* check for trans_id overflow */ |
| @@ -2357,9 +2357,9 @@ static struct buffer_head *reiserfs_breada(struct block_device *dev, | |||
| 2357 | ** | 2357 | ** |
| 2358 | ** On exit, it sets things up so the first transaction will work correctly. | 2358 | ** On exit, it sets things up so the first transaction will work correctly. |
| 2359 | */ | 2359 | */ |
| 2360 | static int journal_read(struct super_block *p_s_sb) | 2360 | static int journal_read(struct super_block *sb) |
| 2361 | { | 2361 | { |
| 2362 | struct reiserfs_journal *journal = SB_JOURNAL(p_s_sb); | 2362 | struct reiserfs_journal *journal = SB_JOURNAL(sb); |
| 2363 | struct reiserfs_journal_desc *desc; | 2363 | struct reiserfs_journal_desc *desc; |
| 2364 | unsigned int oldest_trans_id = 0; | 2364 | unsigned int oldest_trans_id = 0; |
| 2365 | unsigned int oldest_invalid_trans_id = 0; | 2365 | unsigned int oldest_invalid_trans_id = 0; |
| @@ -2375,8 +2375,8 @@ static int journal_read(struct super_block *p_s_sb) | |||
| 2375 | int ret; | 2375 | int ret; |
| 2376 | char b[BDEVNAME_SIZE]; | 2376 | char b[BDEVNAME_SIZE]; |
| 2377 | 2377 | ||
| 2378 | cur_dblock = SB_ONDISK_JOURNAL_1st_BLOCK(p_s_sb); | 2378 | cur_dblock = SB_ONDISK_JOURNAL_1st_BLOCK(sb); |
| 2379 | reiserfs_info(p_s_sb, "checking transaction log (%s)\n", | 2379 | reiserfs_info(sb, "checking transaction log (%s)\n", |
| 2380 | bdevname(journal->j_dev_bd, b)); | 2380 | bdevname(journal->j_dev_bd, b)); |
| 2381 | start = get_seconds(); | 2381 | start = get_seconds(); |
| 2382 | 2382 | ||
| @@ -2384,22 +2384,22 @@ static int journal_read(struct super_block *p_s_sb) | |||
| 2384 | ** is the first unflushed, and if that transaction is not valid, | 2384 | ** is the first unflushed, and if that transaction is not valid, |
| 2385 | ** replay is done | 2385 | ** replay is done |
| 2386 | */ | 2386 | */ |
| 2387 | journal->j_header_bh = journal_bread(p_s_sb, | 2387 | journal->j_header_bh = journal_bread(sb, |
| 2388 | SB_ONDISK_JOURNAL_1st_BLOCK(p_s_sb) | 2388 | SB_ONDISK_JOURNAL_1st_BLOCK(sb) |
| 2389 | + SB_ONDISK_JOURNAL_SIZE(p_s_sb)); | 2389 | + SB_ONDISK_JOURNAL_SIZE(sb)); |
| 2390 | if (!journal->j_header_bh) { | 2390 | if (!journal->j_header_bh) { |
| 2391 | return 1; | 2391 | return 1; |
| 2392 | } | 2392 | } |
| 2393 | jh = (struct reiserfs_journal_header *)(journal->j_header_bh->b_data); | 2393 | jh = (struct reiserfs_journal_header *)(journal->j_header_bh->b_data); |
| 2394 | if (le32_to_cpu(jh->j_first_unflushed_offset) < | 2394 | if (le32_to_cpu(jh->j_first_unflushed_offset) < |
| 2395 | SB_ONDISK_JOURNAL_SIZE(p_s_sb) | 2395 | SB_ONDISK_JOURNAL_SIZE(sb) |
| 2396 | && le32_to_cpu(jh->j_last_flush_trans_id) > 0) { | 2396 | && le32_to_cpu(jh->j_last_flush_trans_id) > 0) { |
| 2397 | oldest_start = | 2397 | oldest_start = |
| 2398 | SB_ONDISK_JOURNAL_1st_BLOCK(p_s_sb) + | 2398 | SB_ONDISK_JOURNAL_1st_BLOCK(sb) + |
| 2399 | le32_to_cpu(jh->j_first_unflushed_offset); | 2399 | le32_to_cpu(jh->j_first_unflushed_offset); |
| 2400 | oldest_trans_id = le32_to_cpu(jh->j_last_flush_trans_id) + 1; | 2400 | oldest_trans_id = le32_to_cpu(jh->j_last_flush_trans_id) + 1; |
| 2401 | newest_mount_id = le32_to_cpu(jh->j_mount_id); | 2401 | newest_mount_id = le32_to_cpu(jh->j_mount_id); |
| 2402 | reiserfs_debug(p_s_sb, REISERFS_DEBUG_CODE, | 2402 | reiserfs_debug(sb, REISERFS_DEBUG_CODE, |
| 2403 | "journal-1153: found in " | 2403 | "journal-1153: found in " |
| 2404 | "header: first_unflushed_offset %d, last_flushed_trans_id " | 2404 | "header: first_unflushed_offset %d, last_flushed_trans_id " |
| 2405 | "%lu", le32_to_cpu(jh->j_first_unflushed_offset), | 2405 | "%lu", le32_to_cpu(jh->j_first_unflushed_offset), |
| @@ -2411,10 +2411,10 @@ static int journal_read(struct super_block *p_s_sb) | |||
| 2411 | ** through the whole log. | 2411 | ** through the whole log. |
| 2412 | */ | 2412 | */ |
| 2413 | d_bh = | 2413 | d_bh = |
| 2414 | journal_bread(p_s_sb, | 2414 | journal_bread(sb, |
| 2415 | SB_ONDISK_JOURNAL_1st_BLOCK(p_s_sb) + | 2415 | SB_ONDISK_JOURNAL_1st_BLOCK(sb) + |
| 2416 | le32_to_cpu(jh->j_first_unflushed_offset)); | 2416 | le32_to_cpu(jh->j_first_unflushed_offset)); |
| 2417 | ret = journal_transaction_is_valid(p_s_sb, d_bh, NULL, NULL); | 2417 | ret = journal_transaction_is_valid(sb, d_bh, NULL, NULL); |
| 2418 | if (!ret) { | 2418 | if (!ret) { |
| 2419 | continue_replay = 0; | 2419 | continue_replay = 0; |
| 2420 | } | 2420 | } |
| @@ -2422,8 +2422,8 @@ static int journal_read(struct super_block *p_s_sb) | |||
| 2422 | goto start_log_replay; | 2422 | goto start_log_replay; |
| 2423 | } | 2423 | } |
| 2424 | 2424 | ||
| 2425 | if (continue_replay && bdev_read_only(p_s_sb->s_bdev)) { | 2425 | if (continue_replay && bdev_read_only(sb->s_bdev)) { |
| 2426 | reiserfs_warning(p_s_sb, "clm-2076", | 2426 | reiserfs_warning(sb, "clm-2076", |
| 2427 | "device is readonly, unable to replay log"); | 2427 | "device is readonly, unable to replay log"); |
| 2428 | return -1; | 2428 | return -1; |
| 2429 | } | 2429 | } |
| @@ -2433,17 +2433,17 @@ static int journal_read(struct super_block *p_s_sb) | |||
| 2433 | */ | 2433 | */ |
| 2434 | while (continue_replay | 2434 | while (continue_replay |
| 2435 | && cur_dblock < | 2435 | && cur_dblock < |
| 2436 | (SB_ONDISK_JOURNAL_1st_BLOCK(p_s_sb) + | 2436 | (SB_ONDISK_JOURNAL_1st_BLOCK(sb) + |
| 2437 | SB_ONDISK_JOURNAL_SIZE(p_s_sb))) { | 2437 | SB_ONDISK_JOURNAL_SIZE(sb))) { |
| 2438 | /* Note that it is required for blocksize of primary fs device and journal | 2438 | /* Note that it is required for blocksize of primary fs device and journal |
| 2439 | device to be the same */ | 2439 | device to be the same */ |
| 2440 | d_bh = | 2440 | d_bh = |
| 2441 | reiserfs_breada(journal->j_dev_bd, cur_dblock, | 2441 | reiserfs_breada(journal->j_dev_bd, cur_dblock, |
| 2442 | p_s_sb->s_blocksize, | 2442 | sb->s_blocksize, |
| 2443 | SB_ONDISK_JOURNAL_1st_BLOCK(p_s_sb) + | 2443 | SB_ONDISK_JOURNAL_1st_BLOCK(sb) + |
| 2444 | SB_ONDISK_JOURNAL_SIZE(p_s_sb)); | 2444 | SB_ONDISK_JOURNAL_SIZE(sb)); |
| 2445 | ret = | 2445 | ret = |
| 2446 | journal_transaction_is_valid(p_s_sb, d_bh, | 2446 | journal_transaction_is_valid(sb, d_bh, |
| 2447 | &oldest_invalid_trans_id, | 2447 | &oldest_invalid_trans_id, |
| 2448 | &newest_mount_id); | 2448 | &newest_mount_id); |
| 2449 | if (ret == 1) { | 2449 | if (ret == 1) { |
| @@ -2452,26 +2452,26 @@ static int journal_read(struct super_block *p_s_sb) | |||
| 2452 | oldest_trans_id = get_desc_trans_id(desc); | 2452 | oldest_trans_id = get_desc_trans_id(desc); |
| 2453 | oldest_start = d_bh->b_blocknr; | 2453 | oldest_start = d_bh->b_blocknr; |
| 2454 | newest_mount_id = get_desc_mount_id(desc); | 2454 | newest_mount_id = get_desc_mount_id(desc); |
| 2455 | reiserfs_debug(p_s_sb, REISERFS_DEBUG_CODE, | 2455 | reiserfs_debug(sb, REISERFS_DEBUG_CODE, |
| 2456 | "journal-1179: Setting " | 2456 | "journal-1179: Setting " |
| 2457 | "oldest_start to offset %llu, trans_id %lu", | 2457 | "oldest_start to offset %llu, trans_id %lu", |
| 2458 | oldest_start - | 2458 | oldest_start - |
| 2459 | SB_ONDISK_JOURNAL_1st_BLOCK | 2459 | SB_ONDISK_JOURNAL_1st_BLOCK |
| 2460 | (p_s_sb), oldest_trans_id); | 2460 | (sb), oldest_trans_id); |
| 2461 | } else if (oldest_trans_id > get_desc_trans_id(desc)) { | 2461 | } else if (oldest_trans_id > get_desc_trans_id(desc)) { |
| 2462 | /* one we just read was older */ | 2462 | /* one we just read was older */ |
| 2463 | oldest_trans_id = get_desc_trans_id(desc); | 2463 | oldest_trans_id = get_desc_trans_id(desc); |
| 2464 | oldest_start = d_bh->b_blocknr; | 2464 | oldest_start = d_bh->b_blocknr; |
| 2465 | reiserfs_debug(p_s_sb, REISERFS_DEBUG_CODE, | 2465 | reiserfs_debug(sb, REISERFS_DEBUG_CODE, |
| 2466 | "journal-1180: Resetting " | 2466 | "journal-1180: Resetting " |
| 2467 | "oldest_start to offset %lu, trans_id %lu", | 2467 | "oldest_start to offset %lu, trans_id %lu", |
| 2468 | oldest_start - | 2468 | oldest_start - |
| 2469 | SB_ONDISK_JOURNAL_1st_BLOCK | 2469 | SB_ONDISK_JOURNAL_1st_BLOCK |
| 2470 | (p_s_sb), oldest_trans_id); | 2470 | (sb), oldest_trans_id); |
| 2471 | } | 2471 | } |
| 2472 | if (newest_mount_id < get_desc_mount_id(desc)) { | 2472 | if (newest_mount_id < get_desc_mount_id(desc)) { |
| 2473 | newest_mount_id = get_desc_mount_id(desc); | 2473 | newest_mount_id = get_desc_mount_id(desc); |
| 2474 | reiserfs_debug(p_s_sb, REISERFS_DEBUG_CODE, | 2474 | reiserfs_debug(sb, REISERFS_DEBUG_CODE, |
| 2475 | "journal-1299: Setting " | 2475 | "journal-1299: Setting " |
| 2476 | "newest_mount_id to %d", | 2476 | "newest_mount_id to %d", |
| 2477 | get_desc_mount_id(desc)); | 2477 | get_desc_mount_id(desc)); |
| @@ -2486,17 +2486,17 @@ static int journal_read(struct super_block *p_s_sb) | |||
| 2486 | start_log_replay: | 2486 | start_log_replay: |
| 2487 | cur_dblock = oldest_start; | 2487 | cur_dblock = oldest_start; |
| 2488 | if (oldest_trans_id) { | 2488 | if (oldest_trans_id) { |
| 2489 | reiserfs_debug(p_s_sb, REISERFS_DEBUG_CODE, | 2489 | reiserfs_debug(sb, REISERFS_DEBUG_CODE, |
| 2490 | "journal-1206: Starting replay " | 2490 | "journal-1206: Starting replay " |
| 2491 | "from offset %llu, trans_id %lu", | 2491 | "from offset %llu, trans_id %lu", |
| 2492 | cur_dblock - SB_ONDISK_JOURNAL_1st_BLOCK(p_s_sb), | 2492 | cur_dblock - SB_ONDISK_JOURNAL_1st_BLOCK(sb), |
| 2493 | oldest_trans_id); | 2493 | oldest_trans_id); |
| 2494 | 2494 | ||
| 2495 | } | 2495 | } |
| 2496 | replay_count = 0; | 2496 | replay_count = 0; |
| 2497 | while (continue_replay && oldest_trans_id > 0) { | 2497 | while (continue_replay && oldest_trans_id > 0) { |
| 2498 | ret = | 2498 | ret = |
| 2499 | journal_read_transaction(p_s_sb, cur_dblock, oldest_start, | 2499 | journal_read_transaction(sb, cur_dblock, oldest_start, |
| 2500 | oldest_trans_id, newest_mount_id); | 2500 | oldest_trans_id, newest_mount_id); |
| 2501 | if (ret < 0) { | 2501 | if (ret < 0) { |
| 2502 | return ret; | 2502 | return ret; |
| @@ -2504,14 +2504,14 @@ static int journal_read(struct super_block *p_s_sb) | |||
| 2504 | break; | 2504 | break; |
| 2505 | } | 2505 | } |
| 2506 | cur_dblock = | 2506 | cur_dblock = |
| 2507 | SB_ONDISK_JOURNAL_1st_BLOCK(p_s_sb) + journal->j_start; | 2507 | SB_ONDISK_JOURNAL_1st_BLOCK(sb) + journal->j_start; |
| 2508 | replay_count++; | 2508 | replay_count++; |
| 2509 | if (cur_dblock == oldest_start) | 2509 | if (cur_dblock == oldest_start) |
| 2510 | break; | 2510 | break; |
| 2511 | } | 2511 | } |
| 2512 | 2512 | ||
| 2513 | if (oldest_trans_id == 0) { | 2513 | if (oldest_trans_id == 0) { |
| 2514 | reiserfs_debug(p_s_sb, REISERFS_DEBUG_CODE, | 2514 | reiserfs_debug(sb, REISERFS_DEBUG_CODE, |
| 2515 | "journal-1225: No valid " "transactions found"); | 2515 | "journal-1225: No valid " "transactions found"); |
| 2516 | } | 2516 | } |
| 2517 | /* j_start does not get set correctly if we don't replay any transactions. | 2517 | /* j_start does not get set correctly if we don't replay any transactions. |
| @@ -2531,16 +2531,16 @@ static int journal_read(struct super_block *p_s_sb) | |||
| 2531 | } else { | 2531 | } else { |
| 2532 | journal->j_mount_id = newest_mount_id + 1; | 2532 | journal->j_mount_id = newest_mount_id + 1; |
| 2533 | } | 2533 | } |
| 2534 | reiserfs_debug(p_s_sb, REISERFS_DEBUG_CODE, "journal-1299: Setting " | 2534 | reiserfs_debug(sb, REISERFS_DEBUG_CODE, "journal-1299: Setting " |
| 2535 | "newest_mount_id to %lu", journal->j_mount_id); | 2535 | "newest_mount_id to %lu", journal->j_mount_id); |
| 2536 | journal->j_first_unflushed_offset = journal->j_start; | 2536 | journal->j_first_unflushed_offset = journal->j_start; |
| 2537 | if (replay_count > 0) { | 2537 | if (replay_count > 0) { |
| 2538 | reiserfs_info(p_s_sb, | 2538 | reiserfs_info(sb, |
| 2539 | "replayed %d transactions in %lu seconds\n", | 2539 | "replayed %d transactions in %lu seconds\n", |
| 2540 | replay_count, get_seconds() - start); | 2540 | replay_count, get_seconds() - start); |
| 2541 | } | 2541 | } |
| 2542 | if (!bdev_read_only(p_s_sb->s_bdev) && | 2542 | if (!bdev_read_only(sb->s_bdev) && |
| 2543 | _update_journal_header_block(p_s_sb, journal->j_start, | 2543 | _update_journal_header_block(sb, journal->j_start, |
| 2544 | journal->j_last_flush_trans_id)) { | 2544 | journal->j_last_flush_trans_id)) { |
| 2545 | /* replay failed, caller must call free_journal_ram and abort | 2545 | /* replay failed, caller must call free_journal_ram and abort |
| 2546 | ** the mount | 2546 | ** the mount |
| @@ -2565,9 +2565,9 @@ static struct reiserfs_journal_list *alloc_journal_list(struct super_block *s) | |||
| 2565 | return jl; | 2565 | return jl; |
| 2566 | } | 2566 | } |
| 2567 | 2567 | ||
| 2568 | static void journal_list_init(struct super_block *p_s_sb) | 2568 | static void journal_list_init(struct super_block *sb) |
| 2569 | { | 2569 | { |
| 2570 | SB_JOURNAL(p_s_sb)->j_current_jl = alloc_journal_list(p_s_sb); | 2570 | SB_JOURNAL(sb)->j_current_jl = alloc_journal_list(sb); |
| 2571 | } | 2571 | } |
| 2572 | 2572 | ||
| 2573 | static int release_journal_dev(struct super_block *super, | 2573 | static int release_journal_dev(struct super_block *super, |
| @@ -2666,28 +2666,28 @@ static int journal_init_dev(struct super_block *super, | |||
| 2666 | */ | 2666 | */ |
| 2667 | #define REISERFS_STANDARD_BLKSIZE (4096) | 2667 | #define REISERFS_STANDARD_BLKSIZE (4096) |
| 2668 | 2668 | ||
| 2669 | static int check_advise_trans_params(struct super_block *p_s_sb, | 2669 | static int check_advise_trans_params(struct super_block *sb, |
| 2670 | struct reiserfs_journal *journal) | 2670 | struct reiserfs_journal *journal) |
| 2671 | { | 2671 | { |
| 2672 | if (journal->j_trans_max) { | 2672 | if (journal->j_trans_max) { |
| 2673 | /* Non-default journal params. | 2673 | /* Non-default journal params. |
| 2674 | Do sanity check for them. */ | 2674 | Do sanity check for them. */ |
| 2675 | int ratio = 1; | 2675 | int ratio = 1; |
| 2676 | if (p_s_sb->s_blocksize < REISERFS_STANDARD_BLKSIZE) | 2676 | if (sb->s_blocksize < REISERFS_STANDARD_BLKSIZE) |
| 2677 | ratio = REISERFS_STANDARD_BLKSIZE / p_s_sb->s_blocksize; | 2677 | ratio = REISERFS_STANDARD_BLKSIZE / sb->s_blocksize; |
| 2678 | 2678 | ||
| 2679 | if (journal->j_trans_max > JOURNAL_TRANS_MAX_DEFAULT / ratio || | 2679 | if (journal->j_trans_max > JOURNAL_TRANS_MAX_DEFAULT / ratio || |
| 2680 | journal->j_trans_max < JOURNAL_TRANS_MIN_DEFAULT / ratio || | 2680 | journal->j_trans_max < JOURNAL_TRANS_MIN_DEFAULT / ratio || |
| 2681 | SB_ONDISK_JOURNAL_SIZE(p_s_sb) / journal->j_trans_max < | 2681 | SB_ONDISK_JOURNAL_SIZE(sb) / journal->j_trans_max < |
| 2682 | JOURNAL_MIN_RATIO) { | 2682 | JOURNAL_MIN_RATIO) { |
| 2683 | reiserfs_warning(p_s_sb, "sh-462", | 2683 | reiserfs_warning(sb, "sh-462", |
| 2684 | "bad transaction max size (%u). " | 2684 | "bad transaction max size (%u). " |
| 2685 | "FSCK?", journal->j_trans_max); | 2685 | "FSCK?", journal->j_trans_max); |
| 2686 | return 1; | 2686 | return 1; |
| 2687 | } | 2687 | } |
| 2688 | if (journal->j_max_batch != (journal->j_trans_max) * | 2688 | if (journal->j_max_batch != (journal->j_trans_max) * |
| 2689 | JOURNAL_MAX_BATCH_DEFAULT/JOURNAL_TRANS_MAX_DEFAULT) { | 2689 | JOURNAL_MAX_BATCH_DEFAULT/JOURNAL_TRANS_MAX_DEFAULT) { |
| 2690 | reiserfs_warning(p_s_sb, "sh-463", | 2690 | reiserfs_warning(sb, "sh-463", |
| 2691 | "bad transaction max batch (%u). " | 2691 | "bad transaction max batch (%u). " |
| 2692 | "FSCK?", journal->j_max_batch); | 2692 | "FSCK?", journal->j_max_batch); |
| 2693 | return 1; | 2693 | return 1; |
| @@ -2697,9 +2697,9 @@ static int check_advise_trans_params(struct super_block *p_s_sb, | |||
| 2697 | The file system was created by old version | 2697 | The file system was created by old version |
| 2698 | of mkreiserfs, so some fields contain zeros, | 2698 | of mkreiserfs, so some fields contain zeros, |
| 2699 | and we need to advise proper values for them */ | 2699 | and we need to advise proper values for them */ |
| 2700 | if (p_s_sb->s_blocksize != REISERFS_STANDARD_BLKSIZE) { | 2700 | if (sb->s_blocksize != REISERFS_STANDARD_BLKSIZE) { |
| 2701 | reiserfs_warning(p_s_sb, "sh-464", "bad blocksize (%u)", | 2701 | reiserfs_warning(sb, "sh-464", "bad blocksize (%u)", |
| 2702 | p_s_sb->s_blocksize); | 2702 | sb->s_blocksize); |
| 2703 | return 1; | 2703 | return 1; |
| 2704 | } | 2704 | } |
| 2705 | journal->j_trans_max = JOURNAL_TRANS_MAX_DEFAULT; | 2705 | journal->j_trans_max = JOURNAL_TRANS_MAX_DEFAULT; |
| @@ -2712,10 +2712,10 @@ static int check_advise_trans_params(struct super_block *p_s_sb, | |||
| 2712 | /* | 2712 | /* |
| 2713 | ** must be called once on fs mount. calls journal_read for you | 2713 | ** must be called once on fs mount. calls journal_read for you |
| 2714 | */ | 2714 | */ |
| 2715 | int journal_init(struct super_block *p_s_sb, const char *j_dev_name, | 2715 | int journal_init(struct super_block *sb, const char *j_dev_name, |
| 2716 | int old_format, unsigned int commit_max_age) | 2716 | int old_format, unsigned int commit_max_age) |
| 2717 | { | 2717 | { |
| 2718 | int num_cnodes = SB_ONDISK_JOURNAL_SIZE(p_s_sb) * 2; | 2718 | int num_cnodes = SB_ONDISK_JOURNAL_SIZE(sb) * 2; |
| 2719 | struct buffer_head *bhjh; | 2719 | struct buffer_head *bhjh; |
| 2720 | struct reiserfs_super_block *rs; | 2720 | struct reiserfs_super_block *rs; |
| 2721 | struct reiserfs_journal_header *jh; | 2721 | struct reiserfs_journal_header *jh; |
| @@ -2723,9 +2723,9 @@ int journal_init(struct super_block *p_s_sb, const char *j_dev_name, | |||
| 2723 | struct reiserfs_journal_list *jl; | 2723 | struct reiserfs_journal_list *jl; |
| 2724 | char b[BDEVNAME_SIZE]; | 2724 | char b[BDEVNAME_SIZE]; |
| 2725 | 2725 | ||
| 2726 | journal = SB_JOURNAL(p_s_sb) = vmalloc(sizeof(struct reiserfs_journal)); | 2726 | journal = SB_JOURNAL(sb) = vmalloc(sizeof(struct reiserfs_journal)); |
| 2727 | if (!journal) { | 2727 | if (!journal) { |
| 2728 | reiserfs_warning(p_s_sb, "journal-1256", | 2728 | reiserfs_warning(sb, "journal-1256", |
| 2729 | "unable to get memory for journal structure"); | 2729 | "unable to get memory for journal structure"); |
| 2730 | return 1; | 2730 | return 1; |
| 2731 | } | 2731 | } |
| @@ -2735,50 +2735,50 @@ int journal_init(struct super_block *p_s_sb, const char *j_dev_name, | |||
| 2735 | INIT_LIST_HEAD(&journal->j_working_list); | 2735 | INIT_LIST_HEAD(&journal->j_working_list); |
| 2736 | INIT_LIST_HEAD(&journal->j_journal_list); | 2736 | INIT_LIST_HEAD(&journal->j_journal_list); |
| 2737 | journal->j_persistent_trans = 0; | 2737 | journal->j_persistent_trans = 0; |
| 2738 | if (reiserfs_allocate_list_bitmaps(p_s_sb, | 2738 | if (reiserfs_allocate_list_bitmaps(sb, |
| 2739 | journal->j_list_bitmap, | 2739 | journal->j_list_bitmap, |
| 2740 | reiserfs_bmap_count(p_s_sb))) | 2740 | reiserfs_bmap_count(sb))) |
| 2741 | goto free_and_return; | 2741 | goto free_and_return; |
| 2742 | allocate_bitmap_nodes(p_s_sb); | 2742 | allocate_bitmap_nodes(sb); |
| 2743 | 2743 | ||
| 2744 | /* reserved for journal area support */ | 2744 | /* reserved for journal area support */ |
| 2745 | SB_JOURNAL_1st_RESERVED_BLOCK(p_s_sb) = (old_format ? | 2745 | SB_JOURNAL_1st_RESERVED_BLOCK(sb) = (old_format ? |
| 2746 | REISERFS_OLD_DISK_OFFSET_IN_BYTES | 2746 | REISERFS_OLD_DISK_OFFSET_IN_BYTES |
| 2747 | / p_s_sb->s_blocksize + | 2747 | / sb->s_blocksize + |
| 2748 | reiserfs_bmap_count(p_s_sb) + | 2748 | reiserfs_bmap_count(sb) + |
| 2749 | 1 : | 2749 | 1 : |
| 2750 | REISERFS_DISK_OFFSET_IN_BYTES / | 2750 | REISERFS_DISK_OFFSET_IN_BYTES / |
| 2751 | p_s_sb->s_blocksize + 2); | 2751 | sb->s_blocksize + 2); |
| 2752 | 2752 | ||
| 2753 | /* Sanity check to see is the standard journal fitting withing first bitmap | 2753 | /* Sanity check to see is the standard journal fitting withing first bitmap |
| 2754 | (actual for small blocksizes) */ | 2754 | (actual for small blocksizes) */ |
| 2755 | if (!SB_ONDISK_JOURNAL_DEVICE(p_s_sb) && | 2755 | if (!SB_ONDISK_JOURNAL_DEVICE(sb) && |
| 2756 | (SB_JOURNAL_1st_RESERVED_BLOCK(p_s_sb) + | 2756 | (SB_JOURNAL_1st_RESERVED_BLOCK(sb) + |
| 2757 | SB_ONDISK_JOURNAL_SIZE(p_s_sb) > p_s_sb->s_blocksize * 8)) { | 2757 | SB_ONDISK_JOURNAL_SIZE(sb) > sb->s_blocksize * 8)) { |
| 2758 | reiserfs_warning(p_s_sb, "journal-1393", | 2758 | reiserfs_warning(sb, "journal-1393", |
| 2759 | "journal does not fit for area addressed " | 2759 | "journal does not fit for area addressed " |
| 2760 | "by first of bitmap blocks. It starts at " | 2760 | "by first of bitmap blocks. It starts at " |
| 2761 | "%u and its size is %u. Block size %ld", | 2761 | "%u and its size is %u. Block size %ld", |
| 2762 | SB_JOURNAL_1st_RESERVED_BLOCK(p_s_sb), | 2762 | SB_JOURNAL_1st_RESERVED_BLOCK(sb), |
| 2763 | SB_ONDISK_JOURNAL_SIZE(p_s_sb), | 2763 | SB_ONDISK_JOURNAL_SIZE(sb), |
| 2764 | p_s_sb->s_blocksize); | 2764 | sb->s_blocksize); |
| 2765 | goto free_and_return; | 2765 | goto free_and_return; |
| 2766 | } | 2766 | } |
| 2767 | 2767 | ||
| 2768 | if (journal_init_dev(p_s_sb, journal, j_dev_name) != 0) { | 2768 | if (journal_init_dev(sb, journal, j_dev_name) != 0) { |
| 2769 | reiserfs_warning(p_s_sb, "sh-462", | 2769 | reiserfs_warning(sb, "sh-462", |
| 2770 | "unable to initialize jornal device"); | 2770 | "unable to initialize jornal device"); |
| 2771 | goto free_and_return; | 2771 | goto free_and_return; |
| 2772 | } | 2772 | } |
| 2773 | 2773 | ||
| 2774 | rs = SB_DISK_SUPER_BLOCK(p_s_sb); | 2774 | rs = SB_DISK_SUPER_BLOCK(sb); |
| 2775 | 2775 | ||
| 2776 | /* read journal header */ | 2776 | /* read journal header */ |
| 2777 | bhjh = journal_bread(p_s_sb, | 2777 | bhjh = journal_bread(sb, |
| 2778 | SB_ONDISK_JOURNAL_1st_BLOCK(p_s_sb) + | 2778 | SB_ONDISK_JOURNAL_1st_BLOCK(sb) + |
| 2779 | SB_ONDISK_JOURNAL_SIZE(p_s_sb)); | 2779 | SB_ONDISK_JOURNAL_SIZE(sb)); |
| 2780 | if (!bhjh) { | 2780 | if (!bhjh) { |
| 2781 | reiserfs_warning(p_s_sb, "sh-459", | 2781 | reiserfs_warning(sb, "sh-459", |
| 2782 | "unable to read journal header"); | 2782 | "unable to read journal header"); |
| 2783 | goto free_and_return; | 2783 | goto free_and_return; |
| 2784 | } | 2784 | } |
| @@ -2788,7 +2788,7 @@ int journal_init(struct super_block *p_s_sb, const char *j_dev_name, | |||
| 2788 | if (is_reiserfs_jr(rs) | 2788 | if (is_reiserfs_jr(rs) |
| 2789 | && (le32_to_cpu(jh->jh_journal.jp_journal_magic) != | 2789 | && (le32_to_cpu(jh->jh_journal.jp_journal_magic) != |
| 2790 | sb_jp_journal_magic(rs))) { | 2790 | sb_jp_journal_magic(rs))) { |
| 2791 | reiserfs_warning(p_s_sb, "sh-460", | 2791 | reiserfs_warning(sb, "sh-460", |
| 2792 | "journal header magic %x (device %s) does " | 2792 | "journal header magic %x (device %s) does " |
| 2793 | "not match to magic found in super block %x", | 2793 | "not match to magic found in super block %x", |
| 2794 | jh->jh_journal.jp_journal_magic, | 2794 | jh->jh_journal.jp_journal_magic, |
| @@ -2804,7 +2804,7 @@ int journal_init(struct super_block *p_s_sb, const char *j_dev_name, | |||
| 2804 | le32_to_cpu(jh->jh_journal.jp_journal_max_commit_age); | 2804 | le32_to_cpu(jh->jh_journal.jp_journal_max_commit_age); |
| 2805 | journal->j_max_trans_age = JOURNAL_MAX_TRANS_AGE; | 2805 | journal->j_max_trans_age = JOURNAL_MAX_TRANS_AGE; |
| 2806 | 2806 | ||
| 2807 | if (check_advise_trans_params(p_s_sb, journal) != 0) | 2807 | if (check_advise_trans_params(sb, journal) != 0) |
| 2808 | goto free_and_return; | 2808 | goto free_and_return; |
| 2809 | journal->j_default_max_commit_age = journal->j_max_commit_age; | 2809 | journal->j_default_max_commit_age = journal->j_max_commit_age; |
| 2810 | 2810 | ||
| @@ -2813,12 +2813,12 @@ int journal_init(struct super_block *p_s_sb, const char *j_dev_name, | |||
| 2813 | journal->j_max_trans_age = commit_max_age; | 2813 | journal->j_max_trans_age = commit_max_age; |
| 2814 | } | 2814 | } |
| 2815 | 2815 | ||
| 2816 | reiserfs_info(p_s_sb, "journal params: device %s, size %u, " | 2816 | reiserfs_info(sb, "journal params: device %s, size %u, " |
| 2817 | "journal first block %u, max trans len %u, max batch %u, " | 2817 | "journal first block %u, max trans len %u, max batch %u, " |
| 2818 | "max commit age %u, max trans age %u\n", | 2818 | "max commit age %u, max trans age %u\n", |
| 2819 | bdevname(journal->j_dev_bd, b), | 2819 | bdevname(journal->j_dev_bd, b), |
| 2820 | SB_ONDISK_JOURNAL_SIZE(p_s_sb), | 2820 | SB_ONDISK_JOURNAL_SIZE(sb), |
| 2821 | SB_ONDISK_JOURNAL_1st_BLOCK(p_s_sb), | 2821 | SB_ONDISK_JOURNAL_1st_BLOCK(sb), |
| 2822 | journal->j_trans_max, | 2822 | journal->j_trans_max, |
| 2823 | journal->j_max_batch, | 2823 | journal->j_max_batch, |
| 2824 | journal->j_max_commit_age, journal->j_max_trans_age); | 2824 | journal->j_max_commit_age, journal->j_max_trans_age); |
| @@ -2826,7 +2826,7 @@ int journal_init(struct super_block *p_s_sb, const char *j_dev_name, | |||
| 2826 | brelse(bhjh); | 2826 | brelse(bhjh); |
| 2827 | 2827 | ||
| 2828 | journal->j_list_bitmap_index = 0; | 2828 | journal->j_list_bitmap_index = 0; |
| 2829 | journal_list_init(p_s_sb); | 2829 | journal_list_init(sb); |
| 2830 | 2830 | ||
| 2831 | memset(journal->j_list_hash_table, 0, | 2831 | memset(journal->j_list_hash_table, 0, |
| 2832 | JOURNAL_HASH_SIZE * sizeof(struct reiserfs_journal_cnode *)); | 2832 | JOURNAL_HASH_SIZE * sizeof(struct reiserfs_journal_cnode *)); |
| @@ -2858,7 +2858,7 @@ int journal_init(struct super_block *p_s_sb, const char *j_dev_name, | |||
| 2858 | journal->j_must_wait = 0; | 2858 | journal->j_must_wait = 0; |
| 2859 | 2859 | ||
| 2860 | if (journal->j_cnode_free == 0) { | 2860 | if (journal->j_cnode_free == 0) { |
| 2861 | reiserfs_warning(p_s_sb, "journal-2004", "Journal cnode memory " | 2861 | reiserfs_warning(sb, "journal-2004", "Journal cnode memory " |
| 2862 | "allocation failed (%ld bytes). Journal is " | 2862 | "allocation failed (%ld bytes). Journal is " |
| 2863 | "too large for available memory. Usually " | 2863 | "too large for available memory. Usually " |
| 2864 | "this is due to a journal that is too large.", | 2864 | "this is due to a journal that is too large.", |
| @@ -2866,16 +2866,16 @@ int journal_init(struct super_block *p_s_sb, const char *j_dev_name, | |||
| 2866 | goto free_and_return; | 2866 | goto free_and_return; |
| 2867 | } | 2867 | } |
| 2868 | 2868 | ||
| 2869 | init_journal_hash(p_s_sb); | 2869 | init_journal_hash(sb); |
| 2870 | jl = journal->j_current_jl; | 2870 | jl = journal->j_current_jl; |
| 2871 | jl->j_list_bitmap = get_list_bitmap(p_s_sb, jl); | 2871 | jl->j_list_bitmap = get_list_bitmap(sb, jl); |
| 2872 | if (!jl->j_list_bitmap) { | 2872 | if (!jl->j_list_bitmap) { |
| 2873 | reiserfs_warning(p_s_sb, "journal-2005", | 2873 | reiserfs_warning(sb, "journal-2005", |
| 2874 | "get_list_bitmap failed for journal list 0"); | 2874 | "get_list_bitmap failed for journal list 0"); |
| 2875 | goto free_and_return; | 2875 | goto free_and_return; |
| 2876 | } | 2876 | } |
| 2877 | if (journal_read(p_s_sb) < 0) { | 2877 | if (journal_read(sb) < 0) { |
| 2878 | reiserfs_warning(p_s_sb, "reiserfs-2006", | 2878 | reiserfs_warning(sb, "reiserfs-2006", |
| 2879 | "Replay Failure, unable to mount"); | 2879 | "Replay Failure, unable to mount"); |
| 2880 | goto free_and_return; | 2880 | goto free_and_return; |
| 2881 | } | 2881 | } |
| @@ -2885,10 +2885,10 @@ int journal_init(struct super_block *p_s_sb, const char *j_dev_name, | |||
| 2885 | commit_wq = create_workqueue("reiserfs"); | 2885 | commit_wq = create_workqueue("reiserfs"); |
| 2886 | 2886 | ||
| 2887 | INIT_DELAYED_WORK(&journal->j_work, flush_async_commits); | 2887 | INIT_DELAYED_WORK(&journal->j_work, flush_async_commits); |
| 2888 | journal->j_work_sb = p_s_sb; | 2888 | journal->j_work_sb = sb; |
| 2889 | return 0; | 2889 | return 0; |
| 2890 | free_and_return: | 2890 | free_and_return: |
| 2891 | free_journal_ram(p_s_sb); | 2891 | free_journal_ram(sb); |
| 2892 | return 1; | 2892 | return 1; |
| 2893 | } | 2893 | } |
| 2894 | 2894 | ||
| @@ -3004,37 +3004,37 @@ static void let_transaction_grow(struct super_block *sb, unsigned int trans_id) | |||
| 3004 | ** expect to use in nblocks. | 3004 | ** expect to use in nblocks. |
| 3005 | */ | 3005 | */ |
| 3006 | static int do_journal_begin_r(struct reiserfs_transaction_handle *th, | 3006 | static int do_journal_begin_r(struct reiserfs_transaction_handle *th, |
| 3007 | struct super_block *p_s_sb, unsigned long nblocks, | 3007 | struct super_block *sb, unsigned long nblocks, |
| 3008 | int join) | 3008 | int join) |
| 3009 | { | 3009 | { |
| 3010 | time_t now = get_seconds(); | 3010 | time_t now = get_seconds(); |
| 3011 | unsigned int old_trans_id; | 3011 | unsigned int old_trans_id; |
| 3012 | struct reiserfs_journal *journal = SB_JOURNAL(p_s_sb); | 3012 | struct reiserfs_journal *journal = SB_JOURNAL(sb); |
| 3013 | struct reiserfs_transaction_handle myth; | 3013 | struct reiserfs_transaction_handle myth; |
| 3014 | int sched_count = 0; | 3014 | int sched_count = 0; |
| 3015 | int retval; | 3015 | int retval; |
| 3016 | 3016 | ||
| 3017 | reiserfs_check_lock_depth(p_s_sb, "journal_begin"); | 3017 | reiserfs_check_lock_depth(sb, "journal_begin"); |
| 3018 | BUG_ON(nblocks > journal->j_trans_max); | 3018 | BUG_ON(nblocks > journal->j_trans_max); |
| 3019 | 3019 | ||
| 3020 | PROC_INFO_INC(p_s_sb, journal.journal_being); | 3020 | PROC_INFO_INC(sb, journal.journal_being); |
| 3021 | /* set here for journal_join */ | 3021 | /* set here for journal_join */ |
| 3022 | th->t_refcount = 1; | 3022 | th->t_refcount = 1; |
| 3023 | th->t_super = p_s_sb; | 3023 | th->t_super = sb; |
| 3024 | 3024 | ||
| 3025 | relock: | 3025 | relock: |
| 3026 | lock_journal(p_s_sb); | 3026 | lock_journal(sb); |
| 3027 | if (join != JBEGIN_ABORT && reiserfs_is_journal_aborted(journal)) { | 3027 | if (join != JBEGIN_ABORT && reiserfs_is_journal_aborted(journal)) { |
| 3028 | unlock_journal(p_s_sb); | 3028 | unlock_journal(sb); |
| 3029 | retval = journal->j_errno; | 3029 | retval = journal->j_errno; |
| 3030 | goto out_fail; | 3030 | goto out_fail; |
| 3031 | } | 3031 | } |
| 3032 | journal->j_bcount++; | 3032 | journal->j_bcount++; |
| 3033 | 3033 | ||
| 3034 | if (test_bit(J_WRITERS_BLOCKED, &journal->j_state)) { | 3034 | if (test_bit(J_WRITERS_BLOCKED, &journal->j_state)) { |
| 3035 | unlock_journal(p_s_sb); | 3035 | unlock_journal(sb); |
| 3036 | reiserfs_wait_on_write_block(p_s_sb); | 3036 | reiserfs_wait_on_write_block(sb); |
| 3037 | PROC_INFO_INC(p_s_sb, journal.journal_relock_writers); | 3037 | PROC_INFO_INC(sb, journal.journal_relock_writers); |
| 3038 | goto relock; | 3038 | goto relock; |
| 3039 | } | 3039 | } |
| 3040 | now = get_seconds(); | 3040 | now = get_seconds(); |
| @@ -3055,7 +3055,7 @@ static int do_journal_begin_r(struct reiserfs_transaction_handle *th, | |||
| 3055 | || (!join && journal->j_cnode_free < (journal->j_trans_max * 3))) { | 3055 | || (!join && journal->j_cnode_free < (journal->j_trans_max * 3))) { |
| 3056 | 3056 | ||
| 3057 | old_trans_id = journal->j_trans_id; | 3057 | old_trans_id = journal->j_trans_id; |
| 3058 | unlock_journal(p_s_sb); /* allow others to finish this transaction */ | 3058 | unlock_journal(sb); /* allow others to finish this transaction */ |
| 3059 | 3059 | ||
| 3060 | if (!join && (journal->j_len_alloc + nblocks + 2) >= | 3060 | if (!join && (journal->j_len_alloc + nblocks + 2) >= |
| 3061 | journal->j_max_batch && | 3061 | journal->j_max_batch && |
| @@ -3063,7 +3063,7 @@ static int do_journal_begin_r(struct reiserfs_transaction_handle *th, | |||
| 3063 | (journal->j_len_alloc * 75)) { | 3063 | (journal->j_len_alloc * 75)) { |
| 3064 | if (atomic_read(&journal->j_wcount) > 10) { | 3064 | if (atomic_read(&journal->j_wcount) > 10) { |
| 3065 | sched_count++; | 3065 | sched_count++; |
| 3066 | queue_log_writer(p_s_sb); | 3066 | queue_log_writer(sb); |
| 3067 | goto relock; | 3067 | goto relock; |
| 3068 | } | 3068 | } |
| 3069 | } | 3069 | } |
| @@ -3073,25 +3073,25 @@ static int do_journal_begin_r(struct reiserfs_transaction_handle *th, | |||
| 3073 | if (atomic_read(&journal->j_jlock)) { | 3073 | if (atomic_read(&journal->j_jlock)) { |
| 3074 | while (journal->j_trans_id == old_trans_id && | 3074 | while (journal->j_trans_id == old_trans_id && |
| 3075 | atomic_read(&journal->j_jlock)) { | 3075 | atomic_read(&journal->j_jlock)) { |
| 3076 | queue_log_writer(p_s_sb); | 3076 | queue_log_writer(sb); |
| 3077 | } | 3077 | } |
| 3078 | goto relock; | 3078 | goto relock; |
| 3079 | } | 3079 | } |
| 3080 | retval = journal_join(&myth, p_s_sb, 1); | 3080 | retval = journal_join(&myth, sb, 1); |
| 3081 | if (retval) | 3081 | if (retval) |
| 3082 | goto out_fail; | 3082 | goto out_fail; |
| 3083 | 3083 | ||
| 3084 | /* someone might have ended the transaction while we joined */ | 3084 | /* someone might have ended the transaction while we joined */ |
| 3085 | if (old_trans_id != journal->j_trans_id) { | 3085 | if (old_trans_id != journal->j_trans_id) { |
| 3086 | retval = do_journal_end(&myth, p_s_sb, 1, 0); | 3086 | retval = do_journal_end(&myth, sb, 1, 0); |
| 3087 | } else { | 3087 | } else { |
| 3088 | retval = do_journal_end(&myth, p_s_sb, 1, COMMIT_NOW); | 3088 | retval = do_journal_end(&myth, sb, 1, COMMIT_NOW); |
| 3089 | } | 3089 | } |
| 3090 | 3090 | ||
| 3091 | if (retval) | 3091 | if (retval) |
| 3092 | goto out_fail; | 3092 | goto out_fail; |
| 3093 | 3093 | ||
| 3094 | PROC_INFO_INC(p_s_sb, journal.journal_relock_wcount); | 3094 | PROC_INFO_INC(sb, journal.journal_relock_wcount); |
| 3095 | goto relock; | 3095 | goto relock; |
| 3096 | } | 3096 | } |
| 3097 | /* we are the first writer, set trans_id */ | 3097 | /* we are the first writer, set trans_id */ |
| @@ -3103,7 +3103,7 @@ static int do_journal_begin_r(struct reiserfs_transaction_handle *th, | |||
| 3103 | th->t_blocks_logged = 0; | 3103 | th->t_blocks_logged = 0; |
| 3104 | th->t_blocks_allocated = nblocks; | 3104 | th->t_blocks_allocated = nblocks; |
| 3105 | th->t_trans_id = journal->j_trans_id; | 3105 | th->t_trans_id = journal->j_trans_id; |
| 3106 | unlock_journal(p_s_sb); | 3106 | unlock_journal(sb); |
| 3107 | INIT_LIST_HEAD(&th->t_list); | 3107 | INIT_LIST_HEAD(&th->t_list); |
| 3108 | get_fs_excl(); | 3108 | get_fs_excl(); |
| 3109 | return 0; | 3109 | return 0; |
| @@ -3113,7 +3113,7 @@ static int do_journal_begin_r(struct reiserfs_transaction_handle *th, | |||
| 3113 | /* Re-set th->t_super, so we can properly keep track of how many | 3113 | /* Re-set th->t_super, so we can properly keep track of how many |
| 3114 | * persistent transactions there are. We need to do this so if this | 3114 | * persistent transactions there are. We need to do this so if this |
| 3115 | * call is part of a failed restart_transaction, we can free it later */ | 3115 | * call is part of a failed restart_transaction, we can free it later */ |
| 3116 | th->t_super = p_s_sb; | 3116 | th->t_super = sb; |
| 3117 | return retval; | 3117 | return retval; |
| 3118 | } | 3118 | } |
| 3119 | 3119 | ||
| @@ -3164,7 +3164,7 @@ int reiserfs_end_persistent_transaction(struct reiserfs_transaction_handle *th) | |||
| 3164 | } | 3164 | } |
| 3165 | 3165 | ||
| 3166 | static int journal_join(struct reiserfs_transaction_handle *th, | 3166 | static int journal_join(struct reiserfs_transaction_handle *th, |
| 3167 | struct super_block *p_s_sb, unsigned long nblocks) | 3167 | struct super_block *sb, unsigned long nblocks) |
| 3168 | { | 3168 | { |
| 3169 | struct reiserfs_transaction_handle *cur_th = current->journal_info; | 3169 | struct reiserfs_transaction_handle *cur_th = current->journal_info; |
| 3170 | 3170 | ||
| @@ -3173,11 +3173,11 @@ static int journal_join(struct reiserfs_transaction_handle *th, | |||
| 3173 | */ | 3173 | */ |
| 3174 | th->t_handle_save = cur_th; | 3174 | th->t_handle_save = cur_th; |
| 3175 | BUG_ON(cur_th && cur_th->t_refcount > 1); | 3175 | BUG_ON(cur_th && cur_th->t_refcount > 1); |
| 3176 | return do_journal_begin_r(th, p_s_sb, nblocks, JBEGIN_JOIN); | 3176 | return do_journal_begin_r(th, sb, nblocks, JBEGIN_JOIN); |
| 3177 | } | 3177 | } |
| 3178 | 3178 | ||
| 3179 | int journal_join_abort(struct reiserfs_transaction_handle *th, | 3179 | int journal_join_abort(struct reiserfs_transaction_handle *th, |
| 3180 | struct super_block *p_s_sb, unsigned long nblocks) | 3180 | struct super_block *sb, unsigned long nblocks) |
| 3181 | { | 3181 | { |
| 3182 | struct reiserfs_transaction_handle *cur_th = current->journal_info; | 3182 | struct reiserfs_transaction_handle *cur_th = current->journal_info; |
| 3183 | 3183 | ||
| @@ -3186,11 +3186,11 @@ int journal_join_abort(struct reiserfs_transaction_handle *th, | |||
| 3186 | */ | 3186 | */ |
| 3187 | th->t_handle_save = cur_th; | 3187 | th->t_handle_save = cur_th; |
| 3188 | BUG_ON(cur_th && cur_th->t_refcount > 1); | 3188 | BUG_ON(cur_th && cur_th->t_refcount > 1); |
| 3189 | return do_journal_begin_r(th, p_s_sb, nblocks, JBEGIN_ABORT); | 3189 | return do_journal_begin_r(th, sb, nblocks, JBEGIN_ABORT); |
| 3190 | } | 3190 | } |
| 3191 | 3191 | ||
| 3192 | int journal_begin(struct reiserfs_transaction_handle *th, | 3192 | int journal_begin(struct reiserfs_transaction_handle *th, |
| 3193 | struct super_block *p_s_sb, unsigned long nblocks) | 3193 | struct super_block *sb, unsigned long nblocks) |
| 3194 | { | 3194 | { |
| 3195 | struct reiserfs_transaction_handle *cur_th = current->journal_info; | 3195 | struct reiserfs_transaction_handle *cur_th = current->journal_info; |
| 3196 | int ret; | 3196 | int ret; |
| @@ -3198,12 +3198,12 @@ int journal_begin(struct reiserfs_transaction_handle *th, | |||
| 3198 | th->t_handle_save = NULL; | 3198 | th->t_handle_save = NULL; |
| 3199 | if (cur_th) { | 3199 | if (cur_th) { |
| 3200 | /* we are nesting into the current transaction */ | 3200 | /* we are nesting into the current transaction */ |
| 3201 | if (cur_th->t_super == p_s_sb) { | 3201 | if (cur_th->t_super == sb) { |
| 3202 | BUG_ON(!cur_th->t_refcount); | 3202 | BUG_ON(!cur_th->t_refcount); |
| 3203 | cur_th->t_refcount++; | 3203 | cur_th->t_refcount++; |
| 3204 | memcpy(th, cur_th, sizeof(*th)); | 3204 | memcpy(th, cur_th, sizeof(*th)); |
| 3205 | if (th->t_refcount <= 1) | 3205 | if (th->t_refcount <= 1) |
| 3206 | reiserfs_warning(p_s_sb, "reiserfs-2005", | 3206 | reiserfs_warning(sb, "reiserfs-2005", |
| 3207 | "BAD: refcount <= 1, but " | 3207 | "BAD: refcount <= 1, but " |
| 3208 | "journal_info != 0"); | 3208 | "journal_info != 0"); |
| 3209 | return 0; | 3209 | return 0; |
| @@ -3212,7 +3212,7 @@ int journal_begin(struct reiserfs_transaction_handle *th, | |||
| 3212 | ** save it and restore on journal_end. This should never | 3212 | ** save it and restore on journal_end. This should never |
| 3213 | ** really happen... | 3213 | ** really happen... |
| 3214 | */ | 3214 | */ |
| 3215 | reiserfs_warning(p_s_sb, "clm-2100", | 3215 | reiserfs_warning(sb, "clm-2100", |
| 3216 | "nesting info a different FS"); | 3216 | "nesting info a different FS"); |
| 3217 | th->t_handle_save = current->journal_info; | 3217 | th->t_handle_save = current->journal_info; |
| 3218 | current->journal_info = th; | 3218 | current->journal_info = th; |
| @@ -3220,7 +3220,7 @@ int journal_begin(struct reiserfs_transaction_handle *th, | |||
| 3220 | } else { | 3220 | } else { |
| 3221 | current->journal_info = th; | 3221 | current->journal_info = th; |
| 3222 | } | 3222 | } |
| 3223 | ret = do_journal_begin_r(th, p_s_sb, nblocks, JBEGIN_REG); | 3223 | ret = do_journal_begin_r(th, sb, nblocks, JBEGIN_REG); |
| 3224 | BUG_ON(current->journal_info != th); | 3224 | BUG_ON(current->journal_info != th); |
| 3225 | 3225 | ||
| 3226 | /* I guess this boils down to being the reciprocal of clm-2100 above. | 3226 | /* I guess this boils down to being the reciprocal of clm-2100 above. |
| @@ -3244,28 +3244,28 @@ int journal_begin(struct reiserfs_transaction_handle *th, | |||
| 3244 | ** if j_len, is bigger than j_len_alloc, it pushes j_len_alloc to 10 + j_len. | 3244 | ** if j_len, is bigger than j_len_alloc, it pushes j_len_alloc to 10 + j_len. |
| 3245 | */ | 3245 | */ |
| 3246 | int journal_mark_dirty(struct reiserfs_transaction_handle *th, | 3246 | int journal_mark_dirty(struct reiserfs_transaction_handle *th, |
| 3247 | struct super_block *p_s_sb, struct buffer_head *bh) | 3247 | struct super_block *sb, struct buffer_head *bh) |
| 3248 | { | 3248 | { |
| 3249 | struct reiserfs_journal *journal = SB_JOURNAL(p_s_sb); | 3249 | struct reiserfs_journal *journal = SB_JOURNAL(sb); |
| 3250 | struct reiserfs_journal_cnode *cn = NULL; | 3250 | struct reiserfs_journal_cnode *cn = NULL; |
| 3251 | int count_already_incd = 0; | 3251 | int count_already_incd = 0; |
| 3252 | int prepared = 0; | 3252 | int prepared = 0; |
| 3253 | BUG_ON(!th->t_trans_id); | 3253 | BUG_ON(!th->t_trans_id); |
| 3254 | 3254 | ||
| 3255 | PROC_INFO_INC(p_s_sb, journal.mark_dirty); | 3255 | PROC_INFO_INC(sb, journal.mark_dirty); |
| 3256 | if (th->t_trans_id != journal->j_trans_id) { | 3256 | if (th->t_trans_id != journal->j_trans_id) { |
| 3257 | reiserfs_panic(th->t_super, "journal-1577", | 3257 | reiserfs_panic(th->t_super, "journal-1577", |
| 3258 | "handle trans id %ld != current trans id %ld", | 3258 | "handle trans id %ld != current trans id %ld", |
| 3259 | th->t_trans_id, journal->j_trans_id); | 3259 | th->t_trans_id, journal->j_trans_id); |
| 3260 | } | 3260 | } |
| 3261 | 3261 | ||
| 3262 | p_s_sb->s_dirt = 1; | 3262 | sb->s_dirt = 1; |
| 3263 | 3263 | ||
| 3264 | prepared = test_clear_buffer_journal_prepared(bh); | 3264 | prepared = test_clear_buffer_journal_prepared(bh); |
| 3265 | clear_buffer_journal_restore_dirty(bh); | 3265 | clear_buffer_journal_restore_dirty(bh); |
| 3266 | /* already in this transaction, we are done */ | 3266 | /* already in this transaction, we are done */ |
| 3267 | if (buffer_journaled(bh)) { | 3267 | if (buffer_journaled(bh)) { |
| 3268 | PROC_INFO_INC(p_s_sb, journal.mark_dirty_already); | 3268 | PROC_INFO_INC(sb, journal.mark_dirty_already); |
| 3269 | return 0; | 3269 | return 0; |
| 3270 | } | 3270 | } |
| 3271 | 3271 | ||
| @@ -3274,7 +3274,7 @@ int journal_mark_dirty(struct reiserfs_transaction_handle *th, | |||
| 3274 | ** could get to disk too early. NOT GOOD. | 3274 | ** could get to disk too early. NOT GOOD. |
| 3275 | */ | 3275 | */ |
| 3276 | if (!prepared || buffer_dirty(bh)) { | 3276 | if (!prepared || buffer_dirty(bh)) { |
| 3277 | reiserfs_warning(p_s_sb, "journal-1777", | 3277 | reiserfs_warning(sb, "journal-1777", |
| 3278 | "buffer %llu bad state " | 3278 | "buffer %llu bad state " |
| 3279 | "%cPREPARED %cLOCKED %cDIRTY %cJDIRTY_WAIT", | 3279 | "%cPREPARED %cLOCKED %cDIRTY %cJDIRTY_WAIT", |
| 3280 | (unsigned long long)bh->b_blocknr, | 3280 | (unsigned long long)bh->b_blocknr, |
| @@ -3285,7 +3285,7 @@ int journal_mark_dirty(struct reiserfs_transaction_handle *th, | |||
| 3285 | } | 3285 | } |
| 3286 | 3286 | ||
| 3287 | if (atomic_read(&(journal->j_wcount)) <= 0) { | 3287 | if (atomic_read(&(journal->j_wcount)) <= 0) { |
| 3288 | reiserfs_warning(p_s_sb, "journal-1409", | 3288 | reiserfs_warning(sb, "journal-1409", |
| 3289 | "returning because j_wcount was %d", | 3289 | "returning because j_wcount was %d", |
| 3290 | atomic_read(&(journal->j_wcount))); | 3290 | atomic_read(&(journal->j_wcount))); |
| 3291 | return 1; | 3291 | return 1; |
| @@ -3301,7 +3301,7 @@ int journal_mark_dirty(struct reiserfs_transaction_handle *th, | |||
| 3301 | 3301 | ||
| 3302 | if (buffer_journal_dirty(bh)) { | 3302 | if (buffer_journal_dirty(bh)) { |
| 3303 | count_already_incd = 1; | 3303 | count_already_incd = 1; |
| 3304 | PROC_INFO_INC(p_s_sb, journal.mark_dirty_notjournal); | 3304 | PROC_INFO_INC(sb, journal.mark_dirty_notjournal); |
| 3305 | clear_buffer_journal_dirty(bh); | 3305 | clear_buffer_journal_dirty(bh); |
| 3306 | } | 3306 | } |
| 3307 | 3307 | ||
| @@ -3313,10 +3313,9 @@ int journal_mark_dirty(struct reiserfs_transaction_handle *th, | |||
| 3313 | 3313 | ||
| 3314 | /* now put this guy on the end */ | 3314 | /* now put this guy on the end */ |
| 3315 | if (!cn) { | 3315 | if (!cn) { |
| 3316 | cn = get_cnode(p_s_sb); | 3316 | cn = get_cnode(sb); |
| 3317 | if (!cn) { | 3317 | if (!cn) { |
| 3318 | reiserfs_panic(p_s_sb, "journal-4", | 3318 | reiserfs_panic(sb, "journal-4", "get_cnode failed!"); |
| 3319 | "get_cnode failed!"); | ||
| 3320 | } | 3319 | } |
| 3321 | 3320 | ||
| 3322 | if (th->t_blocks_logged == th->t_blocks_allocated) { | 3321 | if (th->t_blocks_logged == th->t_blocks_allocated) { |
| @@ -3328,7 +3327,7 @@ int journal_mark_dirty(struct reiserfs_transaction_handle *th, | |||
| 3328 | 3327 | ||
| 3329 | cn->bh = bh; | 3328 | cn->bh = bh; |
| 3330 | cn->blocknr = bh->b_blocknr; | 3329 | cn->blocknr = bh->b_blocknr; |
| 3331 | cn->sb = p_s_sb; | 3330 | cn->sb = sb; |
| 3332 | cn->jlist = NULL; | 3331 | cn->jlist = NULL; |
| 3333 | insert_journal_hash(journal->j_hash_table, cn); | 3332 | insert_journal_hash(journal->j_hash_table, cn); |
| 3334 | if (!count_already_incd) { | 3333 | if (!count_already_incd) { |
| @@ -3349,10 +3348,10 @@ int journal_mark_dirty(struct reiserfs_transaction_handle *th, | |||
| 3349 | } | 3348 | } |
| 3350 | 3349 | ||
| 3351 | int journal_end(struct reiserfs_transaction_handle *th, | 3350 | int journal_end(struct reiserfs_transaction_handle *th, |
| 3352 | struct super_block *p_s_sb, unsigned long nblocks) | 3351 | struct super_block *sb, unsigned long nblocks) |
| 3353 | { | 3352 | { |
| 3354 | if (!current->journal_info && th->t_refcount > 1) | 3353 | if (!current->journal_info && th->t_refcount > 1) |
| 3355 | reiserfs_warning(p_s_sb, "REISER-NESTING", | 3354 | reiserfs_warning(sb, "REISER-NESTING", |
| 3356 | "th NULL, refcount %d", th->t_refcount); | 3355 | "th NULL, refcount %d", th->t_refcount); |
| 3357 | 3356 | ||
| 3358 | if (!th->t_trans_id) { | 3357 | if (!th->t_trans_id) { |
| @@ -3376,7 +3375,7 @@ int journal_end(struct reiserfs_transaction_handle *th, | |||
| 3376 | } | 3375 | } |
| 3377 | return 0; | 3376 | return 0; |
| 3378 | } else { | 3377 | } else { |
| 3379 | return do_journal_end(th, p_s_sb, nblocks, 0); | 3378 | return do_journal_end(th, sb, nblocks, 0); |
| 3380 | } | 3379 | } |
| 3381 | } | 3380 | } |
| 3382 | 3381 | ||
| @@ -3387,15 +3386,15 @@ int journal_end(struct reiserfs_transaction_handle *th, | |||
| 3387 | ** | 3386 | ** |
| 3388 | ** returns 1 if it cleaned and relsed the buffer. 0 otherwise | 3387 | ** returns 1 if it cleaned and relsed the buffer. 0 otherwise |
| 3389 | */ | 3388 | */ |
| 3390 | static int remove_from_transaction(struct super_block *p_s_sb, | 3389 | static int remove_from_transaction(struct super_block *sb, |
| 3391 | b_blocknr_t blocknr, int already_cleaned) | 3390 | b_blocknr_t blocknr, int already_cleaned) |
| 3392 | { | 3391 | { |
| 3393 | struct buffer_head *bh; | 3392 | struct buffer_head *bh; |
| 3394 | struct reiserfs_journal_cnode *cn; | 3393 | struct reiserfs_journal_cnode *cn; |
| 3395 | struct reiserfs_journal *journal = SB_JOURNAL(p_s_sb); | 3394 | struct reiserfs_journal *journal = SB_JOURNAL(sb); |
| 3396 | int ret = 0; | 3395 | int ret = 0; |
| 3397 | 3396 | ||
| 3398 | cn = get_journal_hash_dev(p_s_sb, journal->j_hash_table, blocknr); | 3397 | cn = get_journal_hash_dev(sb, journal->j_hash_table, blocknr); |
| 3399 | if (!cn || !cn->bh) { | 3398 | if (!cn || !cn->bh) { |
| 3400 | return ret; | 3399 | return ret; |
| 3401 | } | 3400 | } |
| @@ -3413,7 +3412,7 @@ static int remove_from_transaction(struct super_block *p_s_sb, | |||
| 3413 | journal->j_last = cn->prev; | 3412 | journal->j_last = cn->prev; |
| 3414 | } | 3413 | } |
| 3415 | if (bh) | 3414 | if (bh) |
| 3416 | remove_journal_hash(p_s_sb, journal->j_hash_table, NULL, | 3415 | remove_journal_hash(sb, journal->j_hash_table, NULL, |
| 3417 | bh->b_blocknr, 0); | 3416 | bh->b_blocknr, 0); |
| 3418 | clear_buffer_journaled(bh); /* don't log this one */ | 3417 | clear_buffer_journaled(bh); /* don't log this one */ |
| 3419 | 3418 | ||
| @@ -3423,14 +3422,14 @@ static int remove_from_transaction(struct super_block *p_s_sb, | |||
| 3423 | clear_buffer_journal_test(bh); | 3422 | clear_buffer_journal_test(bh); |
| 3424 | put_bh(bh); | 3423 | put_bh(bh); |
| 3425 | if (atomic_read(&(bh->b_count)) < 0) { | 3424 | if (atomic_read(&(bh->b_count)) < 0) { |
| 3426 | reiserfs_warning(p_s_sb, "journal-1752", | 3425 | reiserfs_warning(sb, "journal-1752", |
| 3427 | "b_count < 0"); | 3426 | "b_count < 0"); |
| 3428 | } | 3427 | } |
| 3429 | ret = 1; | 3428 | ret = 1; |
| 3430 | } | 3429 | } |
| 3431 | journal->j_len--; | 3430 | journal->j_len--; |
| 3432 | journal->j_len_alloc--; | 3431 | journal->j_len_alloc--; |
| 3433 | free_cnode(p_s_sb, cn); | 3432 | free_cnode(sb, cn); |
| 3434 | return ret; | 3433 | return ret; |
| 3435 | } | 3434 | } |
| 3436 | 3435 | ||
| @@ -3481,19 +3480,19 @@ static int can_dirty(struct reiserfs_journal_cnode *cn) | |||
| 3481 | ** will wait until the current transaction is done/committed before returning | 3480 | ** will wait until the current transaction is done/committed before returning |
| 3482 | */ | 3481 | */ |
| 3483 | int journal_end_sync(struct reiserfs_transaction_handle *th, | 3482 | int journal_end_sync(struct reiserfs_transaction_handle *th, |
| 3484 | struct super_block *p_s_sb, unsigned long nblocks) | 3483 | struct super_block *sb, unsigned long nblocks) |
| 3485 | { | 3484 | { |
| 3486 | struct reiserfs_journal *journal = SB_JOURNAL(p_s_sb); | 3485 | struct reiserfs_journal *journal = SB_JOURNAL(sb); |
| 3487 | 3486 | ||
| 3488 | BUG_ON(!th->t_trans_id); | 3487 | BUG_ON(!th->t_trans_id); |
| 3489 | /* you can sync while nested, very, very bad */ | 3488 | /* you can sync while nested, very, very bad */ |
| 3490 | BUG_ON(th->t_refcount > 1); | 3489 | BUG_ON(th->t_refcount > 1); |
| 3491 | if (journal->j_len == 0) { | 3490 | if (journal->j_len == 0) { |
| 3492 | reiserfs_prepare_for_journal(p_s_sb, SB_BUFFER_WITH_SB(p_s_sb), | 3491 | reiserfs_prepare_for_journal(sb, SB_BUFFER_WITH_SB(sb), |
| 3493 | 1); | 3492 | 1); |
| 3494 | journal_mark_dirty(th, p_s_sb, SB_BUFFER_WITH_SB(p_s_sb)); | 3493 | journal_mark_dirty(th, sb, SB_BUFFER_WITH_SB(sb)); |
| 3495 | } | 3494 | } |
| 3496 | return do_journal_end(th, p_s_sb, nblocks, COMMIT_NOW | WAIT); | 3495 | return do_journal_end(th, sb, nblocks, COMMIT_NOW | WAIT); |
| 3497 | } | 3496 | } |
| 3498 | 3497 | ||
| 3499 | /* | 3498 | /* |
| @@ -3503,7 +3502,7 @@ static void flush_async_commits(struct work_struct *work) | |||
| 3503 | { | 3502 | { |
| 3504 | struct reiserfs_journal *journal = | 3503 | struct reiserfs_journal *journal = |
| 3505 | container_of(work, struct reiserfs_journal, j_work.work); | 3504 | container_of(work, struct reiserfs_journal, j_work.work); |
| 3506 | struct super_block *p_s_sb = journal->j_work_sb; | 3505 | struct super_block *sb = journal->j_work_sb; |
| 3507 | struct reiserfs_journal_list *jl; | 3506 | struct reiserfs_journal_list *jl; |
| 3508 | struct list_head *entry; | 3507 | struct list_head *entry; |
| 3509 | 3508 | ||
| @@ -3512,7 +3511,7 @@ static void flush_async_commits(struct work_struct *work) | |||
| 3512 | /* last entry is the youngest, commit it and you get everything */ | 3511 | /* last entry is the youngest, commit it and you get everything */ |
| 3513 | entry = journal->j_journal_list.prev; | 3512 | entry = journal->j_journal_list.prev; |
| 3514 | jl = JOURNAL_LIST_ENTRY(entry); | 3513 | jl = JOURNAL_LIST_ENTRY(entry); |
| 3515 | flush_commit_list(p_s_sb, jl, 1); | 3514 | flush_commit_list(sb, jl, 1); |
| 3516 | } | 3515 | } |
| 3517 | unlock_kernel(); | 3516 | unlock_kernel(); |
| 3518 | } | 3517 | } |
| @@ -3521,11 +3520,11 @@ static void flush_async_commits(struct work_struct *work) | |||
| 3521 | ** flushes any old transactions to disk | 3520 | ** flushes any old transactions to disk |
| 3522 | ** ends the current transaction if it is too old | 3521 | ** ends the current transaction if it is too old |
| 3523 | */ | 3522 | */ |
| 3524 | int reiserfs_flush_old_commits(struct super_block *p_s_sb) | 3523 | int reiserfs_flush_old_commits(struct super_block *sb) |
| 3525 | { | 3524 | { |
| 3526 | time_t now; | 3525 | time_t now; |
| 3527 | struct reiserfs_transaction_handle th; | 3526 | struct reiserfs_transaction_handle th; |
| 3528 | struct reiserfs_journal *journal = SB_JOURNAL(p_s_sb); | 3527 | struct reiserfs_journal *journal = SB_JOURNAL(sb); |
| 3529 | 3528 | ||
| 3530 | now = get_seconds(); | 3529 | now = get_seconds(); |
| 3531 | /* safety check so we don't flush while we are replaying the log during | 3530 | /* safety check so we don't flush while we are replaying the log during |
| @@ -3542,20 +3541,20 @@ int reiserfs_flush_old_commits(struct super_block *p_s_sb) | |||
| 3542 | journal->j_trans_start_time > 0 && | 3541 | journal->j_trans_start_time > 0 && |
| 3543 | journal->j_len > 0 && | 3542 | journal->j_len > 0 && |
| 3544 | (now - journal->j_trans_start_time) > journal->j_max_trans_age) { | 3543 | (now - journal->j_trans_start_time) > journal->j_max_trans_age) { |
| 3545 | if (!journal_join(&th, p_s_sb, 1)) { | 3544 | if (!journal_join(&th, sb, 1)) { |
| 3546 | reiserfs_prepare_for_journal(p_s_sb, | 3545 | reiserfs_prepare_for_journal(sb, |
| 3547 | SB_BUFFER_WITH_SB(p_s_sb), | 3546 | SB_BUFFER_WITH_SB(sb), |
| 3548 | 1); | 3547 | 1); |
| 3549 | journal_mark_dirty(&th, p_s_sb, | 3548 | journal_mark_dirty(&th, sb, |
| 3550 | SB_BUFFER_WITH_SB(p_s_sb)); | 3549 | SB_BUFFER_WITH_SB(sb)); |
| 3551 | 3550 | ||
| 3552 | /* we're only being called from kreiserfsd, it makes no sense to do | 3551 | /* we're only being called from kreiserfsd, it makes no sense to do |
| 3553 | ** an async commit so that kreiserfsd can do it later | 3552 | ** an async commit so that kreiserfsd can do it later |
| 3554 | */ | 3553 | */ |
| 3555 | do_journal_end(&th, p_s_sb, 1, COMMIT_NOW | WAIT); | 3554 | do_journal_end(&th, sb, 1, COMMIT_NOW | WAIT); |
| 3556 | } | 3555 | } |
| 3557 | } | 3556 | } |
| 3558 | return p_s_sb->s_dirt; | 3557 | return sb->s_dirt; |
| 3559 | } | 3558 | } |
| 3560 | 3559 | ||
| 3561 | /* | 3560 | /* |
| @@ -3570,7 +3569,7 @@ int reiserfs_flush_old_commits(struct super_block *p_s_sb) | |||
| 3570 | ** Note, we can't allow the journal_end to proceed while there are still writers in the log. | 3569 | ** Note, we can't allow the journal_end to proceed while there are still writers in the log. |
| 3571 | */ | 3570 | */ |
| 3572 | static int check_journal_end(struct reiserfs_transaction_handle *th, | 3571 | static int check_journal_end(struct reiserfs_transaction_handle *th, |
| 3573 | struct super_block *p_s_sb, unsigned long nblocks, | 3572 | struct super_block *sb, unsigned long nblocks, |
| 3574 | int flags) | 3573 | int flags) |
| 3575 | { | 3574 | { |
| 3576 | 3575 | ||
| @@ -3579,7 +3578,7 @@ static int check_journal_end(struct reiserfs_transaction_handle *th, | |||
| 3579 | int commit_now = flags & COMMIT_NOW; | 3578 | int commit_now = flags & COMMIT_NOW; |
| 3580 | int wait_on_commit = flags & WAIT; | 3579 | int wait_on_commit = flags & WAIT; |
| 3581 | struct reiserfs_journal_list *jl; | 3580 | struct reiserfs_journal_list *jl; |
| 3582 | struct reiserfs_journal *journal = SB_JOURNAL(p_s_sb); | 3581 | struct reiserfs_journal *journal = SB_JOURNAL(sb); |
| 3583 | 3582 | ||
| 3584 | BUG_ON(!th->t_trans_id); | 3583 | BUG_ON(!th->t_trans_id); |
| 3585 | 3584 | ||
| @@ -3618,31 +3617,31 @@ static int check_journal_end(struct reiserfs_transaction_handle *th, | |||
| 3618 | if (flush) { | 3617 | if (flush) { |
| 3619 | journal->j_next_full_flush = 1; | 3618 | journal->j_next_full_flush = 1; |
| 3620 | } | 3619 | } |
| 3621 | unlock_journal(p_s_sb); | 3620 | unlock_journal(sb); |
| 3622 | 3621 | ||
| 3623 | /* sleep while the current transaction is still j_jlocked */ | 3622 | /* sleep while the current transaction is still j_jlocked */ |
| 3624 | while (journal->j_trans_id == trans_id) { | 3623 | while (journal->j_trans_id == trans_id) { |
| 3625 | if (atomic_read(&journal->j_jlock)) { | 3624 | if (atomic_read(&journal->j_jlock)) { |
| 3626 | queue_log_writer(p_s_sb); | 3625 | queue_log_writer(sb); |
| 3627 | } else { | 3626 | } else { |
| 3628 | lock_journal(p_s_sb); | 3627 | lock_journal(sb); |
| 3629 | if (journal->j_trans_id == trans_id) { | 3628 | if (journal->j_trans_id == trans_id) { |
| 3630 | atomic_set(&(journal->j_jlock), | 3629 | atomic_set(&(journal->j_jlock), |
| 3631 | 1); | 3630 | 1); |
| 3632 | } | 3631 | } |
| 3633 | unlock_journal(p_s_sb); | 3632 | unlock_journal(sb); |
| 3634 | } | 3633 | } |
| 3635 | } | 3634 | } |
| 3636 | BUG_ON(journal->j_trans_id == trans_id); | 3635 | BUG_ON(journal->j_trans_id == trans_id); |
| 3637 | 3636 | ||
| 3638 | if (commit_now | 3637 | if (commit_now |
| 3639 | && journal_list_still_alive(p_s_sb, trans_id) | 3638 | && journal_list_still_alive(sb, trans_id) |
| 3640 | && wait_on_commit) { | 3639 | && wait_on_commit) { |
| 3641 | flush_commit_list(p_s_sb, jl, 1); | 3640 | flush_commit_list(sb, jl, 1); |
| 3642 | } | 3641 | } |
| 3643 | return 0; | 3642 | return 0; |
| 3644 | } | 3643 | } |
| 3645 | unlock_journal(p_s_sb); | 3644 | unlock_journal(sb); |
| 3646 | return 0; | 3645 | return 0; |
| 3647 | } | 3646 | } |
| 3648 | 3647 | ||
| @@ -3659,12 +3658,12 @@ static int check_journal_end(struct reiserfs_transaction_handle *th, | |||
| 3659 | && journal->j_len_alloc < journal->j_max_batch | 3658 | && journal->j_len_alloc < journal->j_max_batch |
| 3660 | && journal->j_cnode_free > (journal->j_trans_max * 3)) { | 3659 | && journal->j_cnode_free > (journal->j_trans_max * 3)) { |
| 3661 | journal->j_bcount++; | 3660 | journal->j_bcount++; |
| 3662 | unlock_journal(p_s_sb); | 3661 | unlock_journal(sb); |
| 3663 | return 0; | 3662 | return 0; |
| 3664 | } | 3663 | } |
| 3665 | 3664 | ||
| 3666 | if (journal->j_start > SB_ONDISK_JOURNAL_SIZE(p_s_sb)) { | 3665 | if (journal->j_start > SB_ONDISK_JOURNAL_SIZE(sb)) { |
| 3667 | reiserfs_panic(p_s_sb, "journal-003", | 3666 | reiserfs_panic(sb, "journal-003", |
| 3668 | "j_start (%ld) is too high", | 3667 | "j_start (%ld) is too high", |
| 3669 | journal->j_start); | 3668 | journal->j_start); |
| 3670 | } | 3669 | } |
| @@ -3686,16 +3685,16 @@ static int check_journal_end(struct reiserfs_transaction_handle *th, | |||
| 3686 | ** Then remove it from the current transaction, decrementing any counters and filing it on the clean list. | 3685 | ** Then remove it from the current transaction, decrementing any counters and filing it on the clean list. |
| 3687 | */ | 3686 | */ |
| 3688 | int journal_mark_freed(struct reiserfs_transaction_handle *th, | 3687 | int journal_mark_freed(struct reiserfs_transaction_handle *th, |
| 3689 | struct super_block *p_s_sb, b_blocknr_t blocknr) | 3688 | struct super_block *sb, b_blocknr_t blocknr) |
| 3690 | { | 3689 | { |
| 3691 | struct reiserfs_journal *journal = SB_JOURNAL(p_s_sb); | 3690 | struct reiserfs_journal *journal = SB_JOURNAL(sb); |
| 3692 | struct reiserfs_journal_cnode *cn = NULL; | 3691 | struct reiserfs_journal_cnode *cn = NULL; |
| 3693 | struct buffer_head *bh = NULL; | 3692 | struct buffer_head *bh = NULL; |
| 3694 | struct reiserfs_list_bitmap *jb = NULL; | 3693 | struct reiserfs_list_bitmap *jb = NULL; |
| 3695 | int cleaned = 0; | 3694 | int cleaned = 0; |
| 3696 | BUG_ON(!th->t_trans_id); | 3695 | BUG_ON(!th->t_trans_id); |
| 3697 | 3696 | ||
| 3698 | cn = get_journal_hash_dev(p_s_sb, journal->j_hash_table, blocknr); | 3697 | cn = get_journal_hash_dev(sb, journal->j_hash_table, blocknr); |
| 3699 | if (cn && cn->bh) { | 3698 | if (cn && cn->bh) { |
| 3700 | bh = cn->bh; | 3699 | bh = cn->bh; |
| 3701 | get_bh(bh); | 3700 | get_bh(bh); |
| @@ -3705,15 +3704,15 @@ int journal_mark_freed(struct reiserfs_transaction_handle *th, | |||
| 3705 | clear_buffer_journal_new(bh); | 3704 | clear_buffer_journal_new(bh); |
| 3706 | clear_prepared_bits(bh); | 3705 | clear_prepared_bits(bh); |
| 3707 | reiserfs_clean_and_file_buffer(bh); | 3706 | reiserfs_clean_and_file_buffer(bh); |
| 3708 | cleaned = remove_from_transaction(p_s_sb, blocknr, cleaned); | 3707 | cleaned = remove_from_transaction(sb, blocknr, cleaned); |
| 3709 | } else { | 3708 | } else { |
| 3710 | /* set the bit for this block in the journal bitmap for this transaction */ | 3709 | /* set the bit for this block in the journal bitmap for this transaction */ |
| 3711 | jb = journal->j_current_jl->j_list_bitmap; | 3710 | jb = journal->j_current_jl->j_list_bitmap; |
| 3712 | if (!jb) { | 3711 | if (!jb) { |
| 3713 | reiserfs_panic(p_s_sb, "journal-1702", | 3712 | reiserfs_panic(sb, "journal-1702", |
| 3714 | "journal_list_bitmap is NULL"); | 3713 | "journal_list_bitmap is NULL"); |
| 3715 | } | 3714 | } |
| 3716 | set_bit_in_list_bitmap(p_s_sb, blocknr, jb); | 3715 | set_bit_in_list_bitmap(sb, blocknr, jb); |
| 3717 | 3716 | ||
| 3718 | /* Note, the entire while loop is not allowed to schedule. */ | 3717 | /* Note, the entire while loop is not allowed to schedule. */ |
| 3719 | 3718 | ||
| @@ -3721,13 +3720,13 @@ int journal_mark_freed(struct reiserfs_transaction_handle *th, | |||
| 3721 | clear_prepared_bits(bh); | 3720 | clear_prepared_bits(bh); |
| 3722 | reiserfs_clean_and_file_buffer(bh); | 3721 | reiserfs_clean_and_file_buffer(bh); |
| 3723 | } | 3722 | } |
| 3724 | cleaned = remove_from_transaction(p_s_sb, blocknr, cleaned); | 3723 | cleaned = remove_from_transaction(sb, blocknr, cleaned); |
| 3725 | 3724 | ||
| 3726 | /* find all older transactions with this block, make sure they don't try to write it out */ | 3725 | /* find all older transactions with this block, make sure they don't try to write it out */ |
| 3727 | cn = get_journal_hash_dev(p_s_sb, journal->j_list_hash_table, | 3726 | cn = get_journal_hash_dev(sb, journal->j_list_hash_table, |
| 3728 | blocknr); | 3727 | blocknr); |
| 3729 | while (cn) { | 3728 | while (cn) { |
| 3730 | if (p_s_sb == cn->sb && blocknr == cn->blocknr) { | 3729 | if (sb == cn->sb && blocknr == cn->blocknr) { |
| 3731 | set_bit(BLOCK_FREED, &cn->state); | 3730 | set_bit(BLOCK_FREED, &cn->state); |
| 3732 | if (cn->bh) { | 3731 | if (cn->bh) { |
| 3733 | if (!cleaned) { | 3732 | if (!cleaned) { |
| @@ -3743,7 +3742,7 @@ int journal_mark_freed(struct reiserfs_transaction_handle *th, | |||
| 3743 | put_bh(cn->bh); | 3742 | put_bh(cn->bh); |
| 3744 | if (atomic_read | 3743 | if (atomic_read |
| 3745 | (&(cn->bh->b_count)) < 0) { | 3744 | (&(cn->bh->b_count)) < 0) { |
| 3746 | reiserfs_warning(p_s_sb, | 3745 | reiserfs_warning(sb, |
| 3747 | "journal-2138", | 3746 | "journal-2138", |
| 3748 | "cn->bh->b_count < 0"); | 3747 | "cn->bh->b_count < 0"); |
| 3749 | } | 3748 | } |
| @@ -3850,18 +3849,18 @@ int reiserfs_commit_for_inode(struct inode *inode) | |||
| 3850 | return __commit_trans_jl(inode, id, jl); | 3849 | return __commit_trans_jl(inode, id, jl); |
| 3851 | } | 3850 | } |
| 3852 | 3851 | ||
| 3853 | void reiserfs_restore_prepared_buffer(struct super_block *p_s_sb, | 3852 | void reiserfs_restore_prepared_buffer(struct super_block *sb, |
| 3854 | struct buffer_head *bh) | 3853 | struct buffer_head *bh) |
| 3855 | { | 3854 | { |
| 3856 | struct reiserfs_journal *journal = SB_JOURNAL(p_s_sb); | 3855 | struct reiserfs_journal *journal = SB_JOURNAL(sb); |
| 3857 | PROC_INFO_INC(p_s_sb, journal.restore_prepared); | 3856 | PROC_INFO_INC(sb, journal.restore_prepared); |
| 3858 | if (!bh) { | 3857 | if (!bh) { |
| 3859 | return; | 3858 | return; |
| 3860 | } | 3859 | } |
| 3861 | if (test_clear_buffer_journal_restore_dirty(bh) && | 3860 | if (test_clear_buffer_journal_restore_dirty(bh) && |
| 3862 | buffer_journal_dirty(bh)) { | 3861 | buffer_journal_dirty(bh)) { |
| 3863 | struct reiserfs_journal_cnode *cn; | 3862 | struct reiserfs_journal_cnode *cn; |
| 3864 | cn = get_journal_hash_dev(p_s_sb, | 3863 | cn = get_journal_hash_dev(sb, |
| 3865 | journal->j_list_hash_table, | 3864 | journal->j_list_hash_table, |
| 3866 | bh->b_blocknr); | 3865 | bh->b_blocknr); |
| 3867 | if (cn && can_dirty(cn)) { | 3866 | if (cn && can_dirty(cn)) { |
| @@ -3880,10 +3879,10 @@ extern struct tree_balance *cur_tb; | |||
| 3880 | ** wait on it. | 3879 | ** wait on it. |
| 3881 | ** | 3880 | ** |
| 3882 | */ | 3881 | */ |
| 3883 | int reiserfs_prepare_for_journal(struct super_block *p_s_sb, | 3882 | int reiserfs_prepare_for_journal(struct super_block *sb, |
| 3884 | struct buffer_head *bh, int wait) | 3883 | struct buffer_head *bh, int wait) |
| 3885 | { | 3884 | { |
| 3886 | PROC_INFO_INC(p_s_sb, journal.prepare); | 3885 | PROC_INFO_INC(sb, journal.prepare); |
| 3887 | 3886 | ||
| 3888 | if (!trylock_buffer(bh)) { | 3887 | if (!trylock_buffer(bh)) { |
| 3889 | if (!wait) | 3888 | if (!wait) |
| @@ -3931,10 +3930,10 @@ static void flush_old_journal_lists(struct super_block *s) | |||
| 3931 | ** journal lists, etc just won't happen. | 3930 | ** journal lists, etc just won't happen. |
| 3932 | */ | 3931 | */ |
| 3933 | static int do_journal_end(struct reiserfs_transaction_handle *th, | 3932 | static int do_journal_end(struct reiserfs_transaction_handle *th, |
| 3934 | struct super_block *p_s_sb, unsigned long nblocks, | 3933 | struct super_block *sb, unsigned long nblocks, |
| 3935 | int flags) | 3934 | int flags) |
| 3936 | { | 3935 | { |
| 3937 | struct reiserfs_journal *journal = SB_JOURNAL(p_s_sb); | 3936 | struct reiserfs_journal *journal = SB_JOURNAL(sb); |
| 3938 | struct reiserfs_journal_cnode *cn, *next, *jl_cn; | 3937 | struct reiserfs_journal_cnode *cn, *next, *jl_cn; |
| 3939 | struct reiserfs_journal_cnode *last_cn = NULL; | 3938 | struct reiserfs_journal_cnode *last_cn = NULL; |
| 3940 | struct reiserfs_journal_desc *desc; | 3939 | struct reiserfs_journal_desc *desc; |
| @@ -3964,14 +3963,14 @@ static int do_journal_end(struct reiserfs_transaction_handle *th, | |||
| 3964 | 3963 | ||
| 3965 | put_fs_excl(); | 3964 | put_fs_excl(); |
| 3966 | current->journal_info = th->t_handle_save; | 3965 | current->journal_info = th->t_handle_save; |
| 3967 | reiserfs_check_lock_depth(p_s_sb, "journal end"); | 3966 | reiserfs_check_lock_depth(sb, "journal end"); |
| 3968 | if (journal->j_len == 0) { | 3967 | if (journal->j_len == 0) { |
| 3969 | reiserfs_prepare_for_journal(p_s_sb, SB_BUFFER_WITH_SB(p_s_sb), | 3968 | reiserfs_prepare_for_journal(sb, SB_BUFFER_WITH_SB(sb), |
| 3970 | 1); | 3969 | 1); |
| 3971 | journal_mark_dirty(th, p_s_sb, SB_BUFFER_WITH_SB(p_s_sb)); | 3970 | journal_mark_dirty(th, sb, SB_BUFFER_WITH_SB(sb)); |
| 3972 | } | 3971 | } |
| 3973 | 3972 | ||
| 3974 | lock_journal(p_s_sb); | 3973 | lock_journal(sb); |
| 3975 | if (journal->j_next_full_flush) { | 3974 | if (journal->j_next_full_flush) { |
| 3976 | flags |= FLUSH_ALL; | 3975 | flags |= FLUSH_ALL; |
| 3977 | flush = 1; | 3976 | flush = 1; |
| @@ -3984,10 +3983,10 @@ static int do_journal_end(struct reiserfs_transaction_handle *th, | |||
| 3984 | /* check_journal_end locks the journal, and unlocks if it does not return 1 | 3983 | /* check_journal_end locks the journal, and unlocks if it does not return 1 |
| 3985 | ** it tells us if we should continue with the journal_end, or just return | 3984 | ** it tells us if we should continue with the journal_end, or just return |
| 3986 | */ | 3985 | */ |
| 3987 | if (!check_journal_end(th, p_s_sb, nblocks, flags)) { | 3986 | if (!check_journal_end(th, sb, nblocks, flags)) { |
| 3988 | p_s_sb->s_dirt = 1; | 3987 | sb->s_dirt = 1; |
| 3989 | wake_queued_writers(p_s_sb); | 3988 | wake_queued_writers(sb); |
| 3990 | reiserfs_async_progress_wait(p_s_sb); | 3989 | reiserfs_async_progress_wait(sb); |
| 3991 | goto out; | 3990 | goto out; |
| 3992 | } | 3991 | } |
| 3993 | 3992 | ||
| @@ -4016,8 +4015,8 @@ static int do_journal_end(struct reiserfs_transaction_handle *th, | |||
| 4016 | 4015 | ||
| 4017 | /* setup description block */ | 4016 | /* setup description block */ |
| 4018 | d_bh = | 4017 | d_bh = |
| 4019 | journal_getblk(p_s_sb, | 4018 | journal_getblk(sb, |
| 4020 | SB_ONDISK_JOURNAL_1st_BLOCK(p_s_sb) + | 4019 | SB_ONDISK_JOURNAL_1st_BLOCK(sb) + |
| 4021 | journal->j_start); | 4020 | journal->j_start); |
| 4022 | set_buffer_uptodate(d_bh); | 4021 | set_buffer_uptodate(d_bh); |
| 4023 | desc = (struct reiserfs_journal_desc *)(d_bh)->b_data; | 4022 | desc = (struct reiserfs_journal_desc *)(d_bh)->b_data; |
| @@ -4026,9 +4025,9 @@ static int do_journal_end(struct reiserfs_transaction_handle *th, | |||
| 4026 | set_desc_trans_id(desc, journal->j_trans_id); | 4025 | set_desc_trans_id(desc, journal->j_trans_id); |
| 4027 | 4026 | ||
| 4028 | /* setup commit block. Don't write (keep it clean too) this one until after everyone else is written */ | 4027 | /* setup commit block. Don't write (keep it clean too) this one until after everyone else is written */ |
| 4029 | c_bh = journal_getblk(p_s_sb, SB_ONDISK_JOURNAL_1st_BLOCK(p_s_sb) + | 4028 | c_bh = journal_getblk(sb, SB_ONDISK_JOURNAL_1st_BLOCK(sb) + |
| 4030 | ((journal->j_start + journal->j_len + | 4029 | ((journal->j_start + journal->j_len + |
| 4031 | 1) % SB_ONDISK_JOURNAL_SIZE(p_s_sb))); | 4030 | 1) % SB_ONDISK_JOURNAL_SIZE(sb))); |
| 4032 | commit = (struct reiserfs_journal_commit *)c_bh->b_data; | 4031 | commit = (struct reiserfs_journal_commit *)c_bh->b_data; |
| 4033 | memset(c_bh->b_data, 0, c_bh->b_size); | 4032 | memset(c_bh->b_data, 0, c_bh->b_size); |
| 4034 | set_commit_trans_id(commit, journal->j_trans_id); | 4033 | set_commit_trans_id(commit, journal->j_trans_id); |
| @@ -4061,12 +4060,12 @@ static int do_journal_end(struct reiserfs_transaction_handle *th, | |||
| 4061 | ** for each real block, add it to the journal list hash, | 4060 | ** for each real block, add it to the journal list hash, |
| 4062 | ** copy into real block index array in the commit or desc block | 4061 | ** copy into real block index array in the commit or desc block |
| 4063 | */ | 4062 | */ |
| 4064 | trans_half = journal_trans_half(p_s_sb->s_blocksize); | 4063 | trans_half = journal_trans_half(sb->s_blocksize); |
| 4065 | for (i = 0, cn = journal->j_first; cn; cn = cn->next, i++) { | 4064 | for (i = 0, cn = journal->j_first; cn; cn = cn->next, i++) { |
| 4066 | if (buffer_journaled(cn->bh)) { | 4065 | if (buffer_journaled(cn->bh)) { |
| 4067 | jl_cn = get_cnode(p_s_sb); | 4066 | jl_cn = get_cnode(sb); |
| 4068 | if (!jl_cn) { | 4067 | if (!jl_cn) { |
| 4069 | reiserfs_panic(p_s_sb, "journal-1676", | 4068 | reiserfs_panic(sb, "journal-1676", |
| 4070 | "get_cnode returned NULL"); | 4069 | "get_cnode returned NULL"); |
| 4071 | } | 4070 | } |
| 4072 | if (i == 0) { | 4071 | if (i == 0) { |
| @@ -4082,15 +4081,15 @@ static int do_journal_end(struct reiserfs_transaction_handle *th, | |||
| 4082 | of journal or reserved area */ | 4081 | of journal or reserved area */ |
| 4083 | 4082 | ||
| 4084 | if (is_block_in_log_or_reserved_area | 4083 | if (is_block_in_log_or_reserved_area |
| 4085 | (p_s_sb, cn->bh->b_blocknr)) { | 4084 | (sb, cn->bh->b_blocknr)) { |
| 4086 | reiserfs_panic(p_s_sb, "journal-2332", | 4085 | reiserfs_panic(sb, "journal-2332", |
| 4087 | "Trying to log block %lu, " | 4086 | "Trying to log block %lu, " |
| 4088 | "which is a log block", | 4087 | "which is a log block", |
| 4089 | cn->bh->b_blocknr); | 4088 | cn->bh->b_blocknr); |
| 4090 | } | 4089 | } |
| 4091 | jl_cn->blocknr = cn->bh->b_blocknr; | 4090 | jl_cn->blocknr = cn->bh->b_blocknr; |
| 4092 | jl_cn->state = 0; | 4091 | jl_cn->state = 0; |
| 4093 | jl_cn->sb = p_s_sb; | 4092 | jl_cn->sb = sb; |
| 4094 | jl_cn->bh = cn->bh; | 4093 | jl_cn->bh = cn->bh; |
| 4095 | jl_cn->jlist = jl; | 4094 | jl_cn->jlist = jl; |
| 4096 | insert_journal_hash(journal->j_list_hash_table, jl_cn); | 4095 | insert_journal_hash(journal->j_list_hash_table, jl_cn); |
| @@ -4131,11 +4130,11 @@ static int do_journal_end(struct reiserfs_transaction_handle *th, | |||
| 4131 | char *addr; | 4130 | char *addr; |
| 4132 | struct page *page; | 4131 | struct page *page; |
| 4133 | tmp_bh = | 4132 | tmp_bh = |
| 4134 | journal_getblk(p_s_sb, | 4133 | journal_getblk(sb, |
| 4135 | SB_ONDISK_JOURNAL_1st_BLOCK(p_s_sb) + | 4134 | SB_ONDISK_JOURNAL_1st_BLOCK(sb) + |
| 4136 | ((cur_write_start + | 4135 | ((cur_write_start + |
| 4137 | jindex) % | 4136 | jindex) % |
| 4138 | SB_ONDISK_JOURNAL_SIZE(p_s_sb))); | 4137 | SB_ONDISK_JOURNAL_SIZE(sb))); |
| 4139 | set_buffer_uptodate(tmp_bh); | 4138 | set_buffer_uptodate(tmp_bh); |
| 4140 | page = cn->bh->b_page; | 4139 | page = cn->bh->b_page; |
| 4141 | addr = kmap(page); | 4140 | addr = kmap(page); |
| @@ -4149,13 +4148,13 @@ static int do_journal_end(struct reiserfs_transaction_handle *th, | |||
| 4149 | clear_buffer_journaled(cn->bh); | 4148 | clear_buffer_journaled(cn->bh); |
| 4150 | } else { | 4149 | } else { |
| 4151 | /* JDirty cleared sometime during transaction. don't log this one */ | 4150 | /* JDirty cleared sometime during transaction. don't log this one */ |
| 4152 | reiserfs_warning(p_s_sb, "journal-2048", | 4151 | reiserfs_warning(sb, "journal-2048", |
| 4153 | "BAD, buffer in journal hash, " | 4152 | "BAD, buffer in journal hash, " |
| 4154 | "but not JDirty!"); | 4153 | "but not JDirty!"); |
| 4155 | brelse(cn->bh); | 4154 | brelse(cn->bh); |
| 4156 | } | 4155 | } |
| 4157 | next = cn->next; | 4156 | next = cn->next; |
| 4158 | free_cnode(p_s_sb, cn); | 4157 | free_cnode(sb, cn); |
| 4159 | cn = next; | 4158 | cn = next; |
| 4160 | cond_resched(); | 4159 | cond_resched(); |
| 4161 | } | 4160 | } |
| @@ -4165,7 +4164,7 @@ static int do_journal_end(struct reiserfs_transaction_handle *th, | |||
| 4165 | ** so we dirty/relse c_bh in flush_commit_list, with commit_left <= 1. | 4164 | ** so we dirty/relse c_bh in flush_commit_list, with commit_left <= 1. |
| 4166 | */ | 4165 | */ |
| 4167 | 4166 | ||
| 4168 | journal->j_current_jl = alloc_journal_list(p_s_sb); | 4167 | journal->j_current_jl = alloc_journal_list(sb); |
| 4169 | 4168 | ||
| 4170 | /* now it is safe to insert this transaction on the main list */ | 4169 | /* now it is safe to insert this transaction on the main list */ |
| 4171 | list_add_tail(&jl->j_list, &journal->j_journal_list); | 4170 | list_add_tail(&jl->j_list, &journal->j_journal_list); |
| @@ -4176,7 +4175,7 @@ static int do_journal_end(struct reiserfs_transaction_handle *th, | |||
| 4176 | old_start = journal->j_start; | 4175 | old_start = journal->j_start; |
| 4177 | journal->j_start = | 4176 | journal->j_start = |
| 4178 | (journal->j_start + journal->j_len + | 4177 | (journal->j_start + journal->j_len + |
| 4179 | 2) % SB_ONDISK_JOURNAL_SIZE(p_s_sb); | 4178 | 2) % SB_ONDISK_JOURNAL_SIZE(sb); |
| 4180 | atomic_set(&(journal->j_wcount), 0); | 4179 | atomic_set(&(journal->j_wcount), 0); |
| 4181 | journal->j_bcount = 0; | 4180 | journal->j_bcount = 0; |
| 4182 | journal->j_last = NULL; | 4181 | journal->j_last = NULL; |
| @@ -4191,7 +4190,7 @@ static int do_journal_end(struct reiserfs_transaction_handle *th, | |||
| 4191 | journal->j_len_alloc = 0; | 4190 | journal->j_len_alloc = 0; |
| 4192 | journal->j_next_full_flush = 0; | 4191 | journal->j_next_full_flush = 0; |
| 4193 | journal->j_next_async_flush = 0; | 4192 | journal->j_next_async_flush = 0; |
| 4194 | init_journal_hash(p_s_sb); | 4193 | init_journal_hash(sb); |
| 4195 | 4194 | ||
| 4196 | // make sure reiserfs_add_jh sees the new current_jl before we | 4195 | // make sure reiserfs_add_jh sees the new current_jl before we |
| 4197 | // write out the tails | 4196 | // write out the tails |
| @@ -4220,8 +4219,8 @@ static int do_journal_end(struct reiserfs_transaction_handle *th, | |||
| 4220 | ** queue don't wait for this proc to flush journal lists and such. | 4219 | ** queue don't wait for this proc to flush journal lists and such. |
| 4221 | */ | 4220 | */ |
| 4222 | if (flush) { | 4221 | if (flush) { |
| 4223 | flush_commit_list(p_s_sb, jl, 1); | 4222 | flush_commit_list(sb, jl, 1); |
| 4224 | flush_journal_list(p_s_sb, jl, 1); | 4223 | flush_journal_list(sb, jl, 1); |
| 4225 | } else if (!(jl->j_state & LIST_COMMIT_PENDING)) | 4224 | } else if (!(jl->j_state & LIST_COMMIT_PENDING)) |
| 4226 | queue_delayed_work(commit_wq, &journal->j_work, HZ / 10); | 4225 | queue_delayed_work(commit_wq, &journal->j_work, HZ / 10); |
| 4227 | 4226 | ||
| @@ -4235,11 +4234,11 @@ static int do_journal_end(struct reiserfs_transaction_handle *th, | |||
| 4235 | if (journal->j_start <= temp_jl->j_start) { | 4234 | if (journal->j_start <= temp_jl->j_start) { |
| 4236 | if ((journal->j_start + journal->j_trans_max + 1) >= | 4235 | if ((journal->j_start + journal->j_trans_max + 1) >= |
| 4237 | temp_jl->j_start) { | 4236 | temp_jl->j_start) { |
| 4238 | flush_used_journal_lists(p_s_sb, temp_jl); | 4237 | flush_used_journal_lists(sb, temp_jl); |
| 4239 | goto first_jl; | 4238 | goto first_jl; |
| 4240 | } else if ((journal->j_start + | 4239 | } else if ((journal->j_start + |
| 4241 | journal->j_trans_max + 1) < | 4240 | journal->j_trans_max + 1) < |
| 4242 | SB_ONDISK_JOURNAL_SIZE(p_s_sb)) { | 4241 | SB_ONDISK_JOURNAL_SIZE(sb)) { |
| 4243 | /* if we don't cross into the next transaction and we don't | 4242 | /* if we don't cross into the next transaction and we don't |
| 4244 | * wrap, there is no way we can overlap any later transactions | 4243 | * wrap, there is no way we can overlap any later transactions |
| 4245 | * break now | 4244 | * break now |
| @@ -4248,11 +4247,11 @@ static int do_journal_end(struct reiserfs_transaction_handle *th, | |||
| 4248 | } | 4247 | } |
| 4249 | } else if ((journal->j_start + | 4248 | } else if ((journal->j_start + |
| 4250 | journal->j_trans_max + 1) > | 4249 | journal->j_trans_max + 1) > |
| 4251 | SB_ONDISK_JOURNAL_SIZE(p_s_sb)) { | 4250 | SB_ONDISK_JOURNAL_SIZE(sb)) { |
| 4252 | if (((journal->j_start + journal->j_trans_max + 1) % | 4251 | if (((journal->j_start + journal->j_trans_max + 1) % |
| 4253 | SB_ONDISK_JOURNAL_SIZE(p_s_sb)) >= | 4252 | SB_ONDISK_JOURNAL_SIZE(sb)) >= |
| 4254 | temp_jl->j_start) { | 4253 | temp_jl->j_start) { |
| 4255 | flush_used_journal_lists(p_s_sb, temp_jl); | 4254 | flush_used_journal_lists(sb, temp_jl); |
| 4256 | goto first_jl; | 4255 | goto first_jl; |
| 4257 | } else { | 4256 | } else { |
| 4258 | /* we don't overlap anything from out start to the end of the | 4257 | /* we don't overlap anything from out start to the end of the |
| @@ -4263,34 +4262,34 @@ static int do_journal_end(struct reiserfs_transaction_handle *th, | |||
| 4263 | } | 4262 | } |
| 4264 | } | 4263 | } |
| 4265 | } | 4264 | } |
| 4266 | flush_old_journal_lists(p_s_sb); | 4265 | flush_old_journal_lists(sb); |
| 4267 | 4266 | ||
| 4268 | journal->j_current_jl->j_list_bitmap = | 4267 | journal->j_current_jl->j_list_bitmap = |
| 4269 | get_list_bitmap(p_s_sb, journal->j_current_jl); | 4268 | get_list_bitmap(sb, journal->j_current_jl); |
| 4270 | 4269 | ||
| 4271 | if (!(journal->j_current_jl->j_list_bitmap)) { | 4270 | if (!(journal->j_current_jl->j_list_bitmap)) { |
| 4272 | reiserfs_panic(p_s_sb, "journal-1996", | 4271 | reiserfs_panic(sb, "journal-1996", |
| 4273 | "could not get a list bitmap"); | 4272 | "could not get a list bitmap"); |
| 4274 | } | 4273 | } |
| 4275 | 4274 | ||
| 4276 | atomic_set(&(journal->j_jlock), 0); | 4275 | atomic_set(&(journal->j_jlock), 0); |
| 4277 | unlock_journal(p_s_sb); | 4276 | unlock_journal(sb); |
| 4278 | /* wake up any body waiting to join. */ | 4277 | /* wake up any body waiting to join. */ |
| 4279 | clear_bit(J_WRITERS_QUEUED, &journal->j_state); | 4278 | clear_bit(J_WRITERS_QUEUED, &journal->j_state); |
| 4280 | wake_up(&(journal->j_join_wait)); | 4279 | wake_up(&(journal->j_join_wait)); |
| 4281 | 4280 | ||
| 4282 | if (!flush && wait_on_commit && | 4281 | if (!flush && wait_on_commit && |
| 4283 | journal_list_still_alive(p_s_sb, commit_trans_id)) { | 4282 | journal_list_still_alive(sb, commit_trans_id)) { |
| 4284 | flush_commit_list(p_s_sb, jl, 1); | 4283 | flush_commit_list(sb, jl, 1); |
| 4285 | } | 4284 | } |
| 4286 | out: | 4285 | out: |
| 4287 | reiserfs_check_lock_depth(p_s_sb, "journal end2"); | 4286 | reiserfs_check_lock_depth(sb, "journal end2"); |
| 4288 | 4287 | ||
| 4289 | memset(th, 0, sizeof(*th)); | 4288 | memset(th, 0, sizeof(*th)); |
| 4290 | /* Re-set th->t_super, so we can properly keep track of how many | 4289 | /* Re-set th->t_super, so we can properly keep track of how many |
| 4291 | * persistent transactions there are. We need to do this so if this | 4290 | * persistent transactions there are. We need to do this so if this |
| 4292 | * call is part of a failed restart_transaction, we can free it later */ | 4291 | * call is part of a failed restart_transaction, we can free it later */ |
| 4293 | th->t_super = p_s_sb; | 4292 | th->t_super = sb; |
| 4294 | 4293 | ||
| 4295 | return journal->j_errno; | 4294 | return journal->j_errno; |
| 4296 | } | 4295 | } |
diff --git a/fs/reiserfs/stree.c b/fs/reiserfs/stree.c index a65bfee28bb8..00fd879c4a2a 100644 --- a/fs/reiserfs/stree.c +++ b/fs/reiserfs/stree.c | |||
| @@ -245,7 +245,7 @@ static const struct reiserfs_key MAX_KEY = { | |||
| 245 | static inline const struct reiserfs_key *get_lkey(const struct treepath | 245 | static inline const struct reiserfs_key *get_lkey(const struct treepath |
| 246 | *p_s_chk_path, | 246 | *p_s_chk_path, |
| 247 | const struct super_block | 247 | const struct super_block |
| 248 | *p_s_sb) | 248 | *sb) |
| 249 | { | 249 | { |
| 250 | int n_position, n_path_offset = p_s_chk_path->path_length; | 250 | int n_position, n_path_offset = p_s_chk_path->path_length; |
| 251 | struct buffer_head *p_s_parent; | 251 | struct buffer_head *p_s_parent; |
| @@ -282,14 +282,14 @@ static inline const struct reiserfs_key *get_lkey(const struct treepath | |||
| 282 | } | 282 | } |
| 283 | /* Return MIN_KEY if we are in the root of the buffer tree. */ | 283 | /* Return MIN_KEY if we are in the root of the buffer tree. */ |
| 284 | if (PATH_OFFSET_PBUFFER(p_s_chk_path, FIRST_PATH_ELEMENT_OFFSET)-> | 284 | if (PATH_OFFSET_PBUFFER(p_s_chk_path, FIRST_PATH_ELEMENT_OFFSET)-> |
| 285 | b_blocknr == SB_ROOT_BLOCK(p_s_sb)) | 285 | b_blocknr == SB_ROOT_BLOCK(sb)) |
| 286 | return &MIN_KEY; | 286 | return &MIN_KEY; |
| 287 | return &MAX_KEY; | 287 | return &MAX_KEY; |
| 288 | } | 288 | } |
| 289 | 289 | ||
| 290 | /* Get delimiting key of the buffer at the path and its right neighbor. */ | 290 | /* Get delimiting key of the buffer at the path and its right neighbor. */ |
| 291 | inline const struct reiserfs_key *get_rkey(const struct treepath *p_s_chk_path, | 291 | inline const struct reiserfs_key *get_rkey(const struct treepath *p_s_chk_path, |
| 292 | const struct super_block *p_s_sb) | 292 | const struct super_block *sb) |
| 293 | { | 293 | { |
| 294 | int n_position, n_path_offset = p_s_chk_path->path_length; | 294 | int n_position, n_path_offset = p_s_chk_path->path_length; |
| 295 | struct buffer_head *p_s_parent; | 295 | struct buffer_head *p_s_parent; |
| @@ -325,7 +325,7 @@ inline const struct reiserfs_key *get_rkey(const struct treepath *p_s_chk_path, | |||
| 325 | } | 325 | } |
| 326 | /* Return MAX_KEY if we are in the root of the buffer tree. */ | 326 | /* Return MAX_KEY if we are in the root of the buffer tree. */ |
| 327 | if (PATH_OFFSET_PBUFFER(p_s_chk_path, FIRST_PATH_ELEMENT_OFFSET)-> | 327 | if (PATH_OFFSET_PBUFFER(p_s_chk_path, FIRST_PATH_ELEMENT_OFFSET)-> |
| 328 | b_blocknr == SB_ROOT_BLOCK(p_s_sb)) | 328 | b_blocknr == SB_ROOT_BLOCK(sb)) |
| 329 | return &MAX_KEY; | 329 | return &MAX_KEY; |
| 330 | return &MIN_KEY; | 330 | return &MIN_KEY; |
| 331 | } | 331 | } |
| @@ -337,7 +337,7 @@ inline const struct reiserfs_key *get_rkey(const struct treepath *p_s_chk_path, | |||
| 337 | this case get_lkey and get_rkey return a special key which is MIN_KEY or MAX_KEY. */ | 337 | this case get_lkey and get_rkey return a special key which is MIN_KEY or MAX_KEY. */ |
| 338 | static inline int key_in_buffer(struct treepath *p_s_chk_path, /* Path which should be checked. */ | 338 | static inline int key_in_buffer(struct treepath *p_s_chk_path, /* Path which should be checked. */ |
| 339 | const struct cpu_key *p_s_key, /* Key which should be checked. */ | 339 | const struct cpu_key *p_s_key, /* Key which should be checked. */ |
| 340 | struct super_block *p_s_sb /* Super block pointer. */ | 340 | struct super_block *sb /* Super block pointer. */ |
| 341 | ) | 341 | ) |
| 342 | { | 342 | { |
| 343 | 343 | ||
| @@ -348,11 +348,11 @@ static inline int key_in_buffer(struct treepath *p_s_chk_path, /* Path which sho | |||
| 348 | RFALSE(!PATH_PLAST_BUFFER(p_s_chk_path)->b_bdev, | 348 | RFALSE(!PATH_PLAST_BUFFER(p_s_chk_path)->b_bdev, |
| 349 | "PAP-5060: device must not be NODEV"); | 349 | "PAP-5060: device must not be NODEV"); |
| 350 | 350 | ||
| 351 | if (comp_keys(get_lkey(p_s_chk_path, p_s_sb), p_s_key) == 1) | 351 | if (comp_keys(get_lkey(p_s_chk_path, sb), p_s_key) == 1) |
| 352 | /* left delimiting key is bigger, that the key we look for */ | 352 | /* left delimiting key is bigger, that the key we look for */ |
| 353 | return 0; | 353 | return 0; |
| 354 | // if ( comp_keys(p_s_key, get_rkey(p_s_chk_path, p_s_sb)) != -1 ) | 354 | // if ( comp_keys(p_s_key, get_rkey(p_s_chk_path, sb)) != -1 ) |
| 355 | if (comp_keys(get_rkey(p_s_chk_path, p_s_sb), p_s_key) != 1) | 355 | if (comp_keys(get_rkey(p_s_chk_path, sb), p_s_key) != 1) |
| 356 | /* p_s_key must be less than right delimitiing key */ | 356 | /* p_s_key must be less than right delimitiing key */ |
| 357 | return 0; | 357 | return 0; |
| 358 | return 1; | 358 | return 1; |
| @@ -546,7 +546,7 @@ static void search_by_key_reada(struct super_block *s, | |||
| 546 | /************************************************************************** | 546 | /************************************************************************** |
| 547 | * Algorithm SearchByKey * | 547 | * Algorithm SearchByKey * |
| 548 | * look for item in the Disk S+Tree by its key * | 548 | * look for item in the Disk S+Tree by its key * |
| 549 | * Input: p_s_sb - super block * | 549 | * Input: sb - super block * |
| 550 | * p_s_key - pointer to the key to search * | 550 | * p_s_key - pointer to the key to search * |
| 551 | * Output: ITEM_FOUND, ITEM_NOT_FOUND or IO_ERROR * | 551 | * Output: ITEM_FOUND, ITEM_NOT_FOUND or IO_ERROR * |
| 552 | * p_s_search_path - path from the root to the needed leaf * | 552 | * p_s_search_path - path from the root to the needed leaf * |
| @@ -566,7 +566,7 @@ static void search_by_key_reada(struct super_block *s, | |||
| 566 | correctness of the top of the path but need not be checked for the | 566 | correctness of the top of the path but need not be checked for the |
| 567 | correctness of the bottom of the path */ | 567 | correctness of the bottom of the path */ |
| 568 | /* The function is NOT SCHEDULE-SAFE! */ | 568 | /* The function is NOT SCHEDULE-SAFE! */ |
| 569 | int search_by_key(struct super_block *p_s_sb, const struct cpu_key *p_s_key, /* Key to search. */ | 569 | int search_by_key(struct super_block *sb, const struct cpu_key *p_s_key, /* Key to search. */ |
| 570 | struct treepath *p_s_search_path,/* This structure was | 570 | struct treepath *p_s_search_path,/* This structure was |
| 571 | allocated and initialized | 571 | allocated and initialized |
| 572 | by the calling | 572 | by the calling |
| @@ -592,7 +592,7 @@ int search_by_key(struct super_block *p_s_sb, const struct cpu_key *p_s_key, /* | |||
| 592 | int n_repeat_counter = 0; | 592 | int n_repeat_counter = 0; |
| 593 | #endif | 593 | #endif |
| 594 | 594 | ||
| 595 | PROC_INFO_INC(p_s_sb, search_by_key); | 595 | PROC_INFO_INC(sb, search_by_key); |
| 596 | 596 | ||
| 597 | /* As we add each node to a path we increase its count. This means that | 597 | /* As we add each node to a path we increase its count. This means that |
| 598 | we must be careful to release all nodes in a path before we either | 598 | we must be careful to release all nodes in a path before we either |
| @@ -605,13 +605,13 @@ int search_by_key(struct super_block *p_s_sb, const struct cpu_key *p_s_key, /* | |||
| 605 | /* With each iteration of this loop we search through the items in the | 605 | /* With each iteration of this loop we search through the items in the |
| 606 | current node, and calculate the next current node(next path element) | 606 | current node, and calculate the next current node(next path element) |
| 607 | for the next iteration of this loop.. */ | 607 | for the next iteration of this loop.. */ |
| 608 | n_block_number = SB_ROOT_BLOCK(p_s_sb); | 608 | n_block_number = SB_ROOT_BLOCK(sb); |
| 609 | expected_level = -1; | 609 | expected_level = -1; |
| 610 | while (1) { | 610 | while (1) { |
| 611 | 611 | ||
| 612 | #ifdef CONFIG_REISERFS_CHECK | 612 | #ifdef CONFIG_REISERFS_CHECK |
| 613 | if (!(++n_repeat_counter % 50000)) | 613 | if (!(++n_repeat_counter % 50000)) |
| 614 | reiserfs_warning(p_s_sb, "PAP-5100", | 614 | reiserfs_warning(sb, "PAP-5100", |
| 615 | "%s: there were %d iterations of " | 615 | "%s: there were %d iterations of " |
| 616 | "while loop looking for key %K", | 616 | "while loop looking for key %K", |
| 617 | current->comm, n_repeat_counter, | 617 | current->comm, n_repeat_counter, |
| @@ -622,14 +622,14 @@ int search_by_key(struct super_block *p_s_sb, const struct cpu_key *p_s_key, /* | |||
| 622 | p_s_last_element = | 622 | p_s_last_element = |
| 623 | PATH_OFFSET_PELEMENT(p_s_search_path, | 623 | PATH_OFFSET_PELEMENT(p_s_search_path, |
| 624 | ++p_s_search_path->path_length); | 624 | ++p_s_search_path->path_length); |
| 625 | fs_gen = get_generation(p_s_sb); | 625 | fs_gen = get_generation(sb); |
| 626 | 626 | ||
| 627 | /* Read the next tree node, and set the last element in the path to | 627 | /* Read the next tree node, and set the last element in the path to |
| 628 | have a pointer to it. */ | 628 | have a pointer to it. */ |
| 629 | if ((p_s_bh = p_s_last_element->pe_buffer = | 629 | if ((p_s_bh = p_s_last_element->pe_buffer = |
| 630 | sb_getblk(p_s_sb, n_block_number))) { | 630 | sb_getblk(sb, n_block_number))) { |
| 631 | if (!buffer_uptodate(p_s_bh) && reada_count > 1) { | 631 | if (!buffer_uptodate(p_s_bh) && reada_count > 1) { |
| 632 | search_by_key_reada(p_s_sb, reada_bh, | 632 | search_by_key_reada(sb, reada_bh, |
| 633 | reada_blocks, reada_count); | 633 | reada_blocks, reada_count); |
| 634 | } | 634 | } |
| 635 | ll_rw_block(READ, 1, &p_s_bh); | 635 | ll_rw_block(READ, 1, &p_s_bh); |
| @@ -644,25 +644,25 @@ int search_by_key(struct super_block *p_s_sb, const struct cpu_key *p_s_key, /* | |||
| 644 | } | 644 | } |
| 645 | reada_count = 0; | 645 | reada_count = 0; |
| 646 | if (expected_level == -1) | 646 | if (expected_level == -1) |
| 647 | expected_level = SB_TREE_HEIGHT(p_s_sb); | 647 | expected_level = SB_TREE_HEIGHT(sb); |
| 648 | expected_level--; | 648 | expected_level--; |
| 649 | 649 | ||
| 650 | /* It is possible that schedule occurred. We must check whether the key | 650 | /* It is possible that schedule occurred. We must check whether the key |
| 651 | to search is still in the tree rooted from the current buffer. If | 651 | to search is still in the tree rooted from the current buffer. If |
| 652 | not then repeat search from the root. */ | 652 | not then repeat search from the root. */ |
| 653 | if (fs_changed(fs_gen, p_s_sb) && | 653 | if (fs_changed(fs_gen, sb) && |
| 654 | (!B_IS_IN_TREE(p_s_bh) || | 654 | (!B_IS_IN_TREE(p_s_bh) || |
| 655 | B_LEVEL(p_s_bh) != expected_level || | 655 | B_LEVEL(p_s_bh) != expected_level || |
| 656 | !key_in_buffer(p_s_search_path, p_s_key, p_s_sb))) { | 656 | !key_in_buffer(p_s_search_path, p_s_key, sb))) { |
| 657 | PROC_INFO_INC(p_s_sb, search_by_key_fs_changed); | 657 | PROC_INFO_INC(sb, search_by_key_fs_changed); |
| 658 | PROC_INFO_INC(p_s_sb, search_by_key_restarted); | 658 | PROC_INFO_INC(sb, search_by_key_restarted); |
| 659 | PROC_INFO_INC(p_s_sb, | 659 | PROC_INFO_INC(sb, |
| 660 | sbk_restarted[expected_level - 1]); | 660 | sbk_restarted[expected_level - 1]); |
| 661 | pathrelse(p_s_search_path); | 661 | pathrelse(p_s_search_path); |
| 662 | 662 | ||
| 663 | /* Get the root block number so that we can repeat the search | 663 | /* Get the root block number so that we can repeat the search |
| 664 | starting from the root. */ | 664 | starting from the root. */ |
| 665 | n_block_number = SB_ROOT_BLOCK(p_s_sb); | 665 | n_block_number = SB_ROOT_BLOCK(sb); |
| 666 | expected_level = -1; | 666 | expected_level = -1; |
| 667 | right_neighbor_of_leaf_node = 0; | 667 | right_neighbor_of_leaf_node = 0; |
| 668 | 668 | ||
| @@ -674,12 +674,12 @@ int search_by_key(struct super_block *p_s_sb, const struct cpu_key *p_s_key, /* | |||
| 674 | equal to the MAX_KEY. Latter case is only possible in | 674 | equal to the MAX_KEY. Latter case is only possible in |
| 675 | "finish_unfinished()" processing during mount. */ | 675 | "finish_unfinished()" processing during mount. */ |
| 676 | RFALSE(comp_keys(&MAX_KEY, p_s_key) && | 676 | RFALSE(comp_keys(&MAX_KEY, p_s_key) && |
| 677 | !key_in_buffer(p_s_search_path, p_s_key, p_s_sb), | 677 | !key_in_buffer(p_s_search_path, p_s_key, sb), |
| 678 | "PAP-5130: key is not in the buffer"); | 678 | "PAP-5130: key is not in the buffer"); |
| 679 | #ifdef CONFIG_REISERFS_CHECK | 679 | #ifdef CONFIG_REISERFS_CHECK |
| 680 | if (cur_tb) { | 680 | if (cur_tb) { |
| 681 | print_cur_tb("5140"); | 681 | print_cur_tb("5140"); |
| 682 | reiserfs_panic(p_s_sb, "PAP-5140", | 682 | reiserfs_panic(sb, "PAP-5140", |
| 683 | "schedule occurred in do_balance!"); | 683 | "schedule occurred in do_balance!"); |
| 684 | } | 684 | } |
| 685 | #endif | 685 | #endif |
| @@ -687,7 +687,7 @@ int search_by_key(struct super_block *p_s_sb, const struct cpu_key *p_s_key, /* | |||
| 687 | // make sure, that the node contents look like a node of | 687 | // make sure, that the node contents look like a node of |
| 688 | // certain level | 688 | // certain level |
| 689 | if (!is_tree_node(p_s_bh, expected_level)) { | 689 | if (!is_tree_node(p_s_bh, expected_level)) { |
| 690 | reiserfs_error(p_s_sb, "vs-5150", | 690 | reiserfs_error(sb, "vs-5150", |
| 691 | "invalid format found in block %ld. " | 691 | "invalid format found in block %ld. " |
| 692 | "Fsck?", p_s_bh->b_blocknr); | 692 | "Fsck?", p_s_bh->b_blocknr); |
| 693 | pathrelse(p_s_search_path); | 693 | pathrelse(p_s_search_path); |
| @@ -697,7 +697,7 @@ int search_by_key(struct super_block *p_s_sb, const struct cpu_key *p_s_key, /* | |||
| 697 | /* ok, we have acquired next formatted node in the tree */ | 697 | /* ok, we have acquired next formatted node in the tree */ |
| 698 | n_node_level = B_LEVEL(p_s_bh); | 698 | n_node_level = B_LEVEL(p_s_bh); |
| 699 | 699 | ||
| 700 | PROC_INFO_BH_STAT(p_s_sb, p_s_bh, n_node_level - 1); | 700 | PROC_INFO_BH_STAT(sb, p_s_bh, n_node_level - 1); |
| 701 | 701 | ||
| 702 | RFALSE(n_node_level < n_stop_level, | 702 | RFALSE(n_node_level < n_stop_level, |
| 703 | "vs-5152: tree level (%d) is less than stop level (%d)", | 703 | "vs-5152: tree level (%d) is less than stop level (%d)", |
| @@ -776,7 +776,7 @@ int search_by_key(struct super_block *p_s_sb, const struct cpu_key *p_s_key, /* | |||
| 776 | units of directory entries. */ | 776 | units of directory entries. */ |
| 777 | 777 | ||
| 778 | /* The function is NOT SCHEDULE-SAFE! */ | 778 | /* The function is NOT SCHEDULE-SAFE! */ |
| 779 | int search_for_position_by_key(struct super_block *p_s_sb, /* Pointer to the super block. */ | 779 | int search_for_position_by_key(struct super_block *sb, /* Pointer to the super block. */ |
| 780 | const struct cpu_key *p_cpu_key, /* Key to search (cpu variable) */ | 780 | const struct cpu_key *p_cpu_key, /* Key to search (cpu variable) */ |
| 781 | struct treepath *p_s_search_path /* Filled up by this function. */ | 781 | struct treepath *p_s_search_path /* Filled up by this function. */ |
| 782 | ) | 782 | ) |
| @@ -789,13 +789,13 @@ int search_for_position_by_key(struct super_block *p_s_sb, /* Pointer to the sup | |||
| 789 | 789 | ||
| 790 | /* If searching for directory entry. */ | 790 | /* If searching for directory entry. */ |
| 791 | if (is_direntry_cpu_key(p_cpu_key)) | 791 | if (is_direntry_cpu_key(p_cpu_key)) |
| 792 | return search_by_entry_key(p_s_sb, p_cpu_key, p_s_search_path, | 792 | return search_by_entry_key(sb, p_cpu_key, p_s_search_path, |
| 793 | &de); | 793 | &de); |
| 794 | 794 | ||
| 795 | /* If not searching for directory entry. */ | 795 | /* If not searching for directory entry. */ |
| 796 | 796 | ||
| 797 | /* If item is found. */ | 797 | /* If item is found. */ |
| 798 | retval = search_item(p_s_sb, p_cpu_key, p_s_search_path); | 798 | retval = search_item(sb, p_cpu_key, p_s_search_path); |
| 799 | if (retval == IO_ERROR) | 799 | if (retval == IO_ERROR) |
| 800 | return retval; | 800 | return retval; |
| 801 | if (retval == ITEM_FOUND) { | 801 | if (retval == ITEM_FOUND) { |
| @@ -817,7 +817,7 @@ int search_for_position_by_key(struct super_block *p_s_sb, /* Pointer to the sup | |||
| 817 | p_le_ih = | 817 | p_le_ih = |
| 818 | B_N_PITEM_HEAD(PATH_PLAST_BUFFER(p_s_search_path), | 818 | B_N_PITEM_HEAD(PATH_PLAST_BUFFER(p_s_search_path), |
| 819 | --PATH_LAST_POSITION(p_s_search_path)); | 819 | --PATH_LAST_POSITION(p_s_search_path)); |
| 820 | n_blk_size = p_s_sb->s_blocksize; | 820 | n_blk_size = sb->s_blocksize; |
| 821 | 821 | ||
| 822 | if (comp_short_keys(&(p_le_ih->ih_key), p_cpu_key)) { | 822 | if (comp_short_keys(&(p_le_ih->ih_key), p_cpu_key)) { |
| 823 | return FILE_NOT_FOUND; | 823 | return FILE_NOT_FOUND; |
| @@ -957,7 +957,7 @@ static char prepare_for_delete_or_cut(struct reiserfs_transaction_handle *th, st | |||
| 957 | int *p_n_cut_size, unsigned long long n_new_file_length /* MAX_KEY_OFFSET in case of delete. */ | 957 | int *p_n_cut_size, unsigned long long n_new_file_length /* MAX_KEY_OFFSET in case of delete. */ |
| 958 | ) | 958 | ) |
| 959 | { | 959 | { |
| 960 | struct super_block *p_s_sb = inode->i_sb; | 960 | struct super_block *sb = inode->i_sb; |
| 961 | struct item_head *p_le_ih = PATH_PITEM_HEAD(p_s_path); | 961 | struct item_head *p_le_ih = PATH_PITEM_HEAD(p_s_path); |
| 962 | struct buffer_head *p_s_bh = PATH_PLAST_BUFFER(p_s_path); | 962 | struct buffer_head *p_s_bh = PATH_PLAST_BUFFER(p_s_path); |
| 963 | 963 | ||
| @@ -986,7 +986,7 @@ static char prepare_for_delete_or_cut(struct reiserfs_transaction_handle *th, st | |||
| 986 | 986 | ||
| 987 | /* Case of an indirect item. */ | 987 | /* Case of an indirect item. */ |
| 988 | { | 988 | { |
| 989 | int blk_size = p_s_sb->s_blocksize; | 989 | int blk_size = sb->s_blocksize; |
| 990 | struct item_head s_ih; | 990 | struct item_head s_ih; |
| 991 | int need_re_search; | 991 | int need_re_search; |
| 992 | int delete = 0; | 992 | int delete = 0; |
| @@ -1023,9 +1023,9 @@ static char prepare_for_delete_or_cut(struct reiserfs_transaction_handle *th, st | |||
| 1023 | block = get_block_num(unfm, 0); | 1023 | block = get_block_num(unfm, 0); |
| 1024 | 1024 | ||
| 1025 | if (block != 0) { | 1025 | if (block != 0) { |
| 1026 | reiserfs_prepare_for_journal(p_s_sb, p_s_bh, 1); | 1026 | reiserfs_prepare_for_journal(sb, p_s_bh, 1); |
| 1027 | put_block_num(unfm, 0, 0); | 1027 | put_block_num(unfm, 0, 0); |
| 1028 | journal_mark_dirty (th, p_s_sb, p_s_bh); | 1028 | journal_mark_dirty (th, sb, p_s_bh); |
| 1029 | reiserfs_free_block(th, inode, block, 1); | 1029 | reiserfs_free_block(th, inode, block, 1); |
| 1030 | } | 1030 | } |
| 1031 | 1031 | ||
| @@ -1049,9 +1049,9 @@ static char prepare_for_delete_or_cut(struct reiserfs_transaction_handle *th, st | |||
| 1049 | /* a trick. If the buffer has been logged, this will do nothing. If | 1049 | /* a trick. If the buffer has been logged, this will do nothing. If |
| 1050 | ** we've broken the loop without logging it, it will restore the | 1050 | ** we've broken the loop without logging it, it will restore the |
| 1051 | ** buffer */ | 1051 | ** buffer */ |
| 1052 | reiserfs_restore_prepared_buffer(p_s_sb, p_s_bh); | 1052 | reiserfs_restore_prepared_buffer(sb, p_s_bh); |
| 1053 | } while (need_re_search && | 1053 | } while (need_re_search && |
| 1054 | search_for_position_by_key(p_s_sb, p_s_item_key, p_s_path) == POSITION_FOUND); | 1054 | search_for_position_by_key(sb, p_s_item_key, p_s_path) == POSITION_FOUND); |
| 1055 | pos_in_item(p_s_path) = pos * UNFM_P_SIZE; | 1055 | pos_in_item(p_s_path) = pos * UNFM_P_SIZE; |
| 1056 | 1056 | ||
| 1057 | if (*p_n_cut_size == 0) { | 1057 | if (*p_n_cut_size == 0) { |
| @@ -1090,7 +1090,7 @@ static int calc_deleted_bytes_number(struct tree_balance *p_s_tb, char c_mode) | |||
| 1090 | 1090 | ||
| 1091 | static void init_tb_struct(struct reiserfs_transaction_handle *th, | 1091 | static void init_tb_struct(struct reiserfs_transaction_handle *th, |
| 1092 | struct tree_balance *p_s_tb, | 1092 | struct tree_balance *p_s_tb, |
| 1093 | struct super_block *p_s_sb, | 1093 | struct super_block *sb, |
| 1094 | struct treepath *p_s_path, int n_size) | 1094 | struct treepath *p_s_path, int n_size) |
| 1095 | { | 1095 | { |
| 1096 | 1096 | ||
| @@ -1098,7 +1098,7 @@ static void init_tb_struct(struct reiserfs_transaction_handle *th, | |||
| 1098 | 1098 | ||
| 1099 | memset(p_s_tb, '\0', sizeof(struct tree_balance)); | 1099 | memset(p_s_tb, '\0', sizeof(struct tree_balance)); |
| 1100 | p_s_tb->transaction_handle = th; | 1100 | p_s_tb->transaction_handle = th; |
| 1101 | p_s_tb->tb_sb = p_s_sb; | 1101 | p_s_tb->tb_sb = sb; |
| 1102 | p_s_tb->tb_path = p_s_path; | 1102 | p_s_tb->tb_path = p_s_path; |
| 1103 | PATH_OFFSET_PBUFFER(p_s_path, ILLEGAL_PATH_ELEMENT_OFFSET) = NULL; | 1103 | PATH_OFFSET_PBUFFER(p_s_path, ILLEGAL_PATH_ELEMENT_OFFSET) = NULL; |
| 1104 | PATH_OFFSET_POSITION(p_s_path, ILLEGAL_PATH_ELEMENT_OFFSET) = 0; | 1104 | PATH_OFFSET_POSITION(p_s_path, ILLEGAL_PATH_ELEMENT_OFFSET) = 0; |
| @@ -1147,7 +1147,7 @@ int reiserfs_delete_item(struct reiserfs_transaction_handle *th, struct treepath | |||
| 1147 | struct inode *p_s_inode, /* inode is here just to update i_blocks and quotas */ | 1147 | struct inode *p_s_inode, /* inode is here just to update i_blocks and quotas */ |
| 1148 | struct buffer_head *p_s_un_bh) | 1148 | struct buffer_head *p_s_un_bh) |
| 1149 | { /* NULL or unformatted node pointer. */ | 1149 | { /* NULL or unformatted node pointer. */ |
| 1150 | struct super_block *p_s_sb = p_s_inode->i_sb; | 1150 | struct super_block *sb = p_s_inode->i_sb; |
| 1151 | struct tree_balance s_del_balance; | 1151 | struct tree_balance s_del_balance; |
| 1152 | struct item_head s_ih; | 1152 | struct item_head s_ih; |
| 1153 | struct item_head *q_ih; | 1153 | struct item_head *q_ih; |
| @@ -1161,7 +1161,7 @@ int reiserfs_delete_item(struct reiserfs_transaction_handle *th, struct treepath | |||
| 1161 | 1161 | ||
| 1162 | BUG_ON(!th->t_trans_id); | 1162 | BUG_ON(!th->t_trans_id); |
| 1163 | 1163 | ||
| 1164 | init_tb_struct(th, &s_del_balance, p_s_sb, p_s_path, | 1164 | init_tb_struct(th, &s_del_balance, sb, p_s_path, |
| 1165 | 0 /*size is unknown */ ); | 1165 | 0 /*size is unknown */ ); |
| 1166 | 1166 | ||
| 1167 | while (1) { | 1167 | while (1) { |
| @@ -1185,15 +1185,15 @@ int reiserfs_delete_item(struct reiserfs_transaction_handle *th, struct treepath | |||
| 1185 | if (n_ret_value != REPEAT_SEARCH) | 1185 | if (n_ret_value != REPEAT_SEARCH) |
| 1186 | break; | 1186 | break; |
| 1187 | 1187 | ||
| 1188 | PROC_INFO_INC(p_s_sb, delete_item_restarted); | 1188 | PROC_INFO_INC(sb, delete_item_restarted); |
| 1189 | 1189 | ||
| 1190 | // file system changed, repeat search | 1190 | // file system changed, repeat search |
| 1191 | n_ret_value = | 1191 | n_ret_value = |
| 1192 | search_for_position_by_key(p_s_sb, p_s_item_key, p_s_path); | 1192 | search_for_position_by_key(sb, p_s_item_key, p_s_path); |
| 1193 | if (n_ret_value == IO_ERROR) | 1193 | if (n_ret_value == IO_ERROR) |
| 1194 | break; | 1194 | break; |
| 1195 | if (n_ret_value == FILE_NOT_FOUND) { | 1195 | if (n_ret_value == FILE_NOT_FOUND) { |
| 1196 | reiserfs_warning(p_s_sb, "vs-5340", | 1196 | reiserfs_warning(sb, "vs-5340", |
| 1197 | "no items of the file %K found", | 1197 | "no items of the file %K found", |
| 1198 | p_s_item_key); | 1198 | p_s_item_key); |
| 1199 | break; | 1199 | break; |
| @@ -1216,8 +1216,8 @@ int reiserfs_delete_item(struct reiserfs_transaction_handle *th, struct treepath | |||
| 1216 | ** the unfm node once | 1216 | ** the unfm node once |
| 1217 | */ | 1217 | */ |
| 1218 | if (!S_ISLNK(p_s_inode->i_mode) && is_direct_le_ih(q_ih)) { | 1218 | if (!S_ISLNK(p_s_inode->i_mode) && is_direct_le_ih(q_ih)) { |
| 1219 | if ((le_ih_k_offset(q_ih) & (p_s_sb->s_blocksize - 1)) == 1) { | 1219 | if ((le_ih_k_offset(q_ih) & (sb->s_blocksize - 1)) == 1) { |
| 1220 | quota_cut_bytes = p_s_sb->s_blocksize + UNFM_P_SIZE; | 1220 | quota_cut_bytes = sb->s_blocksize + UNFM_P_SIZE; |
| 1221 | } else { | 1221 | } else { |
| 1222 | quota_cut_bytes = 0; | 1222 | quota_cut_bytes = 0; |
| 1223 | } | 1223 | } |
| @@ -1258,7 +1258,7 @@ int reiserfs_delete_item(struct reiserfs_transaction_handle *th, struct treepath | |||
| 1258 | do_balance(&s_del_balance, NULL, NULL, M_DELETE); | 1258 | do_balance(&s_del_balance, NULL, NULL, M_DELETE); |
| 1259 | 1259 | ||
| 1260 | #ifdef REISERQUOTA_DEBUG | 1260 | #ifdef REISERQUOTA_DEBUG |
| 1261 | reiserfs_debug(p_s_sb, REISERFS_DEBUG_CODE, | 1261 | reiserfs_debug(sb, REISERFS_DEBUG_CODE, |
| 1262 | "reiserquota delete_item(): freeing %u, id=%u type=%c", | 1262 | "reiserquota delete_item(): freeing %u, id=%u type=%c", |
| 1263 | quota_cut_bytes, p_s_inode->i_uid, head2type(&s_ih)); | 1263 | quota_cut_bytes, p_s_inode->i_uid, head2type(&s_ih)); |
| 1264 | #endif | 1264 | #endif |
| @@ -1430,8 +1430,8 @@ static int maybe_indirect_to_direct(struct reiserfs_transaction_handle *th, | |||
| 1430 | const struct cpu_key *p_s_item_key, | 1430 | const struct cpu_key *p_s_item_key, |
| 1431 | loff_t n_new_file_size, char *p_c_mode) | 1431 | loff_t n_new_file_size, char *p_c_mode) |
| 1432 | { | 1432 | { |
| 1433 | struct super_block *p_s_sb = p_s_inode->i_sb; | 1433 | struct super_block *sb = p_s_inode->i_sb; |
| 1434 | int n_block_size = p_s_sb->s_blocksize; | 1434 | int n_block_size = sb->s_blocksize; |
| 1435 | int cut_bytes; | 1435 | int cut_bytes; |
| 1436 | BUG_ON(!th->t_trans_id); | 1436 | BUG_ON(!th->t_trans_id); |
| 1437 | BUG_ON(n_new_file_size != p_s_inode->i_size); | 1437 | BUG_ON(n_new_file_size != p_s_inode->i_size); |
| @@ -1509,7 +1509,7 @@ int reiserfs_cut_from_item(struct reiserfs_transaction_handle *th, | |||
| 1509 | struct inode *p_s_inode, | 1509 | struct inode *p_s_inode, |
| 1510 | struct page *page, loff_t n_new_file_size) | 1510 | struct page *page, loff_t n_new_file_size) |
| 1511 | { | 1511 | { |
| 1512 | struct super_block *p_s_sb = p_s_inode->i_sb; | 1512 | struct super_block *sb = p_s_inode->i_sb; |
| 1513 | /* Every function which is going to call do_balance must first | 1513 | /* Every function which is going to call do_balance must first |
| 1514 | create a tree_balance structure. Then it must fill up this | 1514 | create a tree_balance structure. Then it must fill up this |
| 1515 | structure by using the init_tb_struct and fix_nodes functions. | 1515 | structure by using the init_tb_struct and fix_nodes functions. |
| @@ -1560,7 +1560,7 @@ int reiserfs_cut_from_item(struct reiserfs_transaction_handle *th, | |||
| 1560 | /* removing of last unformatted node will change value we | 1560 | /* removing of last unformatted node will change value we |
| 1561 | have to return to truncate. Save it */ | 1561 | have to return to truncate. Save it */ |
| 1562 | retval2 = n_ret_value; | 1562 | retval2 = n_ret_value; |
| 1563 | /*retval2 = p_s_sb->s_blocksize - (n_new_file_size & (p_s_sb->s_blocksize - 1)); */ | 1563 | /*retval2 = sb->s_blocksize - (n_new_file_size & (sb->s_blocksize - 1)); */ |
| 1564 | 1564 | ||
| 1565 | /* So, we have performed the first part of the conversion: | 1565 | /* So, we have performed the first part of the conversion: |
| 1566 | inserting the new direct item. Now we are removing the | 1566 | inserting the new direct item. Now we are removing the |
| @@ -1569,16 +1569,16 @@ int reiserfs_cut_from_item(struct reiserfs_transaction_handle *th, | |||
| 1569 | set_cpu_key_k_type(p_s_item_key, TYPE_INDIRECT); | 1569 | set_cpu_key_k_type(p_s_item_key, TYPE_INDIRECT); |
| 1570 | p_s_item_key->key_length = 4; | 1570 | p_s_item_key->key_length = 4; |
| 1571 | n_new_file_size -= | 1571 | n_new_file_size -= |
| 1572 | (n_new_file_size & (p_s_sb->s_blocksize - 1)); | 1572 | (n_new_file_size & (sb->s_blocksize - 1)); |
| 1573 | tail_pos = n_new_file_size; | 1573 | tail_pos = n_new_file_size; |
| 1574 | set_cpu_key_k_offset(p_s_item_key, n_new_file_size + 1); | 1574 | set_cpu_key_k_offset(p_s_item_key, n_new_file_size + 1); |
| 1575 | if (search_for_position_by_key | 1575 | if (search_for_position_by_key |
| 1576 | (p_s_sb, p_s_item_key, | 1576 | (sb, p_s_item_key, |
| 1577 | p_s_path) == POSITION_NOT_FOUND) { | 1577 | p_s_path) == POSITION_NOT_FOUND) { |
| 1578 | print_block(PATH_PLAST_BUFFER(p_s_path), 3, | 1578 | print_block(PATH_PLAST_BUFFER(p_s_path), 3, |
| 1579 | PATH_LAST_POSITION(p_s_path) - 1, | 1579 | PATH_LAST_POSITION(p_s_path) - 1, |
| 1580 | PATH_LAST_POSITION(p_s_path) + 1); | 1580 | PATH_LAST_POSITION(p_s_path) + 1); |
| 1581 | reiserfs_panic(p_s_sb, "PAP-5580", "item to " | 1581 | reiserfs_panic(sb, "PAP-5580", "item to " |
| 1582 | "convert does not exist (%K)", | 1582 | "convert does not exist (%K)", |
| 1583 | p_s_item_key); | 1583 | p_s_item_key); |
| 1584 | } | 1584 | } |
| @@ -1595,14 +1595,14 @@ int reiserfs_cut_from_item(struct reiserfs_transaction_handle *th, | |||
| 1595 | if (n_ret_value != REPEAT_SEARCH) | 1595 | if (n_ret_value != REPEAT_SEARCH) |
| 1596 | break; | 1596 | break; |
| 1597 | 1597 | ||
| 1598 | PROC_INFO_INC(p_s_sb, cut_from_item_restarted); | 1598 | PROC_INFO_INC(sb, cut_from_item_restarted); |
| 1599 | 1599 | ||
| 1600 | n_ret_value = | 1600 | n_ret_value = |
| 1601 | search_for_position_by_key(p_s_sb, p_s_item_key, p_s_path); | 1601 | search_for_position_by_key(sb, p_s_item_key, p_s_path); |
| 1602 | if (n_ret_value == POSITION_FOUND) | 1602 | if (n_ret_value == POSITION_FOUND) |
| 1603 | continue; | 1603 | continue; |
| 1604 | 1604 | ||
| 1605 | reiserfs_warning(p_s_sb, "PAP-5610", "item %K not found", | 1605 | reiserfs_warning(sb, "PAP-5610", "item %K not found", |
| 1606 | p_s_item_key); | 1606 | p_s_item_key); |
| 1607 | unfix_nodes(&s_cut_balance); | 1607 | unfix_nodes(&s_cut_balance); |
| 1608 | return (n_ret_value == IO_ERROR) ? -EIO : -ENOENT; | 1608 | return (n_ret_value == IO_ERROR) ? -EIO : -ENOENT; |
| @@ -1616,7 +1616,7 @@ int reiserfs_cut_from_item(struct reiserfs_transaction_handle *th, | |||
| 1616 | indirect_to_direct_roll_back(th, p_s_inode, p_s_path); | 1616 | indirect_to_direct_roll_back(th, p_s_inode, p_s_path); |
| 1617 | } | 1617 | } |
| 1618 | if (n_ret_value == NO_DISK_SPACE) | 1618 | if (n_ret_value == NO_DISK_SPACE) |
| 1619 | reiserfs_warning(p_s_sb, "reiserfs-5092", | 1619 | reiserfs_warning(sb, "reiserfs-5092", |
| 1620 | "NO_DISK_SPACE"); | 1620 | "NO_DISK_SPACE"); |
| 1621 | unfix_nodes(&s_cut_balance); | 1621 | unfix_nodes(&s_cut_balance); |
| 1622 | return -EIO; | 1622 | return -EIO; |
| @@ -1642,11 +1642,11 @@ int reiserfs_cut_from_item(struct reiserfs_transaction_handle *th, | |||
| 1642 | p_le_ih = PATH_PITEM_HEAD(s_cut_balance.tb_path); | 1642 | p_le_ih = PATH_PITEM_HEAD(s_cut_balance.tb_path); |
| 1643 | if (!S_ISLNK(p_s_inode->i_mode) && is_direct_le_ih(p_le_ih)) { | 1643 | if (!S_ISLNK(p_s_inode->i_mode) && is_direct_le_ih(p_le_ih)) { |
| 1644 | if (c_mode == M_DELETE && | 1644 | if (c_mode == M_DELETE && |
| 1645 | (le_ih_k_offset(p_le_ih) & (p_s_sb->s_blocksize - 1)) == | 1645 | (le_ih_k_offset(p_le_ih) & (sb->s_blocksize - 1)) == |
| 1646 | 1) { | 1646 | 1) { |
| 1647 | // FIXME: this is to keep 3.5 happy | 1647 | // FIXME: this is to keep 3.5 happy |
| 1648 | REISERFS_I(p_s_inode)->i_first_direct_byte = U32_MAX; | 1648 | REISERFS_I(p_s_inode)->i_first_direct_byte = U32_MAX; |
| 1649 | quota_cut_bytes = p_s_sb->s_blocksize + UNFM_P_SIZE; | 1649 | quota_cut_bytes = sb->s_blocksize + UNFM_P_SIZE; |
| 1650 | } else { | 1650 | } else { |
| 1651 | quota_cut_bytes = 0; | 1651 | quota_cut_bytes = 0; |
| 1652 | } | 1652 | } |
| @@ -1659,18 +1659,18 @@ int reiserfs_cut_from_item(struct reiserfs_transaction_handle *th, | |||
| 1659 | sure, that we exactly remove last unformatted node pointer | 1659 | sure, that we exactly remove last unformatted node pointer |
| 1660 | of the item */ | 1660 | of the item */ |
| 1661 | if (!is_indirect_le_ih(le_ih)) | 1661 | if (!is_indirect_le_ih(le_ih)) |
| 1662 | reiserfs_panic(p_s_sb, "vs-5652", | 1662 | reiserfs_panic(sb, "vs-5652", |
| 1663 | "item must be indirect %h", le_ih); | 1663 | "item must be indirect %h", le_ih); |
| 1664 | 1664 | ||
| 1665 | if (c_mode == M_DELETE && ih_item_len(le_ih) != UNFM_P_SIZE) | 1665 | if (c_mode == M_DELETE && ih_item_len(le_ih) != UNFM_P_SIZE) |
| 1666 | reiserfs_panic(p_s_sb, "vs-5653", "completing " | 1666 | reiserfs_panic(sb, "vs-5653", "completing " |
| 1667 | "indirect2direct conversion indirect " | 1667 | "indirect2direct conversion indirect " |
| 1668 | "item %h being deleted must be of " | 1668 | "item %h being deleted must be of " |
| 1669 | "4 byte long", le_ih); | 1669 | "4 byte long", le_ih); |
| 1670 | 1670 | ||
| 1671 | if (c_mode == M_CUT | 1671 | if (c_mode == M_CUT |
| 1672 | && s_cut_balance.insert_size[0] != -UNFM_P_SIZE) { | 1672 | && s_cut_balance.insert_size[0] != -UNFM_P_SIZE) { |
| 1673 | reiserfs_panic(p_s_sb, "vs-5654", "can not complete " | 1673 | reiserfs_panic(sb, "vs-5654", "can not complete " |
| 1674 | "indirect2direct conversion of %h " | 1674 | "indirect2direct conversion of %h " |
| 1675 | "(CUT, insert_size==%d)", | 1675 | "(CUT, insert_size==%d)", |
| 1676 | le_ih, s_cut_balance.insert_size[0]); | 1676 | le_ih, s_cut_balance.insert_size[0]); |
diff --git a/fs/reiserfs/tail_conversion.c b/fs/reiserfs/tail_conversion.c index 0635cfe0f0b7..27311a5f0469 100644 --- a/fs/reiserfs/tail_conversion.c +++ b/fs/reiserfs/tail_conversion.c | |||
| @@ -175,9 +175,9 @@ int indirect2direct(struct reiserfs_transaction_handle *th, struct inode *p_s_in | |||
| 175 | loff_t n_new_file_size, /* New file size. */ | 175 | loff_t n_new_file_size, /* New file size. */ |
| 176 | char *p_c_mode) | 176 | char *p_c_mode) |
| 177 | { | 177 | { |
| 178 | struct super_block *p_s_sb = p_s_inode->i_sb; | 178 | struct super_block *sb = p_s_inode->i_sb; |
| 179 | struct item_head s_ih; | 179 | struct item_head s_ih; |
| 180 | unsigned long n_block_size = p_s_sb->s_blocksize; | 180 | unsigned long n_block_size = sb->s_blocksize; |
| 181 | char *tail; | 181 | char *tail; |
| 182 | int tail_len, round_tail_len; | 182 | int tail_len, round_tail_len; |
| 183 | loff_t pos, pos1; /* position of first byte of the tail */ | 183 | loff_t pos, pos1; /* position of first byte of the tail */ |
| @@ -185,7 +185,7 @@ int indirect2direct(struct reiserfs_transaction_handle *th, struct inode *p_s_in | |||
| 185 | 185 | ||
| 186 | BUG_ON(!th->t_trans_id); | 186 | BUG_ON(!th->t_trans_id); |
| 187 | 187 | ||
| 188 | REISERFS_SB(p_s_sb)->s_indirect2direct++; | 188 | REISERFS_SB(sb)->s_indirect2direct++; |
| 189 | 189 | ||
| 190 | *p_c_mode = M_SKIP_BALANCING; | 190 | *p_c_mode = M_SKIP_BALANCING; |
| 191 | 191 | ||
| @@ -200,7 +200,7 @@ int indirect2direct(struct reiserfs_transaction_handle *th, struct inode *p_s_in | |||
| 200 | 200 | ||
| 201 | pos = | 201 | pos = |
| 202 | le_ih_k_offset(&s_ih) - 1 + (ih_item_len(&s_ih) / UNFM_P_SIZE - | 202 | le_ih_k_offset(&s_ih) - 1 + (ih_item_len(&s_ih) / UNFM_P_SIZE - |
| 203 | 1) * p_s_sb->s_blocksize; | 203 | 1) * sb->s_blocksize; |
| 204 | pos1 = pos; | 204 | pos1 = pos; |
| 205 | 205 | ||
| 206 | // we are protected by i_mutex. The tail can not disapper, not | 206 | // we are protected by i_mutex. The tail can not disapper, not |
| @@ -211,18 +211,18 @@ int indirect2direct(struct reiserfs_transaction_handle *th, struct inode *p_s_in | |||
| 211 | 211 | ||
| 212 | if (path_changed(&s_ih, p_s_path)) { | 212 | if (path_changed(&s_ih, p_s_path)) { |
| 213 | /* re-search indirect item */ | 213 | /* re-search indirect item */ |
| 214 | if (search_for_position_by_key(p_s_sb, p_s_item_key, p_s_path) | 214 | if (search_for_position_by_key(sb, p_s_item_key, p_s_path) |
| 215 | == POSITION_NOT_FOUND) | 215 | == POSITION_NOT_FOUND) |
| 216 | reiserfs_panic(p_s_sb, "PAP-5520", | 216 | reiserfs_panic(sb, "PAP-5520", |
| 217 | "item to be converted %K does not exist", | 217 | "item to be converted %K does not exist", |
| 218 | p_s_item_key); | 218 | p_s_item_key); |
| 219 | copy_item_head(&s_ih, PATH_PITEM_HEAD(p_s_path)); | 219 | copy_item_head(&s_ih, PATH_PITEM_HEAD(p_s_path)); |
| 220 | #ifdef CONFIG_REISERFS_CHECK | 220 | #ifdef CONFIG_REISERFS_CHECK |
| 221 | pos = le_ih_k_offset(&s_ih) - 1 + | 221 | pos = le_ih_k_offset(&s_ih) - 1 + |
| 222 | (ih_item_len(&s_ih) / UNFM_P_SIZE - | 222 | (ih_item_len(&s_ih) / UNFM_P_SIZE - |
| 223 | 1) * p_s_sb->s_blocksize; | 223 | 1) * sb->s_blocksize; |
| 224 | if (pos != pos1) | 224 | if (pos != pos1) |
| 225 | reiserfs_panic(p_s_sb, "vs-5530", "tail position " | 225 | reiserfs_panic(sb, "vs-5530", "tail position " |
| 226 | "changed while we were reading it"); | 226 | "changed while we were reading it"); |
| 227 | #endif | 227 | #endif |
| 228 | } | 228 | } |
diff --git a/include/linux/reiserfs_fs.h b/include/linux/reiserfs_fs.h index eb4e912e6bd3..9bd7800d989c 100644 --- a/include/linux/reiserfs_fs.h +++ b/include/linux/reiserfs_fs.h | |||
| @@ -1769,12 +1769,12 @@ int journal_end_sync(struct reiserfs_transaction_handle *, struct super_block *, | |||
| 1769 | int journal_mark_freed(struct reiserfs_transaction_handle *, | 1769 | int journal_mark_freed(struct reiserfs_transaction_handle *, |
| 1770 | struct super_block *, b_blocknr_t blocknr); | 1770 | struct super_block *, b_blocknr_t blocknr); |
| 1771 | int journal_transaction_should_end(struct reiserfs_transaction_handle *, int); | 1771 | int journal_transaction_should_end(struct reiserfs_transaction_handle *, int); |
| 1772 | int reiserfs_in_journal(struct super_block *p_s_sb, unsigned int bmap_nr, | 1772 | int reiserfs_in_journal(struct super_block *sb, unsigned int bmap_nr, |
| 1773 | int bit_nr, int searchall, b_blocknr_t *next); | 1773 | int bit_nr, int searchall, b_blocknr_t *next); |
| 1774 | int journal_begin(struct reiserfs_transaction_handle *, | 1774 | int journal_begin(struct reiserfs_transaction_handle *, |
| 1775 | struct super_block *p_s_sb, unsigned long); | 1775 | struct super_block *sb, unsigned long); |
| 1776 | int journal_join_abort(struct reiserfs_transaction_handle *, | 1776 | int journal_join_abort(struct reiserfs_transaction_handle *, |
| 1777 | struct super_block *p_s_sb, unsigned long); | 1777 | struct super_block *sb, unsigned long); |
| 1778 | void reiserfs_abort_journal(struct super_block *sb, int errno); | 1778 | void reiserfs_abort_journal(struct super_block *sb, int errno); |
| 1779 | void reiserfs_abort(struct super_block *sb, int errno, const char *fmt, ...); | 1779 | void reiserfs_abort(struct super_block *sb, int errno, const char *fmt, ...); |
| 1780 | int reiserfs_allocate_list_bitmaps(struct super_block *s, | 1780 | int reiserfs_allocate_list_bitmaps(struct super_block *s, |
| @@ -1830,11 +1830,11 @@ static inline void copy_key(struct reiserfs_key *to, | |||
| 1830 | 1830 | ||
| 1831 | int comp_items(const struct item_head *stored_ih, const struct treepath *p_s_path); | 1831 | int comp_items(const struct item_head *stored_ih, const struct treepath *p_s_path); |
| 1832 | const struct reiserfs_key *get_rkey(const struct treepath *p_s_chk_path, | 1832 | const struct reiserfs_key *get_rkey(const struct treepath *p_s_chk_path, |
| 1833 | const struct super_block *p_s_sb); | 1833 | const struct super_block *sb); |
| 1834 | int search_by_key(struct super_block *, const struct cpu_key *, | 1834 | int search_by_key(struct super_block *, const struct cpu_key *, |
| 1835 | struct treepath *, int); | 1835 | struct treepath *, int); |
| 1836 | #define search_item(s,key,path) search_by_key (s, key, path, DISK_LEAF_NODE_LEVEL) | 1836 | #define search_item(s,key,path) search_by_key (s, key, path, DISK_LEAF_NODE_LEVEL) |
| 1837 | int search_for_position_by_key(struct super_block *p_s_sb, | 1837 | int search_for_position_by_key(struct super_block *sb, |
| 1838 | const struct cpu_key *p_s_cpu_key, | 1838 | const struct cpu_key *p_s_cpu_key, |
| 1839 | struct treepath *p_s_search_path); | 1839 | struct treepath *p_s_search_path); |
| 1840 | extern void decrement_bcount(struct buffer_head *p_s_bh); | 1840 | extern void decrement_bcount(struct buffer_head *p_s_bh); |
| @@ -1978,7 +1978,7 @@ int reiserfs_global_version_in_proc(char *buffer, char **start, off_t offset, | |||
| 1978 | #define PROC_INFO_MAX( sb, field, value ) VOID_V | 1978 | #define PROC_INFO_MAX( sb, field, value ) VOID_V |
| 1979 | #define PROC_INFO_INC( sb, field ) VOID_V | 1979 | #define PROC_INFO_INC( sb, field ) VOID_V |
| 1980 | #define PROC_INFO_ADD( sb, field, val ) VOID_V | 1980 | #define PROC_INFO_ADD( sb, field, val ) VOID_V |
| 1981 | #define PROC_INFO_BH_STAT( p_s_sb, p_s_bh, n_node_level ) VOID_V | 1981 | #define PROC_INFO_BH_STAT(sb, p_s_bh, n_node_level) VOID_V |
| 1982 | #endif | 1982 | #endif |
| 1983 | 1983 | ||
| 1984 | /* dir.c */ | 1984 | /* dir.c */ |
