Skip to content

Commit

Permalink
writeback: remove unused nonblocking and congestion checks
Browse files Browse the repository at this point in the history
- no one is calling wb_writeback and write_cache_pages with
  wbc.nonblocking=1 any more
- lumpy pageout will want to do nonblocking writeback without the
  congestion wait

So remove the congestion checks as suggested by Chris.

Signed-off-by: Wu Fengguang <[email protected]>
Cc: Chris Mason <[email protected]>
Cc: Jens Axboe <[email protected]>
Cc: Trond Myklebust <[email protected]>
Cc: Christoph Hellwig <[email protected]>
Cc: Dave Chinner <[email protected]>
Cc: Evgeniy Polyakov <[email protected]>
Cc: Alex Elder <[email protected]>
Signed-off-by: Jens Axboe <[email protected]>
  • Loading branch information
fengguang authored and Jens Axboe committed Dec 3, 2009
1 parent b17621f commit 0d99519
Show file tree
Hide file tree
Showing 4 changed files with 1 addition and 39 deletions.
10 changes: 0 additions & 10 deletions drivers/staging/pohmelfs/inode.c
Original file line number Diff line number Diff line change
Expand Up @@ -143,7 +143,6 @@ static int pohmelfs_writepages(struct address_space *mapping, struct writeback_c
struct inode *inode = mapping->host;
struct pohmelfs_inode *pi = POHMELFS_I(inode);
struct pohmelfs_sb *psb = POHMELFS_SB(inode->i_sb);
struct backing_dev_info *bdi = mapping->backing_dev_info;
int err = 0;
int done = 0;
int nr_pages;
Expand All @@ -152,11 +151,6 @@ static int pohmelfs_writepages(struct address_space *mapping, struct writeback_c
int scanned = 0;
int range_whole = 0;

if (wbc->nonblocking && bdi_write_congested(bdi)) {
wbc->encountered_congestion = 1;
return 0;
}

if (wbc->range_cyclic) {
index = mapping->writeback_index; /* Start from prev offset */
end = -1;
Expand Down Expand Up @@ -248,10 +242,6 @@ static int pohmelfs_writepages(struct address_space *mapping, struct writeback_c

if (wbc->nr_to_write <= 0)
done = 1;
if (wbc->nonblocking && bdi_write_congested(bdi)) {
wbc->encountered_congestion = 1;
done = 1;
}

continue;
out_continue:
Expand Down
9 changes: 0 additions & 9 deletions fs/fs-writeback.c
Original file line number Diff line number Diff line change
Expand Up @@ -639,14 +639,6 @@ static void writeback_inodes_wb(struct bdi_writeback *wb,
continue;
}

if (wbc->nonblocking && bdi_write_congested(wb->bdi)) {
wbc->encountered_congestion = 1;
if (!is_blkdev_sb)
break; /* Skip a congested fs */
requeue_io(inode);
continue; /* Skip a congested blockdev */
}

/*
* Was this inode dirtied after sync_sb_inodes was called?
* This keeps sync from extra jobs and livelock.
Expand Down Expand Up @@ -770,7 +762,6 @@ static long wb_writeback(struct bdi_writeback *wb,
break;

wbc.more_io = 0;
wbc.encountered_congestion = 0;
wbc.nr_to_write = MAX_WRITEBACK_PAGES;
wbc.pages_skipped = 0;
writeback_inodes_wb(wb, &wbc);
Expand Down
9 changes: 1 addition & 8 deletions fs/xfs/linux-2.6/xfs_aops.c
Original file line number Diff line number Diff line change
Expand Up @@ -904,16 +904,9 @@ xfs_convert_page(

if (startio) {
if (count) {
struct backing_dev_info *bdi;

bdi = inode->i_mapping->backing_dev_info;
wbc->nr_to_write--;
if (bdi_write_congested(bdi)) {
wbc->encountered_congestion = 1;
done = 1;
} else if (wbc->nr_to_write <= 0) {
if (wbc->nr_to_write <= 0)
done = 1;
}
}
xfs_start_page_writeback(page, !page_dirty, count);
}
Expand Down
12 changes: 0 additions & 12 deletions mm/page-writeback.c
Original file line number Diff line number Diff line change
Expand Up @@ -821,7 +821,6 @@ int write_cache_pages(struct address_space *mapping,
struct writeback_control *wbc, writepage_t writepage,
void *data)
{
struct backing_dev_info *bdi = mapping->backing_dev_info;
int ret = 0;
int done = 0;
struct pagevec pvec;
Expand All @@ -834,11 +833,6 @@ int write_cache_pages(struct address_space *mapping,
int range_whole = 0;
long nr_to_write = wbc->nr_to_write;

if (wbc->nonblocking && bdi_write_congested(bdi)) {
wbc->encountered_congestion = 1;
return 0;
}

pagevec_init(&pvec, 0);
if (wbc->range_cyclic) {
writeback_index = mapping->writeback_index; /* prev offset */
Expand Down Expand Up @@ -957,12 +951,6 @@ int write_cache_pages(struct address_space *mapping,
break;
}
}

if (wbc->nonblocking && bdi_write_congested(bdi)) {
wbc->encountered_congestion = 1;
done = 1;
break;
}
}
pagevec_release(&pvec);
cond_resched();
Expand Down

0 comments on commit 0d99519

Please sign in to comment.