Searched refs:queued (Results 1 – 6 of 6) sorted by relevance
| /block/ |
| D | blk-throttle.c | 81 struct list_head queued[2]; /* throtl_qnode [READ/WRITE] */ member
414 struct list_head *queued) in throtl_qnode_add_bio() argument
418 list_add_tail(&qn->node, queued); in throtl_qnode_add_bio()
427 static struct bio *throtl_peek_queued(struct list_head *queued) in throtl_peek_queued() argument
432 if (list_empty(queued)) in throtl_peek_queued()
435 qn = list_first_entry(queued, struct throtl_qnode, node); in throtl_peek_queued()
455 static struct bio *throtl_pop_queued(struct list_head *queued, in throtl_pop_queued() argument
461 if (list_empty(queued)) in throtl_pop_queued()
464 qn = list_first_entry(queued, struct throtl_qnode, node); in throtl_pop_queued()
475 list_move_tail(&qn->node, queued); in throtl_pop_queued()
[all …]
|
| D | bfq-cgroup.c | 175 if (blkg_rwstat_total(&stats->queued)) in bfqg_stats_set_start_empty_time()
217 blkg_rwstat_total(&stats->queued)); in bfqg_stats_update_avg_queue_size()
225 blkg_rwstat_add(&bfqg->stats.queued, op, 1); in bfqg_stats_update_io_add()
233 blkg_rwstat_add(&bfqg->stats.queued, op, -1); in bfqg_stats_update_io_remove()
451 blkg_rwstat_exit(&stats->queued); in bfqg_stats_exit()
472 blkg_rwstat_init(&stats->queued, gfp) || in bfqg_stats_init()
1341 .private = offsetof(struct bfq_group, stats.queued),
1384 .private = offsetof(struct bfq_group, stats.queued),
|
| D | bfq-iosched.h | 263 int queued[2]; member
521 int queued; member
825 struct blkg_rwstat queued; member
|
| D | blk-mq.c | 345 data->hctx->queued++; in blk_mq_rq_ctx_init()
1097 static inline unsigned int queued_to_index(unsigned int queued) in queued_to_index() argument
1099 if (!queued) in queued_to_index()
1102 return min(BLK_MQ_MAX_DISPATCH_ORDER - 1, ilog2(queued) + 1); in queued_to_index()
1367 int errors, queued; in blk_mq_dispatch_rq_list() local
1378 errors = queued = 0; in blk_mq_dispatch_rq_list()
1413 queued++; in blk_mq_dispatch_rq_list()
1439 hctx->dispatched[queued_to_index(queued)]++; in blk_mq_dispatch_rq_list()
1445 ret == BLK_STS_DEV_RESOURCE) && q->mq_ops->commit_rqs && queued) in blk_mq_dispatch_rq_list()
1512 return (queued + errors) != 0; in blk_mq_dispatch_rq_list()
[all …]
|
| D | bfq-iosched.c | 432 if (bfqd->queued != 0) { in bfq_schedule_dispatch()
1881 bfqq->queued[rq_is_sync(rq)]++; in bfq_add_request()
1882 bfqd->queued++; in bfq_add_request()
2174 bfqq->queued[sync]--; in bfq_remove_request()
2175 bfqd->queued--; in bfq_remove_request()
5385 bool small_req = bfqq->queued[rq_is_sync(rq)] == 1 && in bfq_rq_enqueued()
5603 if (bfqd->rq_in_driver + bfqd->queued <= BFQ_HW_QUEUE_THRESHOLD) in bfq_update_hw_tag()
5612 bfqq->dispatched + bfqq->queued[0] + bfqq->queued[1] < in bfq_update_hw_tag()
6262 else if (bfqq->queued[0] == 0 && bfqq->queued[1] == 0) in bfq_idle_slice_timer_body()
|
| D | blk-mq-debugfs.c | 585 seq_printf(m, "%lu\n", hctx->queued); in hctx_queued_show()
594 hctx->queued = 0; in hctx_queued_write()
|