Lines Matching refs:WRITE
337 for (rw = READ; rw <= WRITE; rw++) { in throtl_pd_alloc()
344 tg->bps[WRITE] = -1; in throtl_pd_alloc()
346 tg->iops[WRITE] = -1; in throtl_pd_alloc()
387 for (rw = READ; rw <= WRITE; rw++) in tg_update_has_rules()
876 if ((bio = throtl_peek_queued(&sq->queued[WRITE]))) in tg_update_disptime()
963 while ((bio = throtl_peek_queued(&sq->queued[WRITE])) && in throtl_dispatch_tg()
1036 sq->nr_queued[READ] + sq->nr_queued[WRITE], in throtl_pending_timer_fn()
1037 sq->nr_queued[READ], sq->nr_queued[WRITE]); in throtl_pending_timer_fn()
1098 for (rw = READ; rw <= WRITE; rw++) in blk_throtl_dispatch_work_fn()
1155 tg->bps[READ], tg->bps[WRITE], in tg_conf_updated()
1156 tg->iops[READ], tg->iops[WRITE]); in tg_conf_updated()
1239 .private = offsetof(struct throtl_grp, bps[WRITE]),
1251 .private = offsetof(struct throtl_grp, iops[WRITE]),
1277 if (tg->bps[READ] == -1 && tg->bps[WRITE] == -1 && in tg_prfill_max()
1278 tg->iops[READ] == -1 && tg->iops[WRITE] == -1) in tg_prfill_max()
1283 if (tg->bps[WRITE] != -1) in tg_prfill_max()
1284 snprintf(bufs[1], sizeof(bufs[1]), "%llu", tg->bps[WRITE]); in tg_prfill_max()
1287 if (tg->iops[WRITE] != -1) in tg_prfill_max()
1288 snprintf(bufs[3], sizeof(bufs[3]), "%u", tg->iops[WRITE]); in tg_prfill_max()
1318 v[1] = tg->bps[WRITE]; in tg_set_max()
1320 v[3] = tg->iops[WRITE]; in tg_set_max()
1358 tg->bps[WRITE] = v[1]; in tg_set_max()
1360 tg->iops[WRITE] = v[3]; in tg_set_max()
1460 sq->nr_queued[READ], sq->nr_queued[WRITE]); in blk_throtl_bio()
1508 while ((bio = throtl_peek_queued(&sq->queued[WRITE]))) in tg_drain_bios()
1547 for (rw = READ; rw <= WRITE; rw++) in blk_throtl_drain()