1 /* 2 * Copyright 2000 by Hans Reiser, licensing governed by reiserfs/README 3 */ 4 5 #include <linux/time.h> 6 #include "reiserfs.h" 7 #include "acl.h" 8 #include "xattr.h" 9 #include <asm/uaccess.h> 10 #include <linux/pagemap.h> 11 #include <linux/swap.h> 12 #include <linux/writeback.h> 13 #include <linux/blkdev.h> 14 #include <linux/buffer_head.h> 15 #include <linux/quotaops.h> 16 17 /* 18 ** We pack the tails of files on file close, not at the time they are written. 19 ** This implies an unnecessary copy of the tail and an unnecessary indirect item 20 ** insertion/balancing, for files that are written in one write. 21 ** It avoids unnecessary tail packings (balances) for files that are written in 22 ** multiple writes and are small enough to have tails. 23 ** 24 ** file_release is called by the VFS layer when the file is closed. If 25 ** this is the last open file descriptor, and the file 26 ** small enough to have a tail, and the tail is currently in an 27 ** unformatted node, the tail is converted back into a direct item. 28 ** 29 ** We use reiserfs_truncate_file to pack the tail, since it already has 30 ** all the conditions coded. 31 */ 32 static int reiserfs_file_release(struct inode *inode, struct file *filp) 33 { 34 35 struct reiserfs_transaction_handle th; 36 int err; 37 int jbegin_failure = 0; 38 39 BUG_ON(!S_ISREG(inode->i_mode)); 40 41 if (atomic_add_unless(&REISERFS_I(inode)->openers, -1, 1)) 42 return 0; 43 44 mutex_lock(&(REISERFS_I(inode)->tailpack)); 45 46 if (!atomic_dec_and_test(&REISERFS_I(inode)->openers)) { 47 mutex_unlock(&(REISERFS_I(inode)->tailpack)); 48 return 0; 49 } 50 51 /* fast out for when nothing needs to be done */ 52 if ((!(REISERFS_I(inode)->i_flags & i_pack_on_close_mask) || 53 !tail_has_to_be_packed(inode)) && 54 REISERFS_I(inode)->i_prealloc_count <= 0) { 55 mutex_unlock(&(REISERFS_I(inode)->tailpack)); 56 return 0; 57 } 58 59 reiserfs_write_lock(inode->i_sb); 60 /* freeing preallocation only involves relogging blocks that 61 * are already in the current transaction. preallocation gets 62 * freed at the end of each transaction, so it is impossible for 63 * us to log any additional blocks (including quota blocks) 64 */ 65 err = journal_begin(&th, inode->i_sb, 1); 66 if (err) { 67 /* uh oh, we can't allow the inode to go away while there 68 * is still preallocation blocks pending. Try to join the 69 * aborted transaction 70 */ 71 jbegin_failure = err; 72 err = journal_join_abort(&th, inode->i_sb, 1); 73 74 if (err) { 75 /* hmpf, our choices here aren't good. We can pin the inode 76 * which will disallow unmount from every happening, we can 77 * do nothing, which will corrupt random memory on unmount, 78 * or we can forcibly remove the file from the preallocation 79 * list, which will leak blocks on disk. Lets pin the inode 80 * and let the admin know what is going on. 81 */ 82 igrab(inode); 83 reiserfs_warning(inode->i_sb, "clm-9001", 84 "pinning inode %lu because the " 85 "preallocation can't be freed", 86 inode->i_ino); 87 goto out; 88 } 89 } 90 reiserfs_update_inode_transaction(inode); 91 92 #ifdef REISERFS_PREALLOCATE 93 reiserfs_discard_prealloc(&th, inode); 94 #endif 95 err = journal_end(&th, inode->i_sb, 1); 96 97 /* copy back the error code from journal_begin */ 98 if (!err) 99 err = jbegin_failure; 100 101 if (!err && 102 (REISERFS_I(inode)->i_flags & i_pack_on_close_mask) && 103 tail_has_to_be_packed(inode)) { 104 105 /* if regular file is released by last holder and it has been 106 appended (we append by unformatted node only) or its direct 107 item(s) had to be converted, then it may have to be 108 indirect2direct converted */ 109 err = reiserfs_truncate_file(inode, 0); 110 } 111 out: 112 reiserfs_write_unlock(inode->i_sb); 113 mutex_unlock(&(REISERFS_I(inode)->tailpack)); 114 return err; 115 } 116 117 static int reiserfs_file_open(struct inode *inode, struct file *file) 118 { 119 int err = dquot_file_open(inode, file); 120 if (!atomic_inc_not_zero(&REISERFS_I(inode)->openers)) { 121 /* somebody might be tailpacking on final close; wait for it */ 122 mutex_lock(&(REISERFS_I(inode)->tailpack)); 123 atomic_inc(&REISERFS_I(inode)->openers); 124 mutex_unlock(&(REISERFS_I(inode)->tailpack)); 125 } 126 return err; 127 } 128 129 void reiserfs_vfs_truncate_file(struct inode *inode) 130 { 131 mutex_lock(&(REISERFS_I(inode)->tailpack)); 132 reiserfs_truncate_file(inode, 1); 133 mutex_unlock(&(REISERFS_I(inode)->tailpack)); 134 } 135 136 /* Sync a reiserfs file. */ 137 138 /* 139 * FIXME: sync_mapping_buffers() never has anything to sync. Can 140 * be removed... 141 */ 142 143 static int reiserfs_sync_file(struct file *filp, loff_t start, loff_t end, 144 int datasync) 145 { 146 struct inode *inode = filp->f_mapping->host; 147 int err; 148 int barrier_done; 149 150 err = filemap_write_and_wait_range(inode->i_mapping, start, end); 151 if (err) 152 return err; 153 154 mutex_lock(&inode->i_mutex); 155 BUG_ON(!S_ISREG(inode->i_mode)); 156 err = sync_mapping_buffers(inode->i_mapping); 157 reiserfs_write_lock(inode->i_sb); 158 barrier_done = reiserfs_commit_for_inode(inode); 159 reiserfs_write_unlock(inode->i_sb); 160 if (barrier_done != 1 && reiserfs_barrier_flush(inode->i_sb)) 161 blkdev_issue_flush(inode->i_sb->s_bdev, GFP_KERNEL, NULL); 162 mutex_unlock(&inode->i_mutex); 163 if (barrier_done < 0) 164 return barrier_done; 165 return (err < 0) ? -EIO : 0; 166 } 167 168 /* taken fs/buffer.c:__block_commit_write */ 169 int reiserfs_commit_page(struct inode *inode, struct page *page, 170 unsigned from, unsigned to) 171 { 172 unsigned block_start, block_end; 173 int partial = 0; 174 unsigned blocksize; 175 struct buffer_head *bh, *head; 176 unsigned long i_size_index = inode->i_size >> PAGE_CACHE_SHIFT; 177 int new; 178 int logit = reiserfs_file_data_log(inode); 179 struct super_block *s = inode->i_sb; 180 int bh_per_page = PAGE_CACHE_SIZE / s->s_blocksize; 181 struct reiserfs_transaction_handle th; 182 int ret = 0; 183 184 th.t_trans_id = 0; 185 blocksize = 1 << inode->i_blkbits; 186 187 if (logit) { 188 reiserfs_write_lock(s); 189 ret = journal_begin(&th, s, bh_per_page + 1); 190 if (ret) 191 goto drop_write_lock; 192 reiserfs_update_inode_transaction(inode); 193 } 194 for (bh = head = page_buffers(page), block_start = 0; 195 bh != head || !block_start; 196 block_start = block_end, bh = bh->b_this_page) { 197 198 new = buffer_new(bh); 199 clear_buffer_new(bh); 200 block_end = block_start + blocksize; 201 if (block_end <= from || block_start >= to) { 202 if (!buffer_uptodate(bh)) 203 partial = 1; 204 } else { 205 set_buffer_uptodate(bh); 206 if (logit) { 207 reiserfs_prepare_for_journal(s, bh, 1); 208 journal_mark_dirty(&th, s, bh); 209 } else if (!buffer_dirty(bh)) { 210 mark_buffer_dirty(bh); 211 /* do data=ordered on any page past the end 212 * of file and any buffer marked BH_New. 213 */ 214 if (reiserfs_data_ordered(inode->i_sb) && 215 (new || page->index >= i_size_index)) { 216 reiserfs_add_ordered_list(inode, bh); 217 } 218 } 219 } 220 } 221 if (logit) { 222 ret = journal_end(&th, s, bh_per_page + 1); 223 drop_write_lock: 224 reiserfs_write_unlock(s); 225 } 226 /* 227 * If this is a partial write which happened to make all buffers 228 * uptodate then we can optimize away a bogus readpage() for 229 * the next read(). Here we 'discover' whether the page went 230 * uptodate as a result of this (potentially partial) write. 231 */ 232 if (!partial) 233 SetPageUptodate(page); 234 return ret; 235 } 236 237 const struct file_operations reiserfs_file_operations = { 238 .read = do_sync_read, 239 .write = do_sync_write, 240 .unlocked_ioctl = reiserfs_ioctl, 241 #ifdef CONFIG_COMPAT 242 .compat_ioctl = reiserfs_compat_ioctl, 243 #endif 244 .mmap = generic_file_mmap, 245 .open = reiserfs_file_open, 246 .release = reiserfs_file_release, 247 .fsync = reiserfs_sync_file, 248 .aio_read = generic_file_aio_read, 249 .aio_write = generic_file_aio_write, 250 .splice_read = generic_file_splice_read, 251 .splice_write = generic_file_splice_write, 252 .llseek = generic_file_llseek, 253 }; 254 255 const struct inode_operations reiserfs_file_inode_operations = { 256 .setattr = reiserfs_setattr, 257 .setxattr = reiserfs_setxattr, 258 .getxattr = reiserfs_getxattr, 259 .listxattr = reiserfs_listxattr, 260 .removexattr = reiserfs_removexattr, 261 .permission = reiserfs_permission, 262 .get_acl = reiserfs_get_acl, 263 }; 264