Lines Matching refs:td

94 	struct throtl_data *td;  member
201 return tg->td; in sq_to_td()
355 struct throtl_data *td = blkg->q->td; in throtl_pd_init() local
371 sq->parent_sq = &td->service_queue; in throtl_pd_init()
374 tg->td = td; in throtl_pd_init()
933 BUG_ON(tg->td->nr_queued[rw] <= 0); in tg_dispatch_one_bio()
934 tg->td->nr_queued[rw]--; in tg_dispatch_one_bio()
1023 struct throtl_data *td = sq_to_td(sq); in throtl_pending_timer_fn() local
1024 struct request_queue *q = td->queue; in throtl_pending_timer_fn()
1070 queue_work(kthrotld_workqueue, &td->dispatch_work); in throtl_pending_timer_fn()
1086 struct throtl_data *td = container_of(work, struct throtl_data, in blk_throtl_dispatch_work_fn() local
1088 struct throtl_service_queue *td_sq = &td->service_queue; in blk_throtl_dispatch_work_fn()
1089 struct request_queue *q = td->queue; in blk_throtl_dispatch_work_fn()
1381 struct throtl_data *td = q->td; in throtl_shutdown_wq() local
1383 cancel_work_sync(&td->dispatch_work); in throtl_shutdown_wq()
1463 tg->td->nr_queued[rw]++; in blk_throtl_bio()
1522 struct throtl_data *td = q->td; in blk_throtl_drain() local
1537 blkg_for_each_descendant_post(blkg, pos_css, td->queue->root_blkg) in blk_throtl_drain()
1541 tg_drain_bios(&td->service_queue); in blk_throtl_drain()
1548 while ((bio = throtl_pop_queued(&td->service_queue.queued[rw], in blk_throtl_drain()
1557 struct throtl_data *td; in blk_throtl_init() local
1560 td = kzalloc_node(sizeof(*td), GFP_KERNEL, q->node); in blk_throtl_init()
1561 if (!td) in blk_throtl_init()
1564 INIT_WORK(&td->dispatch_work, blk_throtl_dispatch_work_fn); in blk_throtl_init()
1565 throtl_service_queue_init(&td->service_queue); in blk_throtl_init()
1567 q->td = td; in blk_throtl_init()
1568 td->queue = q; in blk_throtl_init()
1573 kfree(td); in blk_throtl_init()
1579 BUG_ON(!q->td); in blk_throtl_exit()
1582 kfree(q->td); in blk_throtl_exit()