diff -urNp x-ref/drivers/block/ll_rw_blk.c x/drivers/block/ll_rw_blk.c
--- x-ref/drivers/block/ll_rw_blk.c	2003-02-14 19:10:13.000000000 +0100
+++ x/drivers/block/ll_rw_blk.c	2003-02-14 19:10:14.000000000 +0100
@@ -1429,6 +1429,7 @@ void __submit_bh(int rw, struct buffer_h
 			kstat.pgpgin += count;
 			break;
 	}
+	cond_resched();
 }
 
 /**
diff -urNp x-ref/fs/buffer.c x/fs/buffer.c
--- x-ref/fs/buffer.c	2003-02-14 19:10:13.000000000 +0100
+++ x/fs/buffer.c	2003-02-14 19:11:58.000000000 +0100
@@ -230,8 +230,15 @@ static int write_some_buffers(kdev_t dev
 
 		if (dev != NODEV && bh->b_dev != dev)
 			continue;
-		if (test_and_set_bit(BH_Lock, &bh->b_state))
+		if (test_and_set_bit(BH_Lock, &bh->b_state)) {
+			/*
+			 * FIXME: according to Chris some buggy fs
+			 * submit_bh by hand w/o refiling the bh
+			 * after marking it clean.
+			 */
+			__refile_buffer(bh);
 			continue;
+		}
 		if (buffer_delay(bh)) {
 			if (write_buffer_delay(bh)) {
 				if (count)
@@ -246,6 +253,8 @@ static int write_some_buffers(kdev_t dev
 				continue;
 
 			spin_unlock(&lru_list_lock);
+			cond_resched();
+
 			write_locked_buffers(array, count);
 			return -EAGAIN;
 		}
@@ -253,6 +262,7 @@ static int write_some_buffers(kdev_t dev
 		__refile_buffer(bh);
 	}
 	spin_unlock(&lru_list_lock);
+	cond_resched();
 
 	if (count)
 		write_locked_buffers(array, count);
@@ -298,17 +308,19 @@ static int wait_for_buffers(kdev_t dev, 
 		spin_unlock(&lru_list_lock);
 		wait_on_buffer (bh);
 		put_bh(bh);
+		cond_resched();
 		return -EAGAIN;
 	}
 	spin_unlock(&lru_list_lock);
+	cond_resched();
 	return 0;
 }
 
 static int wait_for_locked_buffers(kdev_t dev, int index, int refile)
 {
-	do {
+	do
 		spin_lock(&lru_list_lock);
-	} while (wait_for_buffers(dev, index, refile));
+	while (wait_for_buffers(dev, index, refile));
 	return 0;
 }
 
@@ -881,6 +893,11 @@ int fsync_buffers_list(struct list_head 
 				spin_lock(&lru_list_lock);
 			}
 		}
