Commit ad15ec06 authored by Yan, Zheng's avatar Yan, Zheng Committed by Ilya Dryomov

ceph: handle interrupted ceph_writepage()

writepage() can be interrupted when it's called by direct memory
reclaimer (the direct memory relaimer is killed). To avoid lossing
data, we redirty the page.
Signed-off-by: default avatarYan, Zheng <zyan@redhat.com>
parent a78bbd4b
...@@ -544,10 +544,20 @@ static int writepage_nounlock(struct page *page, struct writeback_control *wbc) ...@@ -544,10 +544,20 @@ static int writepage_nounlock(struct page *page, struct writeback_control *wbc)
truncate_seq, truncate_size, truncate_seq, truncate_size,
&inode->i_mtime, &page, 1); &inode->i_mtime, &page, 1);
if (err < 0) { if (err < 0) {
dout("writepage setting page/mapping error %d %p\n", err, page); struct writeback_control tmp_wbc;
if (!wbc)
wbc = &tmp_wbc;
if (err == -ERESTARTSYS) {
/* killed by SIGKILL */
dout("writepage interrupted page %p\n", page);
redirty_page_for_writepage(wbc, page);
end_page_writeback(page);
goto out;
}
dout("writepage setting page/mapping error %d %p\n",
err, page);
SetPageError(page); SetPageError(page);
mapping_set_error(&inode->i_data, err); mapping_set_error(&inode->i_data, err);
if (wbc)
wbc->pages_skipped++; wbc->pages_skipped++;
} else { } else {
dout("writepage cleaned page %p\n", page); dout("writepage cleaned page %p\n", page);
...@@ -569,12 +579,16 @@ static int ceph_writepage(struct page *page, struct writeback_control *wbc) ...@@ -569,12 +579,16 @@ static int ceph_writepage(struct page *page, struct writeback_control *wbc)
BUG_ON(!inode); BUG_ON(!inode);
ihold(inode); ihold(inode);
err = writepage_nounlock(page, wbc); err = writepage_nounlock(page, wbc);
if (err == -ERESTARTSYS) {
/* direct memory reclaimer was killed by SIGKILL. return 0
* to prevent caller from setting mapping/page error */
err = 0;
}
unlock_page(page); unlock_page(page);
iput(inode); iput(inode);
return err; return err;
} }
/* /*
* lame release_pages helper. release_pages() isn't exported to * lame release_pages helper. release_pages() isn't exported to
* modules. * modules.
......
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