diff options
Diffstat (limited to 'mm/backing-dev.c')
-rw-r--r-- | mm/backing-dev.c | 47 |
1 files changed, 35 insertions, 12 deletions
diff --git a/mm/backing-dev.c b/mm/backing-dev.c index f50a2811f9dc..b0ceb29da4c7 100644 --- a/mm/backing-dev.c +++ b/mm/backing-dev.c | |||
@@ -5,6 +5,41 @@ | |||
5 | #include <linux/sched.h> | 5 | #include <linux/sched.h> |
6 | #include <linux/module.h> | 6 | #include <linux/module.h> |
7 | 7 | ||
8 | int bdi_init(struct backing_dev_info *bdi) | ||
9 | { | ||
10 | int i, j; | ||
11 | int err; | ||
12 | |||
13 | for (i = 0; i < NR_BDI_STAT_ITEMS; i++) { | ||
14 | err = percpu_counter_init_irq(&bdi->bdi_stat[i], 0); | ||
15 | if (err) | ||
16 | goto err; | ||
17 | } | ||
18 | |||
19 | bdi->dirty_exceeded = 0; | ||
20 | err = prop_local_init_percpu(&bdi->completions); | ||
21 | |||
22 | if (err) { | ||
23 | err: | ||
24 | for (j = 0; j < i; j++) | ||
25 | percpu_counter_destroy(&bdi->bdi_stat[i]); | ||
26 | } | ||
27 | |||
28 | return err; | ||
29 | } | ||
30 | EXPORT_SYMBOL(bdi_init); | ||
31 | |||
32 | void bdi_destroy(struct backing_dev_info *bdi) | ||
33 | { | ||
34 | int i; | ||
35 | |||
36 | for (i = 0; i < NR_BDI_STAT_ITEMS; i++) | ||
37 | percpu_counter_destroy(&bdi->bdi_stat[i]); | ||
38 | |||
39 | prop_local_destroy_percpu(&bdi->completions); | ||
40 | } | ||
41 | EXPORT_SYMBOL(bdi_destroy); | ||
42 | |||
8 | static wait_queue_head_t congestion_wqh[2] = { | 43 | static wait_queue_head_t congestion_wqh[2] = { |
9 | __WAIT_QUEUE_HEAD_INITIALIZER(congestion_wqh[0]), | 44 | __WAIT_QUEUE_HEAD_INITIALIZER(congestion_wqh[0]), |
10 | __WAIT_QUEUE_HEAD_INITIALIZER(congestion_wqh[1]) | 45 | __WAIT_QUEUE_HEAD_INITIALIZER(congestion_wqh[1]) |
@@ -55,15 +90,3 @@ long congestion_wait(int rw, long timeout) | |||
55 | } | 90 | } |
56 | EXPORT_SYMBOL(congestion_wait); | 91 | EXPORT_SYMBOL(congestion_wait); |
57 | 92 | ||
58 | /** | ||
59 | * congestion_end - wake up sleepers on a congested backing_dev_info | ||
60 | * @rw: READ or WRITE | ||
61 | */ | ||
62 | void congestion_end(int rw) | ||
63 | { | ||
64 | wait_queue_head_t *wqh = &congestion_wqh[rw]; | ||
65 | |||
66 | if (waitqueue_active(wqh)) | ||
67 | wake_up(wqh); | ||
68 | } | ||
69 | EXPORT_SYMBOL(congestion_end); | ||