+		if (need_resched()) {
+			spin_unlock(&lru_list_lock);
+			__cond_resched();
+			spin_lock(&lru_list_lock);
+		}
 	}
 
 	while (!list_empty(&tmp)) {
@@ -892,6 +909,7 @@ int fsync_buffers_list(struct list_head 
 		if (!buffer_uptodate(bh))
 			err = -EIO;
 		brelse(bh);
+		cond_resched();
 		spin_lock(&lru_list_lock);
 	}
 	
@@ -921,6 +939,7 @@ static int osync_buffers_list(struct lis
 	struct buffer_head *bh;
 	struct list_head *p;
 	int err = 0;
+	int num_sched = 0;
 
  repeat:
 	list_for_each_prev(p, list) {
@@ -935,6 +954,13 @@ static int osync_buffers_list(struct lis
 			spin_lock(&lru_list_lock);
 			goto repeat;
 		}
+		if (need_resched() && num_sched < 32) {
+			spin_unlock(&lru_list_lock);
+			__cond_resched();
+			spin_lock(&lru_list_lock);
+			num_sched++;
+			goto repeat;
+		}
 	}
 
 	return err;
@@ -973,6 +999,7 @@ struct buffer_head * getblk(kdev_t dev, 
 	for (;;) {
 		struct buffer_head * bh;
 
+		cond_resched();
 		bh = get_hash_table(dev, block, size);
 		if (bh) {
 			touch_buffer(bh);
@@ -1140,8 +1167,10 @@ struct buffer_head * bread(kdev_t dev, i
 	struct buffer_head * bh;
 
 	bh = getblk(dev, block, size);
-	if (buffer_uptodate(bh))
+	if (buffer_uptodate(bh)) {
+		cond_resched();
 		return bh;
+	}
 	ll_rw_block(READ, 1, &bh);
 	wait_on_buffer(bh);
 	if (buffer_uptodate(bh))
diff -urNp x-ref/fs/dcache.c x/fs/dcache.c
--- x-ref/fs/dcache.c	2003-02-14 19:10:04.000000000 +0100
+++ x/fs/dcache.c	2003-02-14 19:10:14.000000000 +0100
@@ -75,7 +75,7 @@ static inline void d_free(struct dentry 
  * d_iput() operation if defined.
  * Called with dcache_lock held, drops it.
  */
-static inline void dentry_iput(struct dentry * dentry)
+static void dentry_iput(struct dentry * dentry)
 {
 	struct inode *inode = dentry->d_inode;
 	if (inode) {
@@ -88,6 +88,7 @@ static inline void dentry_iput(struct de
 			iput(inode);
 	} else
 		spin_unlock(&dcache_lock);
+	cond_resched();
 }
 
 /* 
diff -urNp x-ref/fs/jbd/commit.c x/fs/jbd/commit.c
--- x-ref/fs/jbd/commit.c	2002-11-29 02:23:15.000000000 +0100
+++ x/fs/jbd/commit.c	2003-02-14 19:10:14.000000000 +0100
@@ -212,6 +212,16 @@ write_out_data_locked:
 				__journal_remove_journal_head(bh);
 				refile_buffer(bh);
 				__brelse(bh);
+				if (current->need_resched) {
+					if (commit_transaction->t_sync_datalist)
+						commit_transaction->t_sync_datalist =
+							next_jh;
+					if (bufs)
+						break;
+					spin_unlock(&journal_datalist_lock);
+					cond_resched();
+					goto write_out_data;
+				}
 			}
 		}
 		if (bufs == ARRAY_SIZE(wbuf)) {
diff -urNp x-ref/fs/proc/array.c x/fs/proc/array.c
--- x-ref/fs/proc/array.c	2003-02-14 19:10:09.000000000 +0100
+++ x/fs/proc/array.c	2003-02-14 19:10:14.000000000 +0100
@@ -424,6 +424,8 @@ static inline void statm_pte_range(pmd_t
 		pte_t page = *pte;
 		struct page *ptpage;
 
+		cond_resched();
+
 		address += PAGE_SIZE;
 		pte++;
 		if (pte_none(page))
diff -urNp x-ref/fs/proc/generic.c x/fs/proc/generic.c
--- x-ref/fs/proc/generic.c	2003-01-29 06:14:13.000000000 +0100
+++ x/fs/proc/generic.c	2003-02-14 19:10:14.000000000 +0100
@@ -98,7 +98,9 @@ proc_file_read(struct file * file, char 
 				retval = n;
 			break;
 		}
-		
+
+		cond_resched();
+
 		/* This is a hack to allow mangling of file pos independent
  		 * of actual bytes read.  Simply place the data at page,
  		 * return the bytes, and set `start' to the desired offset
diff -urNp x-ref/mm/filemap.c x/mm/filemap.c
--- x-ref/mm/filemap.c	2003-02-14 19:10:13.000000000 +0100
+++ x/mm/filemap.c	2003-02-14 19:10:14.000000000 +0100
@@ -304,11 +304,7 @@ static int truncate_list_pages(struct li
 
 			page_cache_release(page);
 
-			if (current->need_resched) {
-				__set_current_state(TASK_RUNNING);
-				schedule();
-			}
-
+			cond_resched();
 			spin_lock(&pagecache_lock);
 			goto restart;
 		}
@@ -414,11 +410,8 @@ static int invalidate_list_pages2(struct
 		}
 
 		page_cache_release(page);
-		if (current->need_resched) {
-			__set_current_state(TASK_RUNNING);
-			schedule();
-		}
 
+		cond_resched();
 		spin_lock(&pagecache_lock);
 		goto restart;
 	}
@@ -586,6 +579,7 @@ int filemap_fdatasync(struct address_spa
 			UnlockPage(page);
 
 		page_cache_release(page);
+		cond_resched();
 		spin_lock(&pagecache_lock);
 	}
 	spin_unlock(&pagecache_lock);
@@ -708,6 +702,8 @@ static int page_cache_read(struct file *
 	struct page **hash = page_hash(mapping, offset);
 	struct page *page; 
 
+	cond_resched();
+
 	spin_lock(&pagecache_lock);
 	page = __find_page_nolock(mapping, offset, *hash);
 	spin_unlock(&pagecache_lock);
@@ -1452,6 +1448,9 @@ page_ok:
 		offset &= ~PAGE_CACHE_MASK;
 
 		page_cache_release(page);
+
+		cond_resched();
+
 		if (ret == nr && desc->count)
 			continue;
 		break;
@@ -3128,6 +3127,8 @@ unlock:
 		UnlockPage(page);
 		page_cache_release(page);
 
+		cond_resched();
+
 		if (status < 0)
 			break;
 	} while (count);