Searched refs:nr_queued (Results 1 – 8 of 8) sorted by relevance
67 unsigned int nr_queued[2]; member813 if (tg->service_queue.nr_queued[READ]) in tg_update_carryover()815 if (tg->service_queue.nr_queued[WRITE]) in tg_update_carryover()922 BUG_ON(tg->service_queue.nr_queued[rw] && in tg_may_dispatch()940 if (throtl_slice_used(tg, rw) && !(tg->service_queue.nr_queued[rw])) in tg_may_dispatch()1006 if (!sq->nr_queued[rw]) in throtl_add_bio_tg()1011 sq->nr_queued[rw]++; in throtl_add_bio_tg()1066 sq->nr_queued[rw]--; in tg_dispatch_one_bio()1084 BUG_ON(tg->td->nr_queued[rw] <= 0); in tg_dispatch_one_bio()1085 tg->td->nr_queued[rw]--; in tg_dispatch_one_bio()[all …]
43 unsigned int nr_queued[2]; /* number of queued bios */ member
102 atomic_t *nr_queued; member
82 int nr_queued; member
288 atomic_inc(&conf->nr_queued[idx]); in reschedule_retry()1074 atomic_read(&conf->nr_queued[idx]); in get_unqueued_pending()2497 atomic_inc(&conf->nr_queued[idx]); in handle_write_finished()2578 atomic_dec(&conf->nr_queued[idx]); in raid1d()2600 atomic_dec(&conf->nr_queued[idx]); in raid1d()2993 conf->nr_queued = kcalloc(BARRIER_BUCKETS_NR, in setup_conf()2995 if (!conf->nr_queued) in setup_conf()3101 kfree(conf->nr_queued); in setup_conf()3209 kfree(conf->nr_queued); in raid1_free()
306 conf->nr_queued ++; in reschedule_retry()1001 conf->nr_queued > 0) in stop_waiting_barrier()1078 conf->nr_queued + extra, flush_pending_writes(conf)); in freeze_array()3070 conf->nr_queued++; in handle_write_completed()3105 conf->nr_queued--; in raid10d()3135 conf->nr_queued--; in raid10d()
719 u32 nr_queued[2]; member
2096 if (dir >= 0 && hba->monitor.nr_queued[dir]++ == 0) in ufshcd_start_monitor()2107 if (dir >= 0 && hba->monitor.nr_queued[dir] > 0) { in ufshcd_update_monitor()2126 m->nr_queued[dir]--; in ufshcd_update_monitor()