Commit 1eec6702 authored by Seth Jennings's avatar Seth Jennings Committed by Linus Torvalds

mm: allow for outstanding swap writeback accounting

To prevent flooding the swap device with writebacks, frontswap backends
need to count and limit the number of outstanding writebacks.  The
incrementing of the counter can be done before the call to
__swap_writepage().  However, the caller must receive a notification
when the writeback completes in order to decrement the counter.

To achieve this functionality, this patch modifies __swap_writepage() to
take the bio completion callback function as an argument.

end_swap_bio_write(), the normal bio completion function, is also made
non-static so that code doing the accounting can call it after the
accounting is done.

There should be no behavioural change to existing code.
Signed-off-by: default avatarSeth Jennings <sjenning@linux.vnet.ibm.com>
Signed-off-by: default avatarBob Liu <bob.liu@oracle.com>
Acked-by: default avatarMinchan Kim <minchan@kernel.org>
Reviewed-by: default avatarDan Magenheimer <dan.magenheimer@oracle.com>
Cc: Konrad Rzeszutek Wilk <konrad.wilk@oracle.com>
Signed-off-by: default avatarAndrew Morton <akpm@linux-foundation.org>
Signed-off-by: default avatarLinus Torvalds <torvalds@linux-foundation.org>
parent 2f772e6c
...@@ -330,7 +330,9 @@ static inline void mem_cgroup_uncharge_swap(swp_entry_t ent) ...@@ -330,7 +330,9 @@ static inline void mem_cgroup_uncharge_swap(swp_entry_t ent)
/* linux/mm/page_io.c */ /* linux/mm/page_io.c */
extern int swap_readpage(struct page *); extern int swap_readpage(struct page *);
extern int swap_writepage(struct page *page, struct writeback_control *wbc); extern int swap_writepage(struct page *page, struct writeback_control *wbc);
extern int __swap_writepage(struct page *page, struct writeback_control *wbc); extern void end_swap_bio_write(struct bio *bio, int err);
extern int __swap_writepage(struct page *page, struct writeback_control *wbc,
void (*end_write_func)(struct bio *, int));
extern int swap_set_page_dirty(struct page *page); extern int swap_set_page_dirty(struct page *page);
extern void end_swap_bio_read(struct bio *bio, int err); extern void end_swap_bio_read(struct bio *bio, int err);
......
...@@ -42,7 +42,7 @@ static struct bio *get_swap_bio(gfp_t gfp_flags, ...@@ -42,7 +42,7 @@ static struct bio *get_swap_bio(gfp_t gfp_flags,
return bio; return bio;
} }
static void end_swap_bio_write(struct bio *bio, int err) void end_swap_bio_write(struct bio *bio, int err)
{ {
const int uptodate = test_bit(BIO_UPTODATE, &bio->bi_flags); const int uptodate = test_bit(BIO_UPTODATE, &bio->bi_flags);
struct page *page = bio->bi_io_vec[0].bv_page; struct page *page = bio->bi_io_vec[0].bv_page;
...@@ -197,12 +197,13 @@ int swap_writepage(struct page *page, struct writeback_control *wbc) ...@@ -197,12 +197,13 @@ int swap_writepage(struct page *page, struct writeback_control *wbc)
end_page_writeback(page); end_page_writeback(page);
goto out; goto out;
} }
ret = __swap_writepage(page, wbc); ret = __swap_writepage(page, wbc, end_swap_bio_write);
out: out:
return ret; return ret;
} }
int __swap_writepage(struct page *page, struct writeback_control *wbc) int __swap_writepage(struct page *page, struct writeback_control *wbc,
void (*end_write_func)(struct bio *, int))
{ {
struct bio *bio; struct bio *bio;
int ret = 0, rw = WRITE; int ret = 0, rw = WRITE;
...@@ -234,7 +235,7 @@ int __swap_writepage(struct page *page, struct writeback_control *wbc) ...@@ -234,7 +235,7 @@ int __swap_writepage(struct page *page, struct writeback_control *wbc)
return ret; return ret;
} }
bio = get_swap_bio(GFP_NOIO, page, end_swap_bio_write); bio = get_swap_bio(GFP_NOIO, page, end_write_func);
if (bio == NULL) { if (bio == NULL) {
set_page_dirty(page); set_page_dirty(page);
unlock_page(page); unlock_page(page);
......
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