Home
last modified time | relevance | path

Searched refs:nr_queued (Results 1 - 13 of 13) sorted by relevance

/kernel/linux/linux-5.10/block/
H A Dblk-throttle.c83 unsigned int nr_queued[2]; /* number of queued bios */ member
210 unsigned int nr_queued[2]; member
1009 BUG_ON(tg->service_queue.nr_queued[rw] && in tg_may_dispatch()
1026 if (throtl_slice_used(tg, rw) && !(tg->service_queue.nr_queued[rw])) in tg_may_dispatch()
1101 if (!sq->nr_queued[rw]) in throtl_add_bio_tg()
1106 sq->nr_queued[rw]++; in throtl_add_bio_tg()
1161 sq->nr_queued[rw]--; in tg_dispatch_one_bio()
1178 BUG_ON(tg->td->nr_queued[rw] <= 0); in tg_dispatch_one_bio()
1179 tg->td->nr_queued[rw]--; in tg_dispatch_one_bio()
1244 if (sq->nr_queued[ in throtl_select_dispatch()
[all...]
/kernel/linux/linux-6.6/block/
H A Dblk-throttle.c67 unsigned int nr_queued[2]; member
820 if (tg->service_queue.nr_queued[READ]) in tg_update_carryover()
822 if (tg->service_queue.nr_queued[WRITE]) in tg_update_carryover()
915 BUG_ON(tg->service_queue.nr_queued[rw] && in tg_may_dispatch()
933 if (throtl_slice_used(tg, rw) && !(tg->service_queue.nr_queued[rw])) in tg_may_dispatch()
1000 if (!sq->nr_queued[rw]) in throtl_add_bio_tg()
1005 sq->nr_queued[rw]++; in throtl_add_bio_tg()
1060 sq->nr_queued[rw]--; in tg_dispatch_one_bio()
1078 BUG_ON(tg->td->nr_queued[rw] <= 0); in tg_dispatch_one_bio()
1079 tg->td->nr_queued[r in tg_dispatch_one_bio()
[all...]
H A Dblk-throttle.h43 unsigned int nr_queued[2]; /* number of queued bios */ member
/kernel/linux/linux-5.10/drivers/md/
H A Draid10.h83 int nr_queued; member
H A Draid1.h16 * atomic_t *nr_queued;
103 atomic_t *nr_queued; member
H A Draid1.c284 atomic_inc(&conf->nr_queued[idx]); in reschedule_retry()
1050 atomic_read(&conf->nr_queued[idx]); in get_unqueued_pending()
1071 * of all conf->nr_queued[]. But normal I/O failure is an exception, in freeze_array()
2450 atomic_inc(&conf->nr_queued[idx]); in handle_write_finished()
2531 atomic_dec(&conf->nr_queued[idx]); in raid1d()
2553 atomic_dec(&conf->nr_queued[idx]); in raid1d()
2946 conf->nr_queued = kcalloc(BARRIER_BUCKETS_NR, in setup_conf()
2948 if (!conf->nr_queued) in setup_conf()
3055 kfree(conf->nr_queued); in setup_conf()
3177 kfree(conf->nr_queued); in raid1_free()
[all...]
H A Draid10.c278 conf->nr_queued ++; in reschedule_retry()
991 conf->nr_queued > 0), in wait_barrier()
1013 * wait until nr_pending match nr_queued+extra in freeze_array()
1018 * Thus the number queued (nr_queued) plus this request (extra) in freeze_array()
1027 atomic_read(&conf->nr_pending) == conf->nr_queued+extra, in freeze_array()
2700 conf->nr_queued++; in handle_write_completed()
2704 * nr_pending == nr_queued + extra to be true. in handle_write_completed()
2735 conf->nr_queued--; in raid10d()
2765 conf->nr_queued--; in raid10d()
/kernel/linux/linux-6.6/drivers/md/
H A Draid1.h16 * atomic_t *nr_queued;
102 atomic_t *nr_queued; member
H A Draid10.h82 int nr_queued; member
H A Draid1.c288 atomic_inc(&conf->nr_queued[idx]); in reschedule_retry()
1070 atomic_read(&conf->nr_queued[idx]); in get_unqueued_pending()
1091 * of all conf->nr_queued[]. But normal I/O failure is an exception, in freeze_array()
2492 atomic_inc(&conf->nr_queued[idx]); in handle_write_finished()
2575 atomic_dec(&conf->nr_queued[idx]); in raid1d()
2597 atomic_dec(&conf->nr_queued[idx]); in raid1d()
2990 conf->nr_queued = kcalloc(BARRIER_BUCKETS_NR, in setup_conf()
2992 if (!conf->nr_queued) in setup_conf()
3099 kfree(conf->nr_queued); in setup_conf()
3207 kfree(conf->nr_queued); in raid1_free()
[all...]
H A Draid10.c306 conf->nr_queued ++; in reschedule_retry()
1069 * wait until nr_pending match nr_queued+extra in freeze_array()
1074 * Thus the number queued (nr_queued) plus this request (extra) in freeze_array()
1083 conf->nr_queued + extra, flush_pending_writes(conf)); in freeze_array()
3086 conf->nr_queued++; in handle_write_completed()
3090 * nr_pending == nr_queued + extra to be true. in handle_write_completed()
3121 conf->nr_queued--; in raid10d()
3151 conf->nr_queued--; in raid10d()
/kernel/linux/linux-6.6/include/ufs/
H A Dufshcd.h744 u32 nr_queued[2]; member
/kernel/linux/linux-6.6/drivers/ufs/core/
H A Dufshcd.c2113 if (dir >= 0 && hba->monitor.nr_queued[dir]++ == 0) in ufshcd_start_monitor()
2124 if (dir >= 0 && hba->monitor.nr_queued[dir] > 0) { in ufshcd_update_monitor()
2143 m->nr_queued[dir]--; in ufshcd_update_monitor()

Completed in 43 milliseconds