Commit 259709b0 authored by Lukas Czerner's avatar Lukas Czerner Committed by Theodore Ts'o

jbd2: change jbd2_journal_invalidatepage to accept length

invalidatepage now accepts range to invalidate and there are two file
system using jbd2 also implementing punch hole feature which can benefit
from this. We need to implement the same thing for jbd2 layer in order to
allow those file system take benefit of this functionality.

This commit adds length argument to the jbd2_journal_invalidatepage()
and updates all instances in ext4 and ocfs2.
Signed-off-by: default avatarLukas Czerner <lczerner@redhat.com>
Reviewed-by: default avatarJan Kara <jack@suse.cz>
parent d47992f8
...@@ -3015,7 +3015,8 @@ static int __ext4_journalled_invalidatepage(struct page *page, ...@@ -3015,7 +3015,8 @@ static int __ext4_journalled_invalidatepage(struct page *page,
if (offset == 0) if (offset == 0)
ClearPageChecked(page); ClearPageChecked(page);
return jbd2_journal_invalidatepage(journal, page, offset); return jbd2_journal_invalidatepage(journal, page, offset,
PAGE_CACHE_SIZE - offset);
} }
/* Wrapper for aops... */ /* Wrapper for aops... */
......
...@@ -2034,18 +2034,23 @@ static int journal_unmap_buffer(journal_t *journal, struct buffer_head *bh, ...@@ -2034,18 +2034,23 @@ static int journal_unmap_buffer(journal_t *journal, struct buffer_head *bh,
* void jbd2_journal_invalidatepage() * void jbd2_journal_invalidatepage()
* @journal: journal to use for flush... * @journal: journal to use for flush...
* @page: page to flush * @page: page to flush
* @offset: length of page to invalidate. * @offset: start of the range to invalidate
* @length: length of the range to invalidate
* *
* Reap page buffers containing data after offset in page. Can return -EBUSY * Reap page buffers containing data after in the specified range in page.
* if buffers are part of the committing transaction and the page is straddling * Can return -EBUSY if buffers are part of the committing transaction and
* i_size. Caller then has to wait for current commit and try again. * the page is straddling i_size. Caller then has to wait for current commit
* and try again.
*/ */
int jbd2_journal_invalidatepage(journal_t *journal, int jbd2_journal_invalidatepage(journal_t *journal,
struct page *page, struct page *page,
unsigned long offset) unsigned int offset,
unsigned int length)
{ {
struct buffer_head *head, *bh, *next; struct buffer_head *head, *bh, *next;
unsigned int stop = offset + length;
unsigned int curr_off = 0; unsigned int curr_off = 0;
int partial_page = (offset || length < PAGE_CACHE_SIZE);
int may_free = 1; int may_free = 1;
int ret = 0; int ret = 0;
...@@ -2054,6 +2059,8 @@ int jbd2_journal_invalidatepage(journal_t *journal, ...@@ -2054,6 +2059,8 @@ int jbd2_journal_invalidatepage(journal_t *journal,
if (!page_has_buffers(page)) if (!page_has_buffers(page))
return 0; return 0;
BUG_ON(stop > PAGE_CACHE_SIZE || stop < length);
/* We will potentially be playing with lists other than just the /* We will potentially be playing with lists other than just the
* data lists (especially for journaled data mode), so be * data lists (especially for journaled data mode), so be
* cautious in our locking. */ * cautious in our locking. */
...@@ -2063,10 +2070,13 @@ int jbd2_journal_invalidatepage(journal_t *journal, ...@@ -2063,10 +2070,13 @@ int jbd2_journal_invalidatepage(journal_t *journal,
unsigned int next_off = curr_off + bh->b_size; unsigned int next_off = curr_off + bh->b_size;
next = bh->b_this_page; next = bh->b_this_page;
if (next_off > stop)
return 0;
if (offset <= curr_off) { if (offset <= curr_off) {
/* This block is wholly outside the truncation point */ /* This block is wholly outside the truncation point */
lock_buffer(bh); lock_buffer(bh);
ret = journal_unmap_buffer(journal, bh, offset > 0); ret = journal_unmap_buffer(journal, bh, partial_page);
unlock_buffer(bh); unlock_buffer(bh);
if (ret < 0) if (ret < 0)
return ret; return ret;
...@@ -2077,7 +2087,7 @@ int jbd2_journal_invalidatepage(journal_t *journal, ...@@ -2077,7 +2087,7 @@ int jbd2_journal_invalidatepage(journal_t *journal,
} while (bh != head); } while (bh != head);
if (!offset) { if (!partial_page) {
if (may_free && try_to_free_buffers(page)) if (may_free && try_to_free_buffers(page))
J_ASSERT(!page_has_buffers(page)); J_ASSERT(!page_has_buffers(page));
} }
......
...@@ -608,7 +608,8 @@ static void ocfs2_invalidatepage(struct page *page, unsigned int offset, ...@@ -608,7 +608,8 @@ static void ocfs2_invalidatepage(struct page *page, unsigned int offset,
{ {
journal_t *journal = OCFS2_SB(page->mapping->host->i_sb)->journal->j_journal; journal_t *journal = OCFS2_SB(page->mapping->host->i_sb)->journal->j_journal;
jbd2_journal_invalidatepage(journal, page, offset); jbd2_journal_invalidatepage(journal, page, offset,
PAGE_CACHE_SIZE - offset);
} }
static int ocfs2_releasepage(struct page *page, gfp_t wait) static int ocfs2_releasepage(struct page *page, gfp_t wait)
......
...@@ -1090,7 +1090,7 @@ extern int jbd2_journal_dirty_metadata (handle_t *, struct buffer_head *); ...@@ -1090,7 +1090,7 @@ extern int jbd2_journal_dirty_metadata (handle_t *, struct buffer_head *);
extern int jbd2_journal_forget (handle_t *, struct buffer_head *); extern int jbd2_journal_forget (handle_t *, struct buffer_head *);
extern void journal_sync_buffer (struct buffer_head *); extern void journal_sync_buffer (struct buffer_head *);
extern int jbd2_journal_invalidatepage(journal_t *, extern int jbd2_journal_invalidatepage(journal_t *,
struct page *, unsigned long); struct page *, unsigned int, unsigned int);
extern int jbd2_journal_try_to_free_buffers(journal_t *, struct page *, gfp_t); extern int jbd2_journal_try_to_free_buffers(journal_t *, struct page *, gfp_t);
extern int jbd2_journal_stop(handle_t *); extern int jbd2_journal_stop(handle_t *);
extern int jbd2_journal_flush (journal_t *); extern int jbd2_journal_flush (journal_t *);
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment