Home
last modified time | relevance | path

Searched refs:nr_pending (Results 1 - 25 of 35) sorted by relevance

12

/kernel/linux/linux-5.10/block/
H A Dblk-pm.h30 rq->q->nr_pending--; in blk_pm_requeue_request()
39 q->nr_pending++; in blk_pm_add_request()
47 --rq->q->nr_pending; in blk_pm_put_request()
H A Dblk-throttle.c90 unsigned int nr_pending; /* # queued in the tree */ member
658 --parent_sq->nr_pending; in throtl_rb_erase()
703 tg->service_queue.parent_sq->nr_pending++; in throtl_enqueue_tg()
757 if (!sq->nr_pending) in throtl_schedule_next_dispatch()
1229 if (!parent_sq->nr_pending) in throtl_select_dispatch()
/kernel/linux/linux-5.10/drivers/md/
H A Draid1.c592 * The rdev for the device selected will have nr_pending incremented.
707 pending = atomic_read(&rdev->nr_pending); in read_balance()
775 atomic_inc(&rdev->nr_pending); in read_balance()
853 * i.e. if nr_pending == 0.
884 * check conf->nr_pending[idx]. In _wait_barrier() we firstly in raise_barrier()
885 * increase conf->nr_pending[idx] then check conf->barrier[idx]. in raise_barrier()
886 * A memory barrier here to make sure conf->nr_pending[idx] won't in raise_barrier()
894 * B: while conf->nr_pending[idx] is not 0, meaning regular I/O in raise_barrier()
901 !atomic_read(&conf->nr_pending[idx]) && in raise_barrier()
933 * We need to increase conf->nr_pending[id in _wait_barrier()
[all...]
H A Draid10.h12 * and if it is non-NULL, increment rdev->nr_pending before dropping the
14 * When .rdev is set to NULL, the nr_pending count checked again and if it has
81 atomic_t nr_pending; member
H A Draid1.h14 * atomic_t *nr_pending;
35 * and if it is non-NULL, increment rdev->nr_pending before dropping the
37 * When .rdev is set to NULL, the nr_pending count checked again and if it has
101 atomic_t *nr_pending; member
H A Draid10.c696 * The rdev for the device selected will have nr_pending incremented.
808 pending = atomic_read(&rdev->nr_pending); in read_balance()
849 atomic_inc(&rdev->nr_pending); in read_balance()
920 * i.e. if nr_pending == 0.
948 !atomic_read(&conf->nr_pending) && conf->barrier < RESYNC_DEPTH, in raise_barrier()
975 * that queue to get the nr_pending in wait_barrier()
981 (atomic_read(&conf->nr_pending) && in wait_barrier()
997 atomic_inc(&conf->nr_pending); in wait_barrier()
1003 if ((atomic_dec_and_test(&conf->nr_pending)) || in allow_barrier()
1013 * wait until nr_pending matc in freeze_array()
[all...]
H A Dmd-multipath.c40 atomic_inc(&rdev->nr_pending); in multipath_map()
260 atomic_read(&rdev->nr_pending)) { in multipath_remove_disk()
268 if (atomic_read(&rdev->nr_pending)) { in multipath_remove_disk()
H A Dmd.h108 atomic_t nr_pending; /* number of pending requests. member
773 if (atomic_dec_and_test(&rdev->nr_pending) && faulty) { in rdev_dec_pending()
/kernel/linux/linux-6.6/drivers/md/
H A Draid1.c596 * The rdev for the device selected will have nr_pending incremented.
711 pending = atomic_read(&rdev->nr_pending); in read_balance()
779 atomic_inc(&rdev->nr_pending); in read_balance()
853 * i.e. if nr_pending == 0.
884 * check conf->nr_pending[idx]. In _wait_barrier() we firstly in raise_barrier()
885 * increase conf->nr_pending[idx] then check conf->barrier[idx]. in raise_barrier()
886 * A memory barrier here to make sure conf->nr_pending[idx] won't in raise_barrier()
894 * B: while conf->nr_pending[idx] is not 0, meaning regular I/O in raise_barrier()
901 !atomic_read(&conf->nr_pending[idx]) && in raise_barrier()
935 * We need to increase conf->nr_pending[id in _wait_barrier()
[all...]
H A Draid10.c722 * The rdev for the device selected will have nr_pending incremented.
834 pending = atomic_read(&rdev->nr_pending); in read_balance()
875 atomic_inc(&rdev->nr_pending); in read_balance()
934 * i.e. if nr_pending == 0.
962 wait_event_barrier(conf, !atomic_read(&conf->nr_pending) && in raise_barrier()
990 * don't wait, as we need to empty that queue to get the nr_pending in stop_waiting_barrier()
993 if (atomic_read(&conf->nr_pending) && bio_list && in stop_waiting_barrier()
1000 * move on if io is issued from raid10d(), nr_pending is not released in stop_waiting_barrier()
1005 WARN_ON_ONCE(atomic_read(&conf->nr_pending) == 0); in stop_waiting_barrier()
1019 atomic_inc(&conf->nr_pending); in wait_barrier_nolock()
[all...]
H A Draid1.h14 * atomic_t *nr_pending;
35 * and if it is non-NULL, increment rdev->nr_pending before dropping the
37 * When .rdev is set to NULL, the nr_pending count checked again and if it has
100 atomic_t *nr_pending; member
H A Draid10.h12 * and if it is non-NULL, increment rdev->nr_pending before dropping the
14 * When .rdev is set to NULL, the nr_pending count checked again and if it has
80 atomic_t nr_pending; member
H A Dmd-multipath.c40 atomic_inc(&rdev->nr_pending); in multipath_map()
255 atomic_read(&rdev->nr_pending)) { in multipath_remove_disk()
263 if (atomic_read(&rdev->nr_pending)) { in multipath_remove_disk()
H A Dmd.h108 atomic_t nr_pending; /* number of pending requests. member
829 if (atomic_dec_and_test(&rdev->nr_pending) && faulty) { in rdev_dec_pending()
H A Draid5.c1208 atomic_inc(&rdev->nr_pending); in ops_run_io()
1212 atomic_inc(&rrdev->nr_pending); in ops_run_io()
1240 * will dec nr_pending, we must in ops_run_io()
1243 atomic_inc(&rdev->nr_pending); in ops_run_io()
2736 * it is known that the nr_pending of the rdev is elevated.
2741 atomic_read(&rcu_access_pointer(rdev)->nr_pending)); in rdev_pend_deref()
3675 atomic_inc(&rdev->nr_pending); in handle_failed_stripe()
4782 atomic_inc(&rdev->nr_pending); in analyse_stripe()
4820 atomic_inc(&rdev2->nr_pending); in analyse_stripe()
4831 atomic_inc(&rdev2->nr_pending); in analyse_stripe()
[all...]
/kernel/linux/linux-5.10/drivers/xen/xenbus/
H A Dxenbus_xs.c714 event->handle->nr_pending++; in xs_watch_msg()
772 watch->nr_pending = 0; in register_xenbus_watch()
823 if (watch->nr_pending) { in unregister_xenbus_watch()
830 watch->nr_pending = 0; in unregister_xenbus_watch()
895 event->handle->nr_pending--; in xenwatch_thread()
H A Dxenbus_probe_backend.c186 return watch->nr_pending == 0; in frontend_will_handle()
/kernel/linux/linux-6.6/drivers/xen/xenbus/
H A Dxenbus_xs.c714 event->handle->nr_pending++; in xs_watch_msg()
772 watch->nr_pending = 0; in register_xenbus_watch()
823 if (watch->nr_pending) { in unregister_xenbus_watch()
830 watch->nr_pending = 0; in unregister_xenbus_watch()
895 event->handle->nr_pending--; in xenwatch_thread()
H A Dxenbus_probe_backend.c186 return watch->nr_pending == 0; in frontend_will_handle()
/kernel/linux/linux-6.6/block/
H A Dblk-throttle.h50 unsigned int nr_pending; /* # queued in the tree */ member
H A Dblk-throttle.c560 tg->service_queue.parent_sq->nr_pending++; in throtl_enqueue_tg()
571 --parent_sq->nr_pending; in throtl_dequeue_tg()
618 if (!sq->nr_pending) in throtl_schedule_next_dispatch()
1129 if (!parent_sq->nr_pending) in throtl_select_dispatch()
/kernel/linux/linux-5.10/include/xen/
H A Dxenbus.h64 unsigned int nr_pending; member
/kernel/linux/linux-6.6/include/xen/
H A Dxenbus.h63 unsigned int nr_pending; member
/kernel/linux/linux-5.10/io_uring/
H A Dio-wq.c134 int nr_pending; member
1036 match->nr_pending++;
1089 if (match.nr_pending && !match.cancel_all) in io_wq_cancel_cb()
1109 if (match.nr_pending) in io_wq_cancel_cb()
/kernel/linux/linux-6.6/io_uring/
H A Dio-wq.c132 int nr_pending; member
1050 match->nr_pending++; in io_acct_cancel_pending_work()
1106 if (match.nr_pending && !match.cancel_all) in io_wq_cancel_cb()
1117 if (match.nr_pending) in io_wq_cancel_cb()

Completed in 40 milliseconds

12