blob: 031270ad55e2208768cf27cff5e5f40e924bccf7 [file] [log] [blame]
David Teiglandb3b94fa2006-01-16 16:50:04 +00001/*
2 * Copyright (C) Sistina Software, Inc. 1997-2003 All rights reserved.
Steven Whitehouse3a8a9a12006-05-18 15:09:15 -04003 * Copyright (C) 2004-2006 Red Hat, Inc. All rights reserved.
David Teiglandb3b94fa2006-01-16 16:50:04 +00004 *
5 * This copyrighted material is made available to anyone wishing to use,
6 * modify, copy, or redistribute it subject to the terms and conditions
7 * of the GNU General Public License v.2.
8 */
9
10#include <linux/sched.h>
11#include <linux/slab.h>
12#include <linux/spinlock.h>
13#include <linux/completion.h>
14#include <linux/buffer_head.h>
15#include <linux/pagemap.h>
Steven Whitehousefd88de562006-05-05 16:59:11 -040016#include <linux/pagevec.h>
Steven Whitehouse9b124fb2006-01-30 11:55:32 +000017#include <linux/mpage.h>
Steven Whitehoused1665e42006-02-14 11:54:42 +000018#include <linux/fs.h>
Steven Whitehouse5c676f62006-02-27 17:23:27 -050019#include <linux/gfs2_ondisk.h>
David Teiglandb3b94fa2006-01-16 16:50:04 +000020
21#include "gfs2.h"
Steven Whitehouse5c676f62006-02-27 17:23:27 -050022#include "lm_interface.h"
23#include "incore.h"
David Teiglandb3b94fa2006-01-16 16:50:04 +000024#include "bmap.h"
25#include "glock.h"
26#include "inode.h"
David Teiglandb3b94fa2006-01-16 16:50:04 +000027#include "log.h"
28#include "meta_io.h"
29#include "ops_address.h"
30#include "page.h"
31#include "quota.h"
32#include "trans.h"
Steven Whitehouse18ec7d52006-02-08 11:50:51 +000033#include "rgrp.h"
Steven Whitehouse61a30dc2006-02-15 10:15:18 +000034#include "ops_file.h"
Steven Whitehouse5c676f62006-02-27 17:23:27 -050035#include "util.h"
Steven Whitehouse4340fe62006-07-11 09:46:33 -040036#include "glops.h"
David Teiglandb3b94fa2006-01-16 16:50:04 +000037
38/**
Steven Whitehouse4ff14672006-01-30 09:39:10 +000039 * gfs2_get_block - Fills in a buffer head with details about a block
David Teiglandb3b94fa2006-01-16 16:50:04 +000040 * @inode: The inode
41 * @lblock: The block number to look up
42 * @bh_result: The buffer head to return the result in
43 * @create: Non-zero if we may add block to the file
44 *
45 * Returns: errno
46 */
47
Steven Whitehouse4ff14672006-01-30 09:39:10 +000048int gfs2_get_block(struct inode *inode, sector_t lblock,
49 struct buffer_head *bh_result, int create)
David Teiglandb3b94fa2006-01-16 16:50:04 +000050{
David Teiglandb3b94fa2006-01-16 16:50:04 +000051 int new = create;
52 uint64_t dblock;
53 int error;
Steven Whitehousefd88de562006-05-05 16:59:11 -040054 int boundary;
David Teiglandb3b94fa2006-01-16 16:50:04 +000055
Steven Whitehousefd88de562006-05-05 16:59:11 -040056 error = gfs2_block_map(inode, lblock, &new, &dblock, &boundary);
David Teiglandb3b94fa2006-01-16 16:50:04 +000057 if (error)
58 return error;
59
60 if (!dblock)
61 return 0;
62
63 map_bh(bh_result, inode->i_sb, dblock);
64 if (new)
65 set_buffer_new(bh_result);
Steven Whitehousefd88de562006-05-05 16:59:11 -040066 if (boundary)
67 set_buffer_boundary(bh_result);
David Teiglandb3b94fa2006-01-16 16:50:04 +000068
69 return 0;
70}
71
72/**
73 * get_block_noalloc - Fills in a buffer head with details about a block
74 * @inode: The inode
75 * @lblock: The block number to look up
76 * @bh_result: The buffer head to return the result in
77 * @create: Non-zero if we may add block to the file
78 *
79 * Returns: errno
80 */
81
82static int get_block_noalloc(struct inode *inode, sector_t lblock,
83 struct buffer_head *bh_result, int create)
84{
David Teiglandb3b94fa2006-01-16 16:50:04 +000085 int new = 0;
86 uint64_t dblock;
87 int error;
Steven Whitehousefd88de562006-05-05 16:59:11 -040088 int boundary;
David Teiglandb3b94fa2006-01-16 16:50:04 +000089
Steven Whitehousefd88de562006-05-05 16:59:11 -040090 error = gfs2_block_map(inode, lblock, &new, &dblock, &boundary);
David Teiglandb3b94fa2006-01-16 16:50:04 +000091 if (error)
92 return error;
93
94 if (dblock)
95 map_bh(bh_result, inode->i_sb, dblock);
Steven Whitehousefeaa7bb2006-06-14 15:32:57 -040096 else if (gfs2_assert_withdraw(GFS2_SB(inode), !create))
David Teiglandb3b94fa2006-01-16 16:50:04 +000097 error = -EIO;
Steven Whitehousefd88de562006-05-05 16:59:11 -040098 if (boundary)
99 set_buffer_boundary(bh_result);
David Teiglandb3b94fa2006-01-16 16:50:04 +0000100
101 return error;
102}
103
David Teiglandb3b94fa2006-01-16 16:50:04 +0000104/**
105 * gfs2_writepage - Write complete page
106 * @page: Page to write
107 *
108 * Returns: errno
109 *
Steven Whitehouse18ec7d52006-02-08 11:50:51 +0000110 * Some of this is copied from block_write_full_page() although we still
111 * call it to do most of the work.
David Teiglandb3b94fa2006-01-16 16:50:04 +0000112 */
113
114static int gfs2_writepage(struct page *page, struct writeback_control *wbc)
115{
Steven Whitehouse18ec7d52006-02-08 11:50:51 +0000116 struct inode *inode = page->mapping->host;
Steven Whitehousefeaa7bb2006-06-14 15:32:57 -0400117 struct gfs2_inode *ip = GFS2_I(page->mapping->host);
118 struct gfs2_sbd *sdp = GFS2_SB(page->mapping->host);
Steven Whitehouse18ec7d52006-02-08 11:50:51 +0000119 loff_t i_size = i_size_read(inode);
120 pgoff_t end_index = i_size >> PAGE_CACHE_SHIFT;
121 unsigned offset;
David Teiglandb3b94fa2006-01-16 16:50:04 +0000122 int error;
Steven Whitehouse18ec7d52006-02-08 11:50:51 +0000123 int done_trans = 0;
David Teiglandb3b94fa2006-01-16 16:50:04 +0000124
David Teiglandb3b94fa2006-01-16 16:50:04 +0000125 if (gfs2_assert_withdraw(sdp, gfs2_glock_is_held_excl(ip->i_gl))) {
126 unlock_page(page);
127 return -EIO;
128 }
Steven Whitehouse5c676f62006-02-27 17:23:27 -0500129 if (current->journal_info)
Steven Whitehouse18ec7d52006-02-08 11:50:51 +0000130 goto out_ignore;
131
132 /* Is the page fully outside i_size? (truncate in progress) */
133 offset = i_size & (PAGE_CACHE_SIZE-1);
Steven Whitehoused2d7b8a2006-05-02 12:09:42 -0400134 if (page->index > end_index || (page->index == end_index && !offset)) {
Steven Whitehouse18ec7d52006-02-08 11:50:51 +0000135 page->mapping->a_ops->invalidatepage(page, 0);
David Teiglandb3b94fa2006-01-16 16:50:04 +0000136 unlock_page(page);
Steven Whitehouse18ec7d52006-02-08 11:50:51 +0000137 return 0; /* don't care */
138 }
139
140 if (sdp->sd_args.ar_data == GFS2_DATA_ORDERED || gfs2_is_jdata(ip)) {
141 error = gfs2_trans_begin(sdp, RES_DINODE + 1, 0);
142 if (error)
143 goto out_ignore;
144 gfs2_page_add_databufs(ip, page, 0, sdp->sd_vfs->s_blocksize-1);
145 done_trans = 1;
David Teiglandb3b94fa2006-01-16 16:50:04 +0000146 }
David Teiglandb3b94fa2006-01-16 16:50:04 +0000147 error = block_write_full_page(page, get_block_noalloc, wbc);
Steven Whitehouse18ec7d52006-02-08 11:50:51 +0000148 if (done_trans)
149 gfs2_trans_end(sdp);
David Teiglandb3b94fa2006-01-16 16:50:04 +0000150 gfs2_meta_cache_flush(ip);
David Teiglandb3b94fa2006-01-16 16:50:04 +0000151 return error;
Steven Whitehouse18ec7d52006-02-08 11:50:51 +0000152
153out_ignore:
154 redirty_page_for_writepage(wbc, page);
155 unlock_page(page);
156 return 0;
David Teiglandb3b94fa2006-01-16 16:50:04 +0000157}
158
Steven Whitehousefd88de562006-05-05 16:59:11 -0400159static int zero_readpage(struct page *page)
160{
161 void *kaddr;
162
163 kaddr = kmap_atomic(page, KM_USER0);
164 memset(kaddr, 0, PAGE_CACHE_SIZE);
165 kunmap_atomic(page, KM_USER0);
166
167 SetPageUptodate(page);
168
169 return 0;
170}
171
David Teiglandb3b94fa2006-01-16 16:50:04 +0000172/**
173 * stuffed_readpage - Fill in a Linux page with stuffed file data
174 * @ip: the inode
175 * @page: the page
176 *
177 * Returns: errno
178 */
179
180static int stuffed_readpage(struct gfs2_inode *ip, struct page *page)
181{
182 struct buffer_head *dibh;
183 void *kaddr;
184 int error;
185
Steven Whitehousefd88de562006-05-05 16:59:11 -0400186 /* Only the first page of a stuffed file might contain data */
187 if (unlikely(page->index))
188 return zero_readpage(page);
189
David Teiglandb3b94fa2006-01-16 16:50:04 +0000190 error = gfs2_meta_inode_buffer(ip, &dibh);
191 if (error)
192 return error;
193
Steven Whitehouse5c4e9e02006-02-15 12:26:19 +0000194 kaddr = kmap_atomic(page, KM_USER0);
Steven Whitehousefd88de562006-05-05 16:59:11 -0400195 memcpy(kaddr, dibh->b_data + sizeof(struct gfs2_dinode),
David Teiglandb3b94fa2006-01-16 16:50:04 +0000196 ip->i_di.di_size);
Steven Whitehousefd88de562006-05-05 16:59:11 -0400197 memset(kaddr + ip->i_di.di_size, 0, PAGE_CACHE_SIZE - ip->i_di.di_size);
Steven Whitehouse5c4e9e02006-02-15 12:26:19 +0000198 kunmap_atomic(page, KM_USER0);
David Teiglandb3b94fa2006-01-16 16:50:04 +0000199
200 brelse(dibh);
201
202 SetPageUptodate(page);
203
204 return 0;
205}
206
David Teiglandb3b94fa2006-01-16 16:50:04 +0000207
208/**
David Teiglandb3b94fa2006-01-16 16:50:04 +0000209 * gfs2_readpage - readpage with locking
Steven Whitehouse18ec7d52006-02-08 11:50:51 +0000210 * @file: The file to read a page for. N.B. This may be NULL if we are
211 * reading an internal file.
David Teiglandb3b94fa2006-01-16 16:50:04 +0000212 * @page: The page to read
213 *
214 * Returns: errno
215 */
216
217static int gfs2_readpage(struct file *file, struct page *page)
218{
Steven Whitehousefeaa7bb2006-06-14 15:32:57 -0400219 struct gfs2_inode *ip = GFS2_I(page->mapping->host);
220 struct gfs2_sbd *sdp = GFS2_SB(page->mapping->host);
Steven Whitehouse18ec7d52006-02-08 11:50:51 +0000221 struct gfs2_holder gh;
David Teiglandb3b94fa2006-01-16 16:50:04 +0000222 int error;
223
Steven Whitehousefd88de562006-05-05 16:59:11 -0400224 if (likely(file != &gfs2_internal_file_sentinal)) {
Steven Whitehousefe1bded2006-04-18 10:09:15 -0400225 gfs2_holder_init(ip->i_gl, LM_ST_SHARED, GL_ATIME|GL_AOP, &gh);
Steven Whitehouse61a30dc2006-02-15 10:15:18 +0000226 error = gfs2_glock_nq_m_atime(1, &gh);
Steven Whitehousefd88de562006-05-05 16:59:11 -0400227 if (unlikely(error))
Steven Whitehouse61a30dc2006-02-15 10:15:18 +0000228 goto out_unlock;
229 }
David Teiglandb3b94fa2006-01-16 16:50:04 +0000230
Steven Whitehouse18ec7d52006-02-08 11:50:51 +0000231 if (gfs2_is_stuffed(ip)) {
Steven Whitehousefd88de562006-05-05 16:59:11 -0400232 error = stuffed_readpage(ip, page);
233 unlock_page(page);
David Teiglandb3b94fa2006-01-16 16:50:04 +0000234 } else
Steven Whitehouse18ec7d52006-02-08 11:50:51 +0000235 error = mpage_readpage(page, gfs2_get_block);
David Teiglandb3b94fa2006-01-16 16:50:04 +0000236
237 if (unlikely(test_bit(SDF_SHUTDOWN, &sdp->sd_flags)))
238 error = -EIO;
239
Steven Whitehouse61a30dc2006-02-15 10:15:18 +0000240 if (file != &gfs2_internal_file_sentinal) {
241 gfs2_glock_dq_m(1, &gh);
242 gfs2_holder_uninit(&gh);
243 }
Steven Whitehouse18ec7d52006-02-08 11:50:51 +0000244out:
David Teiglandb3b94fa2006-01-16 16:50:04 +0000245 return error;
Steven Whitehouse18ec7d52006-02-08 11:50:51 +0000246out_unlock:
247 unlock_page(page);
Steven Whitehousefd88de562006-05-05 16:59:11 -0400248 if (file != &gfs2_internal_file_sentinal)
249 gfs2_holder_uninit(&gh);
250 goto out;
251}
252
Steven Whitehousefd88de562006-05-05 16:59:11 -0400253/**
254 * gfs2_readpages - Read a bunch of pages at once
255 *
256 * Some notes:
257 * 1. This is only for readahead, so we can simply ignore any things
258 * which are slightly inconvenient (such as locking conflicts between
259 * the page lock and the glock) and return having done no I/O. Its
260 * obviously not something we'd want to do on too regular a basis.
261 * Any I/O we ignore at this time will be done via readpage later.
262 * 2. We have to handle stuffed files here too.
263 * 3. mpage_readpages() does most of the heavy lifting in the common case.
264 * 4. gfs2_get_block() is relied upon to set BH_Boundary in the right places.
265 * 5. We use LM_FLAG_TRY_1CB here, effectively we then have lock-ahead as
266 * well as read-ahead.
267 */
268static int gfs2_readpages(struct file *file, struct address_space *mapping,
269 struct list_head *pages, unsigned nr_pages)
270{
271 struct inode *inode = mapping->host;
Steven Whitehousefeaa7bb2006-06-14 15:32:57 -0400272 struct gfs2_inode *ip = GFS2_I(inode);
273 struct gfs2_sbd *sdp = GFS2_SB(inode);
Steven Whitehousefd88de562006-05-05 16:59:11 -0400274 struct gfs2_holder gh;
275 unsigned page_idx;
276 int ret;
277
278 if (likely(file != &gfs2_internal_file_sentinal)) {
279 gfs2_holder_init(ip->i_gl, LM_ST_SHARED,
280 LM_FLAG_TRY_1CB|GL_ATIME|GL_AOP, &gh);
281 ret = gfs2_glock_nq_m_atime(1, &gh);
282 if (ret == GLR_TRYFAILED)
283 goto out_noerror;
284 if (unlikely(ret))
285 goto out_unlock;
286 }
287
288 if (gfs2_is_stuffed(ip)) {
289 struct pagevec lru_pvec;
290 pagevec_init(&lru_pvec, 0);
291 for (page_idx = 0; page_idx < nr_pages; page_idx++) {
Steven Whitehouseffeb8742006-07-10 15:47:01 -0400292 struct page *page = list_entry(pages->prev, struct page, lru);
293 prefetchw(&page->flags);
Steven Whitehousefd88de562006-05-05 16:59:11 -0400294 list_del(&page->lru);
295 if (!add_to_page_cache(page, mapping,
296 page->index, GFP_KERNEL)) {
297 ret = stuffed_readpage(ip, page);
298 unlock_page(page);
299 if (!pagevec_add(&lru_pvec, page))
300 __pagevec_lru_add(&lru_pvec);
Steven Whitehouseffeb8742006-07-10 15:47:01 -0400301 } else {
302 page_cache_release(page);
Steven Whitehousefd88de562006-05-05 16:59:11 -0400303 }
Steven Whitehousefd88de562006-05-05 16:59:11 -0400304 }
305 pagevec_lru_add(&lru_pvec);
306 ret = 0;
307 } else {
308 /* What we really want to do .... */
309 ret = mpage_readpages(mapping, pages, nr_pages, gfs2_get_block);
310 }
311
312 if (likely(file != &gfs2_internal_file_sentinal)) {
313 gfs2_glock_dq_m(1, &gh);
314 gfs2_holder_uninit(&gh);
315 }
316out:
317 if (unlikely(test_bit(SDF_SHUTDOWN, &sdp->sd_flags)))
318 ret = -EIO;
319 return ret;
320out_noerror:
321 ret = 0;
322out_unlock:
323 /* unlock all pages, we can't do any I/O right now */
324 for (page_idx = 0; page_idx < nr_pages; page_idx++) {
Steven Whitehouseffeb8742006-07-10 15:47:01 -0400325 struct page *page = list_entry(pages->prev, struct page, lru);
Steven Whitehousefd88de562006-05-05 16:59:11 -0400326 list_del(&page->lru);
327 unlock_page(page);
328 page_cache_release(page);
329 }
330 if (likely(file != &gfs2_internal_file_sentinal))
331 gfs2_holder_uninit(&gh);
Steven Whitehouse18ec7d52006-02-08 11:50:51 +0000332 goto out;
David Teiglandb3b94fa2006-01-16 16:50:04 +0000333}
334
335/**
336 * gfs2_prepare_write - Prepare to write a page to a file
337 * @file: The file to write to
338 * @page: The page which is to be prepared for writing
339 * @from: From (byte range within page)
340 * @to: To (byte range within page)
341 *
342 * Returns: errno
343 */
344
345static int gfs2_prepare_write(struct file *file, struct page *page,
346 unsigned from, unsigned to)
347{
Steven Whitehousefeaa7bb2006-06-14 15:32:57 -0400348 struct gfs2_inode *ip = GFS2_I(page->mapping->host);
349 struct gfs2_sbd *sdp = GFS2_SB(page->mapping->host);
Steven Whitehouse18ec7d52006-02-08 11:50:51 +0000350 unsigned int data_blocks, ind_blocks, rblocks;
351 int alloc_required;
David Teiglandb3b94fa2006-01-16 16:50:04 +0000352 int error = 0;
Steven Whitehouse18ec7d52006-02-08 11:50:51 +0000353 loff_t pos = ((loff_t)page->index << PAGE_CACHE_SHIFT) + from;
354 loff_t end = ((loff_t)page->index << PAGE_CACHE_SHIFT) + to;
355 struct gfs2_alloc *al;
David Teiglandb3b94fa2006-01-16 16:50:04 +0000356
Steven Whitehousefe1bded2006-04-18 10:09:15 -0400357 gfs2_holder_init(ip->i_gl, LM_ST_EXCLUSIVE, GL_ATIME|GL_AOP, &ip->i_gh);
Steven Whitehouse18ec7d52006-02-08 11:50:51 +0000358 error = gfs2_glock_nq_m_atime(1, &ip->i_gh);
359 if (error)
360 goto out_uninit;
361
362 gfs2_write_calc_reserv(ip, to - from, &data_blocks, &ind_blocks);
363
364 error = gfs2_write_alloc_required(ip, pos, from - to, &alloc_required);
365 if (error)
366 goto out_unlock;
367
368
369 if (alloc_required) {
370 al = gfs2_alloc_get(ip);
371
372 error = gfs2_quota_lock(ip, NO_QUOTA_CHANGE, NO_QUOTA_CHANGE);
373 if (error)
374 goto out_alloc_put;
375
376 error = gfs2_quota_check(ip, ip->i_di.di_uid, ip->i_di.di_gid);
377 if (error)
378 goto out_qunlock;
379
380 al->al_requested = data_blocks + ind_blocks;
381 error = gfs2_inplace_reserve(ip);
382 if (error)
383 goto out_qunlock;
384 }
385
386 rblocks = RES_DINODE + ind_blocks;
387 if (gfs2_is_jdata(ip))
388 rblocks += data_blocks ? data_blocks : 1;
389 if (ind_blocks || data_blocks)
390 rblocks += RES_STATFS + RES_QUOTA;
391
392 error = gfs2_trans_begin(sdp, rblocks, 0);
393 if (error)
394 goto out;
David Teiglandb3b94fa2006-01-16 16:50:04 +0000395
396 if (gfs2_is_stuffed(ip)) {
Steven Whitehouse18ec7d52006-02-08 11:50:51 +0000397 if (end > sdp->sd_sb.sb_bsize - sizeof(struct gfs2_dinode)) {
Steven Whitehouse568f4c92006-02-27 12:00:42 -0500398 error = gfs2_unstuff_dinode(ip, gfs2_unstuffer_page,
399 page);
Steven Whitehouse5c4e9e02006-02-15 12:26:19 +0000400 if (error == 0)
401 goto prepare_write;
402 } else if (!PageUptodate(page))
David Teiglandb3b94fa2006-01-16 16:50:04 +0000403 error = stuffed_readpage(ip, page);
Steven Whitehouse5c4e9e02006-02-15 12:26:19 +0000404 goto out;
Steven Whitehouse18ec7d52006-02-08 11:50:51 +0000405 }
406
Steven Whitehouse5c4e9e02006-02-15 12:26:19 +0000407prepare_write:
Steven Whitehouse18ec7d52006-02-08 11:50:51 +0000408 error = block_prepare_write(page, from, to, gfs2_get_block);
409
410out:
411 if (error) {
412 gfs2_trans_end(sdp);
413 if (alloc_required) {
414 gfs2_inplace_release(ip);
415out_qunlock:
416 gfs2_quota_unlock(ip);
417out_alloc_put:
418 gfs2_alloc_put(ip);
419 }
420out_unlock:
421 gfs2_glock_dq_m(1, &ip->i_gh);
422out_uninit:
423 gfs2_holder_uninit(&ip->i_gh);
424 }
David Teiglandb3b94fa2006-01-16 16:50:04 +0000425
426 return error;
427}
428
429/**
430 * gfs2_commit_write - Commit write to a file
431 * @file: The file to write to
432 * @page: The page containing the data
433 * @from: From (byte range within page)
434 * @to: To (byte range within page)
435 *
436 * Returns: errno
437 */
438
439static int gfs2_commit_write(struct file *file, struct page *page,
440 unsigned from, unsigned to)
441{
442 struct inode *inode = page->mapping->host;
Steven Whitehousefeaa7bb2006-06-14 15:32:57 -0400443 struct gfs2_inode *ip = GFS2_I(inode);
444 struct gfs2_sbd *sdp = GFS2_SB(inode);
Steven Whitehouse18ec7d52006-02-08 11:50:51 +0000445 int error = -EOPNOTSUPP;
446 struct buffer_head *dibh;
447 struct gfs2_alloc *al = &ip->i_alloc;;
David Teiglandb3b94fa2006-01-16 16:50:04 +0000448
Steven Whitehouse18ec7d52006-02-08 11:50:51 +0000449 if (gfs2_assert_withdraw(sdp, gfs2_glock_is_locked_by_me(ip->i_gl)))
450 goto fail_nounlock;
451
452 error = gfs2_meta_inode_buffer(ip, &dibh);
453 if (error)
454 goto fail_endtrans;
455
456 gfs2_trans_add_bh(ip->i_gl, dibh, 1);
457
David Teiglandb3b94fa2006-01-16 16:50:04 +0000458 if (gfs2_is_stuffed(ip)) {
David Teiglandb3b94fa2006-01-16 16:50:04 +0000459 uint64_t file_size;
460 void *kaddr;
461
462 file_size = ((uint64_t)page->index << PAGE_CACHE_SHIFT) + to;
463
Steven Whitehouse18ec7d52006-02-08 11:50:51 +0000464 kaddr = kmap_atomic(page, KM_USER0);
David Teiglandb3b94fa2006-01-16 16:50:04 +0000465 memcpy(dibh->b_data + sizeof(struct gfs2_dinode) + from,
Steven Whitehouse18ec7d52006-02-08 11:50:51 +0000466 (char *)kaddr + from, to - from);
467 kunmap_atomic(page, KM_USER0);
David Teiglandb3b94fa2006-01-16 16:50:04 +0000468
469 SetPageUptodate(page);
470
471 if (inode->i_size < file_size)
472 i_size_write(inode, file_size);
473 } else {
Steven Whitehouse568f4c92006-02-27 12:00:42 -0500474 if (sdp->sd_args.ar_data == GFS2_DATA_ORDERED ||
475 gfs2_is_jdata(ip))
Steven Whitehouse257f9b42006-01-31 10:00:25 +0000476 gfs2_page_add_databufs(ip, page, from, to);
David Teiglandb3b94fa2006-01-16 16:50:04 +0000477 error = generic_commit_write(file, page, from, to);
478 if (error)
479 goto fail;
480 }
481
Steven Whitehouse18ec7d52006-02-08 11:50:51 +0000482 if (ip->i_di.di_size < inode->i_size)
483 ip->i_di.di_size = inode->i_size;
484
485 gfs2_dinode_out(&ip->i_di, dibh->b_data);
486 brelse(dibh);
487 gfs2_trans_end(sdp);
488 if (al->al_requested) {
489 gfs2_inplace_release(ip);
490 gfs2_quota_unlock(ip);
491 gfs2_alloc_put(ip);
492 }
493 gfs2_glock_dq_m(1, &ip->i_gh);
494 gfs2_holder_uninit(&ip->i_gh);
David Teiglandb3b94fa2006-01-16 16:50:04 +0000495 return 0;
496
Steven Whitehouse18ec7d52006-02-08 11:50:51 +0000497fail:
498 brelse(dibh);
499fail_endtrans:
500 gfs2_trans_end(sdp);
501 if (al->al_requested) {
502 gfs2_inplace_release(ip);
503 gfs2_quota_unlock(ip);
504 gfs2_alloc_put(ip);
505 }
506 gfs2_glock_dq_m(1, &ip->i_gh);
507 gfs2_holder_uninit(&ip->i_gh);
508fail_nounlock:
David Teiglandb3b94fa2006-01-16 16:50:04 +0000509 ClearPageUptodate(page);
David Teiglandb3b94fa2006-01-16 16:50:04 +0000510 return error;
511}
512
513/**
514 * gfs2_bmap - Block map function
515 * @mapping: Address space info
516 * @lblock: The block to map
517 *
518 * Returns: The disk address for the block or 0 on hole or error
519 */
520
521static sector_t gfs2_bmap(struct address_space *mapping, sector_t lblock)
522{
Steven Whitehousefeaa7bb2006-06-14 15:32:57 -0400523 struct gfs2_inode *ip = GFS2_I(mapping->host);
David Teiglandb3b94fa2006-01-16 16:50:04 +0000524 struct gfs2_holder i_gh;
525 sector_t dblock = 0;
526 int error;
527
David Teiglandb3b94fa2006-01-16 16:50:04 +0000528 error = gfs2_glock_nq_init(ip->i_gl, LM_ST_SHARED, LM_FLAG_ANY, &i_gh);
529 if (error)
530 return 0;
531
532 if (!gfs2_is_stuffed(ip))
Steven Whitehouse4ff14672006-01-30 09:39:10 +0000533 dblock = generic_block_bmap(mapping, lblock, gfs2_get_block);
David Teiglandb3b94fa2006-01-16 16:50:04 +0000534
535 gfs2_glock_dq_uninit(&i_gh);
536
537 return dblock;
538}
539
540static void discard_buffer(struct gfs2_sbd *sdp, struct buffer_head *bh)
541{
Steven Whitehouse64fb4eb2006-01-18 13:14:40 +0000542 struct gfs2_bufdata *bd;
David Teiglandb3b94fa2006-01-16 16:50:04 +0000543
544 gfs2_log_lock(sdp);
Steven Whitehouse5c676f62006-02-27 17:23:27 -0500545 bd = bh->b_private;
Steven Whitehouse64fb4eb2006-01-18 13:14:40 +0000546 if (bd) {
547 bd->bd_bh = NULL;
Steven Whitehouse5c676f62006-02-27 17:23:27 -0500548 bh->b_private = NULL;
David Teiglandb3b94fa2006-01-16 16:50:04 +0000549 gfs2_log_unlock(sdp);
550 brelse(bh);
551 } else
552 gfs2_log_unlock(sdp);
553
554 lock_buffer(bh);
555 clear_buffer_dirty(bh);
556 bh->b_bdev = NULL;
557 clear_buffer_mapped(bh);
558 clear_buffer_req(bh);
559 clear_buffer_new(bh);
560 clear_buffer_delay(bh);
561 unlock_buffer(bh);
562}
563
Steven Whitehouse8628de02006-03-31 16:48:41 -0500564static void gfs2_invalidatepage(struct page *page, unsigned long offset)
David Teiglandb3b94fa2006-01-16 16:50:04 +0000565{
Steven Whitehouse5c676f62006-02-27 17:23:27 -0500566 struct gfs2_sbd *sdp = page->mapping->host->i_sb->s_fs_info;
David Teiglandb3b94fa2006-01-16 16:50:04 +0000567 struct buffer_head *head, *bh, *next;
568 unsigned int curr_off = 0;
David Teiglandb3b94fa2006-01-16 16:50:04 +0000569
570 BUG_ON(!PageLocked(page));
571 if (!page_has_buffers(page))
Steven Whitehouse8628de02006-03-31 16:48:41 -0500572 return;
David Teiglandb3b94fa2006-01-16 16:50:04 +0000573
574 bh = head = page_buffers(page);
575 do {
576 unsigned int next_off = curr_off + bh->b_size;
577 next = bh->b_this_page;
578
579 if (offset <= curr_off)
580 discard_buffer(sdp, bh);
581
582 curr_off = next_off;
583 bh = next;
584 } while (bh != head);
585
586 if (!offset)
Steven Whitehouse8628de02006-03-31 16:48:41 -0500587 try_to_release_page(page, 0);
David Teiglandb3b94fa2006-01-16 16:50:04 +0000588
Steven Whitehouse8628de02006-03-31 16:48:41 -0500589 return;
David Teiglandb3b94fa2006-01-16 16:50:04 +0000590}
591
Steven Whitehoused1665e42006-02-14 11:54:42 +0000592static ssize_t gfs2_direct_IO_write(struct kiocb *iocb, const struct iovec *iov,
593 loff_t offset, unsigned long nr_segs)
594{
595 struct file *file = iocb->ki_filp;
596 struct inode *inode = file->f_mapping->host;
Steven Whitehousefeaa7bb2006-06-14 15:32:57 -0400597 struct gfs2_inode *ip = GFS2_I(inode);
Steven Whitehoused1665e42006-02-14 11:54:42 +0000598 struct gfs2_holder gh;
599 int rv;
600
601 /*
602 * Shared lock, even though its write, since we do no allocation
603 * on this path. All we need change is atime.
604 */
605 gfs2_holder_init(ip->i_gl, LM_ST_SHARED, GL_ATIME, &gh);
606 rv = gfs2_glock_nq_m_atime(1, &gh);
607 if (rv)
608 goto out;
609
610 /*
611 * Should we return an error here? I can't see that O_DIRECT for
612 * a journaled file makes any sense. For now we'll silently fall
613 * back to buffered I/O, likewise we do the same for stuffed
614 * files since they are (a) small and (b) unaligned.
615 */
616 if (gfs2_is_jdata(ip))
617 goto out;
618
619 if (gfs2_is_stuffed(ip))
620 goto out;
621
622 rv = __blockdev_direct_IO(WRITE, iocb, inode, inode->i_sb->s_bdev,
Steven Whitehouse8628de02006-03-31 16:48:41 -0500623 iov, offset, nr_segs, gfs2_get_block,
Steven Whitehoused1665e42006-02-14 11:54:42 +0000624 NULL, DIO_OWN_LOCKING);
625out:
626 gfs2_glock_dq_m(1, &gh);
627 gfs2_holder_uninit(&gh);
628
629 return rv;
630}
631
632/**
633 * gfs2_direct_IO
634 *
635 * This is called with a shared lock already held for the read path.
636 * Currently, no locks are held when the write path is called.
637 */
638static ssize_t gfs2_direct_IO(int rw, struct kiocb *iocb,
639 const struct iovec *iov, loff_t offset,
640 unsigned long nr_segs)
David Teiglandb3b94fa2006-01-16 16:50:04 +0000641{
642 struct file *file = iocb->ki_filp;
643 struct inode *inode = file->f_mapping->host;
Steven Whitehousefeaa7bb2006-06-14 15:32:57 -0400644 struct gfs2_inode *ip = GFS2_I(inode);
645 struct gfs2_sbd *sdp = GFS2_SB(inode);
Steven Whitehousefaac9bd2006-07-05 08:24:34 -0400646 int ret;
David Teiglandb3b94fa2006-01-16 16:50:04 +0000647
Steven Whitehoused1665e42006-02-14 11:54:42 +0000648 if (rw == WRITE)
649 return gfs2_direct_IO_write(iocb, iov, offset, nr_segs);
650
651 if (gfs2_assert_warn(sdp, gfs2_glock_is_locked_by_me(ip->i_gl)) ||
652 gfs2_assert_warn(sdp, !gfs2_is_stuffed(ip)))
David Teiglandb3b94fa2006-01-16 16:50:04 +0000653 return -EINVAL;
654
Steven Whitehousefaac9bd2006-07-05 08:24:34 -0400655 mutex_lock(&inode->i_mutex);
656 ret = __blockdev_direct_IO(READ, iocb, inode, inode->i_sb->s_bdev, iov,
657 offset, nr_segs, gfs2_get_block, NULL,
658 DIO_OWN_LOCKING);
659 mutex_unlock(&inode->i_mutex);
660 return ret;
David Teiglandb3b94fa2006-01-16 16:50:04 +0000661}
662
Steven Whitehouse4340fe62006-07-11 09:46:33 -0400663/**
664 * stuck_releasepage - We're stuck in gfs2_releasepage(). Print stuff out.
665 * @bh: the buffer we're stuck on
666 *
667 */
668
669static void stuck_releasepage(struct buffer_head *bh)
670{
671 struct inode *inode = bh->b_page->mapping->host;
672 struct gfs2_sbd *sdp = inode->i_sb->s_fs_info;
673 struct gfs2_bufdata *bd = bh->b_private;
674 struct gfs2_glock *gl;
675
676 fs_warn(sdp, "stuck in gfs2_releasepage() %p\n", inode);
677 fs_warn(sdp, "blkno = %llu, bh->b_count = %d\n",
678 (unsigned long long)bh->b_blocknr, atomic_read(&bh->b_count));
679 fs_warn(sdp, "pinned = %u\n", buffer_pinned(bh));
680 fs_warn(sdp, "bh->b_private = %s\n", (bd) ? "!NULL" : "NULL");
681
682 if (!bd)
683 return;
684
685 gl = bd->bd_gl;
686
687 fs_warn(sdp, "gl = (%u, %llu)\n",
688 gl->gl_name.ln_type, (unsigned long long)gl->gl_name.ln_number);
689
690 fs_warn(sdp, "bd_list_tr = %s, bd_le.le_list = %s\n",
691 (list_empty(&bd->bd_list_tr)) ? "no" : "yes",
692 (list_empty(&bd->bd_le.le_list)) ? "no" : "yes");
693
694 if (gl->gl_ops == &gfs2_inode_glops) {
695 struct gfs2_inode *ip = gl->gl_object;
696 unsigned int x;
697
698 if (!ip)
699 return;
700
701 fs_warn(sdp, "ip = %llu %llu\n",
702 (unsigned long long)ip->i_num.no_formal_ino,
703 (unsigned long long)ip->i_num.no_addr);
704
705 for (x = 0; x < GFS2_MAX_META_HEIGHT; x++)
706 fs_warn(sdp, "ip->i_cache[%u] = %s\n",
707 x, (ip->i_cache[x]) ? "!NULL" : "NULL");
708 }
709}
710
711/**
712 * gfs2_aspace_releasepage - free the metadata associated with a page
713 * @page: the page that's being released
714 * @gfp_mask: passed from Linux VFS, ignored by us
715 *
716 * Call try_to_free_buffers() if the buffers in this page can be
717 * released.
718 *
719 * Returns: 0
720 */
721
722int gfs2_releasepage(struct page *page, gfp_t gfp_mask)
723{
724 struct inode *aspace = page->mapping->host;
725 struct gfs2_sbd *sdp = aspace->i_sb->s_fs_info;
726 struct buffer_head *bh, *head;
727 struct gfs2_bufdata *bd;
728 unsigned long t;
729
730 if (!page_has_buffers(page))
731 goto out;
732
733 head = bh = page_buffers(page);
734 do {
735 t = jiffies;
736
737 while (atomic_read(&bh->b_count)) {
738 if (atomic_read(&aspace->i_writecount)) {
739 if (time_after_eq(jiffies, t +
740 gfs2_tune_get(sdp, gt_stall_secs) * HZ)) {
741 stuck_releasepage(bh);
742 t = jiffies;
743 }
744
745 yield();
746 continue;
747 }
748
749 return 0;
750 }
751
752 gfs2_assert_warn(sdp, !buffer_pinned(bh));
753
754 bd = bh->b_private;
755 if (bd) {
756 gfs2_assert_warn(sdp, bd->bd_bh == bh);
757 gfs2_assert_warn(sdp, list_empty(&bd->bd_list_tr));
758 gfs2_assert_warn(sdp, list_empty(&bd->bd_le.le_list));
759 gfs2_assert_warn(sdp, !bd->bd_ail);
760 kmem_cache_free(gfs2_bufdata_cachep, bd);
761 bh->b_private = NULL;
762 }
763
764 bh = bh->b_this_page;
765 }
766 while (bh != head);
767
768 out:
769 return try_to_free_buffers(page);
770}
771
Steven Whitehouse66de0452006-07-03 13:37:30 -0400772const struct address_space_operations gfs2_file_aops = {
David Teiglandb3b94fa2006-01-16 16:50:04 +0000773 .writepage = gfs2_writepage,
774 .readpage = gfs2_readpage,
Steven Whitehousefd88de562006-05-05 16:59:11 -0400775 .readpages = gfs2_readpages,
David Teiglandb3b94fa2006-01-16 16:50:04 +0000776 .sync_page = block_sync_page,
777 .prepare_write = gfs2_prepare_write,
778 .commit_write = gfs2_commit_write,
779 .bmap = gfs2_bmap,
780 .invalidatepage = gfs2_invalidatepage,
Steven Whitehouse4340fe62006-07-11 09:46:33 -0400781 .releasepage = gfs2_releasepage,
David Teiglandb3b94fa2006-01-16 16:50:04 +0000782 .direct_IO = gfs2_direct_IO,
783};
784