aboutsummaryrefslogtreecommitdiffstats
path: root/fs/btrfs/async-thread.c
diff options
context:
space:
mode:
Diffstat (limited to 'fs/btrfs/async-thread.c')
-rw-r--r--fs/btrfs/async-thread.c3
1 files changed, 2 insertions, 1 deletions
diff --git a/fs/btrfs/async-thread.c b/fs/btrfs/async-thread.c
index 958cd8b5f0d7..2ee301740195 100644
--- a/fs/btrfs/async-thread.c
+++ b/fs/btrfs/async-thread.c
@@ -48,6 +48,7 @@ struct btrfs_worker_thread {
48 48
49 /* number of things on the pending list */ 49 /* number of things on the pending list */
50 atomic_t num_pending; 50 atomic_t num_pending;
51
51 unsigned long sequence; 52 unsigned long sequence;
52 53
53 /* protects the pending list. */ 54 /* protects the pending list. */
@@ -242,7 +243,7 @@ static struct btrfs_worker_thread *next_worker(struct btrfs_workers *workers)
242 worker = list_entry(next, struct btrfs_worker_thread, worker_list); 243 worker = list_entry(next, struct btrfs_worker_thread, worker_list);
243 atomic_inc(&worker->num_pending); 244 atomic_inc(&worker->num_pending);
244 worker->sequence++; 245 worker->sequence++;
245 if (worker->sequence % 4 == 0) 246 if (worker->sequence % workers->idle_thresh == 0)
246 list_move_tail(next, &workers->worker_list); 247 list_move_tail(next, &workers->worker_list);
247 return worker; 248 return worker;
248} 249}