aboutsummaryrefslogtreecommitdiffstats
path: root/fs/ocfs2/aops.c
diff options
context:
space:
mode:
Diffstat (limited to 'fs/ocfs2/aops.c')
-rw-r--r--fs/ocfs2/aops.c56
1 files changed, 41 insertions, 15 deletions
diff --git a/fs/ocfs2/aops.c b/fs/ocfs2/aops.c
index fc723fb9c981..b8869fd0884f 100644
--- a/fs/ocfs2/aops.c
+++ b/fs/ocfs2/aops.c
@@ -1034,7 +1034,8 @@ out:
1034 */ 1034 */
1035static int ocfs2_grab_pages_for_write(struct address_space *mapping, 1035static int ocfs2_grab_pages_for_write(struct address_space *mapping,
1036 struct ocfs2_write_ctxt *wc, 1036 struct ocfs2_write_ctxt *wc,
1037 u32 cpos, loff_t user_pos, int new) 1037 u32 cpos, loff_t user_pos, int new,
1038 struct page *mmap_page)
1038{ 1039{
1039 int ret = 0, i; 1040 int ret = 0, i;
1040 unsigned long start, target_index, index; 1041 unsigned long start, target_index, index;
@@ -1058,11 +1059,36 @@ static int ocfs2_grab_pages_for_write(struct address_space *mapping,
1058 for(i = 0; i < wc->w_num_pages; i++) { 1059 for(i = 0; i < wc->w_num_pages; i++) {
1059 index = start + i; 1060 index = start + i;
1060 1061
1061 wc->w_pages[i] = find_or_create_page(mapping, index, GFP_NOFS); 1062 if (index == target_index && mmap_page) {
1062 if (!wc->w_pages[i]) { 1063 /*
1063 ret = -ENOMEM; 1064 * ocfs2_pagemkwrite() is a little different
1064 mlog_errno(ret); 1065 * and wants us to directly use the page
1065 goto out; 1066 * passed in.
1067 */
1068 lock_page(mmap_page);
1069
1070 if (mmap_page->mapping != mapping) {
1071 unlock_page(mmap_page);
1072 /*
1073 * Sanity check - the locking in
1074 * ocfs2_pagemkwrite() should ensure
1075 * that this code doesn't trigger.
1076 */
1077 ret = -EINVAL;
1078 mlog_errno(ret);
1079 goto out;
1080 }
1081
1082 page_cache_get(mmap_page);
1083 wc->w_pages[i] = mmap_page;
1084 } else {
1085 wc->w_pages[i] = find_or_create_page(mapping, index,
1086 GFP_NOFS);
1087 if (!wc->w_pages[i]) {
1088 ret = -ENOMEM;
1089 mlog_errno(ret);
1090 goto out;
1091 }
1066 } 1092 }
1067 1093
1068 if (index == target_index) 1094 if (index == target_index)
@@ -1213,10 +1239,10 @@ static void ocfs2_set_target_boundaries(struct ocfs2_super *osb,
1213 } 1239 }
1214} 1240}
1215 1241
1216static int ocfs2_write_begin_nolock(struct address_space *mapping, 1242int ocfs2_write_begin_nolock(struct address_space *mapping,
1217 loff_t pos, unsigned len, unsigned flags, 1243 loff_t pos, unsigned len, unsigned flags,
1218 struct page **pagep, void **fsdata, 1244 struct page **pagep, void **fsdata,
1219 struct buffer_head *di_bh) 1245 struct buffer_head *di_bh, struct page *mmap_page)
1220{ 1246{
1221 int ret, i, credits = OCFS2_INODE_UPDATE_CREDITS; 1247 int ret, i, credits = OCFS2_INODE_UPDATE_CREDITS;
1222 unsigned int num_clusters = 0, clusters_to_alloc = 0; 1248 unsigned int num_clusters = 0, clusters_to_alloc = 0;
@@ -1318,7 +1344,7 @@ static int ocfs2_write_begin_nolock(struct address_space *mapping,
1318 * extent. 1344 * extent.
1319 */ 1345 */
1320 ret = ocfs2_grab_pages_for_write(mapping, wc, wc->w_cpos, pos, 1346 ret = ocfs2_grab_pages_for_write(mapping, wc, wc->w_cpos, pos,
1321 clusters_to_alloc); 1347 clusters_to_alloc, mmap_page);
1322 if (ret) { 1348 if (ret) {
1323 mlog_errno(ret); 1349 mlog_errno(ret);
1324 goto out_commit; 1350 goto out_commit;
@@ -1386,7 +1412,7 @@ int ocfs2_write_begin(struct file *file, struct address_space *mapping,
1386 } 1412 }
1387 1413
1388 ret = ocfs2_write_begin_nolock(mapping, pos, len, flags, pagep, 1414 ret = ocfs2_write_begin_nolock(mapping, pos, len, flags, pagep,
1389 fsdata, di_bh); 1415 fsdata, di_bh, NULL);
1390 if (ret) { 1416 if (ret) {
1391 mlog_errno(ret); 1417 mlog_errno(ret);
1392 goto out_fail_data; 1418 goto out_fail_data;
@@ -1407,9 +1433,9 @@ out_fail:
1407 return ret; 1433 return ret;
1408} 1434}
1409 1435
1410static int ocfs2_write_end_nolock(struct address_space *mapping, 1436int ocfs2_write_end_nolock(struct address_space *mapping,
1411 loff_t pos, unsigned len, unsigned copied, 1437 loff_t pos, unsigned len, unsigned copied,
1412 struct page *page, void *fsdata) 1438 struct page *page, void *fsdata)
1413{ 1439{
1414 int i; 1440 int i;
1415 unsigned from, to, start = pos & (PAGE_CACHE_SIZE - 1); 1441 unsigned from, to, start = pos & (PAGE_CACHE_SIZE - 1);