diff options
author | Tejun Heo <tj@kernel.org> | 2013-05-14 16:52:31 -0400 |
---|---|---|
committer | Tejun Heo <tj@kernel.org> | 2013-05-14 16:52:31 -0400 |
commit | cb76199c36a7ccf0947ef4875b32e0940f50d1a8 (patch) | |
tree | d14184fb947d7cc622eed013d6a27ad4672fa9fc /block/blk-throttle.c | |
parent | 632b44935f4c99a61c56f8a6f805a1080ab5a432 (diff) |
blk-throttle: collapse throtl_dispatch() into the work function
blk-throttle is about to go through major restructuring to support
hierarchy. Do cosmetic updates in preparation.
* s/throtl_data->throtl_work/throtl_data->dispatch_work/
* s/blk_throtl_work()/blk_throtl_dispatch_work_fn()/
* Collapse throtl_dispatch() into blk_throtl_dispatch_work_fn()
This patch is purely cosmetic.
Signed-off-by: Tejun Heo <tj@kernel.org>
Acked-by: Vivek Goyal <vgoyal@redhat.com>
Diffstat (limited to 'block/blk-throttle.c')
-rw-r--r-- | block/blk-throttle.c | 26 |
1 files changed, 9 insertions, 17 deletions
diff --git a/block/blk-throttle.c b/block/blk-throttle.c index 7dbd0e695df0..0a0bc00059df 100644 --- a/block/blk-throttle.c +++ b/block/blk-throttle.c | |||
@@ -108,7 +108,7 @@ struct throtl_data | |||
108 | unsigned int nr_undestroyed_grps; | 108 | unsigned int nr_undestroyed_grps; |
109 | 109 | ||
110 | /* Work for dispatching throttled bios */ | 110 | /* Work for dispatching throttled bios */ |
111 | struct delayed_work throtl_work; | 111 | struct delayed_work dispatch_work; |
112 | }; | 112 | }; |
113 | 113 | ||
114 | /* list and work item to allocate percpu group stats */ | 114 | /* list and work item to allocate percpu group stats */ |
@@ -820,10 +820,12 @@ static int throtl_select_dispatch(struct throtl_data *td, struct bio_list *bl) | |||
820 | return nr_disp; | 820 | return nr_disp; |
821 | } | 821 | } |
822 | 822 | ||
823 | /* Dispatch throttled bios. Should be called without queue lock held. */ | 823 | /* work function to dispatch throttled bios */ |
824 | static int throtl_dispatch(struct request_queue *q) | 824 | void blk_throtl_dispatch_work_fn(struct work_struct *work) |
825 | { | 825 | { |
826 | struct throtl_data *td = q->td; | 826 | struct throtl_data *td = container_of(to_delayed_work(work), |
827 | struct throtl_data, dispatch_work); | ||
828 | struct request_queue *q = td->queue; | ||
827 | unsigned int nr_disp = 0; | 829 | unsigned int nr_disp = 0; |
828 | struct bio_list bio_list_on_stack; | 830 | struct bio_list bio_list_on_stack; |
829 | struct bio *bio; | 831 | struct bio *bio; |
@@ -859,16 +861,6 @@ out: | |||
859 | generic_make_request(bio); | 861 | generic_make_request(bio); |
860 | blk_finish_plug(&plug); | 862 | blk_finish_plug(&plug); |
861 | } | 863 | } |
862 | return nr_disp; | ||
863 | } | ||
864 | |||
865 | void blk_throtl_work(struct work_struct *work) | ||
866 | { | ||
867 | struct throtl_data *td = container_of(work, struct throtl_data, | ||
868 | throtl_work.work); | ||
869 | struct request_queue *q = td->queue; | ||
870 | |||
871 | throtl_dispatch(q); | ||
872 | } | 864 | } |
873 | 865 | ||
874 | /* Call with queue lock held */ | 866 | /* Call with queue lock held */ |
@@ -876,7 +868,7 @@ static void | |||
876 | throtl_schedule_delayed_work(struct throtl_data *td, unsigned long delay) | 868 | throtl_schedule_delayed_work(struct throtl_data *td, unsigned long delay) |
877 | { | 869 | { |
878 | 870 | ||
879 | struct delayed_work *dwork = &td->throtl_work; | 871 | struct delayed_work *dwork = &td->dispatch_work; |
880 | 872 | ||
881 | if (total_nr_queued(td)) { | 873 | if (total_nr_queued(td)) { |
882 | mod_delayed_work(kthrotld_workqueue, dwork, delay); | 874 | mod_delayed_work(kthrotld_workqueue, dwork, delay); |
@@ -1057,7 +1049,7 @@ static void throtl_shutdown_wq(struct request_queue *q) | |||
1057 | { | 1049 | { |
1058 | struct throtl_data *td = q->td; | 1050 | struct throtl_data *td = q->td; |
1059 | 1051 | ||
1060 | cancel_delayed_work_sync(&td->throtl_work); | 1052 | cancel_delayed_work_sync(&td->dispatch_work); |
1061 | } | 1053 | } |
1062 | 1054 | ||
1063 | static struct blkcg_policy blkcg_policy_throtl = { | 1055 | static struct blkcg_policy blkcg_policy_throtl = { |
@@ -1206,7 +1198,7 @@ int blk_throtl_init(struct request_queue *q) | |||
1206 | return -ENOMEM; | 1198 | return -ENOMEM; |
1207 | 1199 | ||
1208 | td->tg_service_tree = THROTL_RB_ROOT; | 1200 | td->tg_service_tree = THROTL_RB_ROOT; |
1209 | INIT_DELAYED_WORK(&td->throtl_work, blk_throtl_work); | 1201 | INIT_DELAYED_WORK(&td->dispatch_work, blk_throtl_dispatch_work_fn); |
1210 | 1202 | ||
1211 | q->td = td; | 1203 | q->td = td; |
1212 | td->queue = q; | 1204 | td->queue = q; |