Commit cb530541 authored by Theodore Ts'o's avatar Theodore Ts'o

ext4: fix up error handling for mpage_map_and_submit_extent()

The function mpage_released_unused_page() must only be called once;
otherwise the kernel will BUG() when the second call to
mpage_released_unused_page() tries to unlock the pages which had been
unlocked by the first call.

Also restructure the error handling so that we only give up on writing
the dirty pages in the case of ENOSPC where retrying the allocation
won't help.  Otherwise, a transient failure, such as a kmalloc()
failure in calling ext4_map_blocks() might cause us to give up on
those pages, leading to a scary message in /var/log/messages plus data
loss.
Signed-off-by: default avatar"Theodore Ts'o" <tytso@mit.edu>
Reviewed-by: default avatarJan Kara <jack@suse.cz>
parent 39c04153
...@@ -2153,7 +2153,8 @@ static int mpage_map_one_extent(handle_t *handle, struct mpage_da_data *mpd) ...@@ -2153,7 +2153,8 @@ static int mpage_map_one_extent(handle_t *handle, struct mpage_da_data *mpd)
* guaranteed). After mapping we submit all mapped pages for IO. * guaranteed). After mapping we submit all mapped pages for IO.
*/ */
static int mpage_map_and_submit_extent(handle_t *handle, static int mpage_map_and_submit_extent(handle_t *handle,
struct mpage_da_data *mpd) struct mpage_da_data *mpd,
bool *give_up_on_write)
{ {
struct inode *inode = mpd->inode; struct inode *inode = mpd->inode;
struct ext4_map_blocks *map = &mpd->map; struct ext4_map_blocks *map = &mpd->map;
...@@ -2167,29 +2168,30 @@ static int mpage_map_and_submit_extent(handle_t *handle, ...@@ -2167,29 +2168,30 @@ static int mpage_map_and_submit_extent(handle_t *handle,
if (err < 0) { if (err < 0) {
struct super_block *sb = inode->i_sb; struct super_block *sb = inode->i_sb;
if (EXT4_SB(sb)->s_mount_flags & EXT4_MF_FS_ABORTED)
goto invalidate_dirty_pages;
/* /*
* Need to commit transaction to free blocks. Let upper * Let the uper layers retry transient errors.
* layers sort it out. * In the case of ENOSPC, if ext4_count_free_blocks()
* is non-zero, a commit should free up blocks.
*/ */
if (err == -ENOSPC && ext4_count_free_clusters(sb)) if ((err == -ENOMEM) ||
return -ENOSPC; (err == -ENOSPC && ext4_count_free_clusters(sb)))
return err;
if (!(EXT4_SB(sb)->s_mount_flags & EXT4_MF_FS_ABORTED)) {
ext4_msg(sb, KERN_CRIT, ext4_msg(sb, KERN_CRIT,
"Delayed block allocation failed for " "Delayed block allocation failed for "
"inode %lu at logical offset %llu with" "inode %lu at logical offset %llu with"
" max blocks %u with error %d", " max blocks %u with error %d",
inode->i_ino, inode->i_ino,
(unsigned long long)map->m_lblk, (unsigned long long)map->m_lblk,
(unsigned)map->m_len, err); (unsigned)map->m_len, -err);
ext4_msg(sb, KERN_CRIT, ext4_msg(sb, KERN_CRIT,
"This should not happen!! Data will " "This should not happen!! Data will "
"be lost\n"); "be lost\n");
if (err == -ENOSPC) if (err == -ENOSPC)
ext4_print_free_blocks(inode); ext4_print_free_blocks(inode);
} invalidate_dirty_pages:
/* invalidate all the pages */ *give_up_on_write = true;
mpage_release_unused_pages(mpd, true);
return err; return err;
} }
/* /*
...@@ -2377,6 +2379,7 @@ static int ext4_writepages(struct address_space *mapping, ...@@ -2377,6 +2379,7 @@ static int ext4_writepages(struct address_space *mapping,
struct ext4_sb_info *sbi = EXT4_SB(mapping->host->i_sb); struct ext4_sb_info *sbi = EXT4_SB(mapping->host->i_sb);
bool done; bool done;
struct blk_plug plug; struct blk_plug plug;
bool give_up_on_write = false;
trace_ext4_writepages(inode, wbc); trace_ext4_writepages(inode, wbc);
...@@ -2494,7 +2497,8 @@ static int ext4_writepages(struct address_space *mapping, ...@@ -2494,7 +2497,8 @@ static int ext4_writepages(struct address_space *mapping,
ret = mpage_prepare_extent_to_map(&mpd); ret = mpage_prepare_extent_to_map(&mpd);
if (!ret) { if (!ret) {
if (mpd.map.m_len) if (mpd.map.m_len)
ret = mpage_map_and_submit_extent(handle, &mpd); ret = mpage_map_and_submit_extent(handle, &mpd,
&give_up_on_write);
else { else {
/* /*
* We scanned the whole range (or exhausted * We scanned the whole range (or exhausted
...@@ -2509,7 +2513,7 @@ static int ext4_writepages(struct address_space *mapping, ...@@ -2509,7 +2513,7 @@ static int ext4_writepages(struct address_space *mapping,
/* Submit prepared bio */ /* Submit prepared bio */
ext4_io_submit(&mpd.io_submit); ext4_io_submit(&mpd.io_submit);
/* Unlock pages we didn't use */ /* Unlock pages we didn't use */
mpage_release_unused_pages(&mpd, false); mpage_release_unused_pages(&mpd, give_up_on_write);
/* Drop our io_end reference we got from init */ /* Drop our io_end reference we got from init */
ext4_put_io_end(mpd.io_submit.io_end); ext4_put_io_end(mpd.io_submit.io_end);
......
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