Searched refs:nr_pending (Results 1 – 15 of 15) sorted by relevance
709 pending = atomic_read(&rdev->nr_pending); in read_balance()777 atomic_inc(&rdev->nr_pending); in read_balance()903 !atomic_read(&conf->nr_pending[idx]) && in raise_barrier()942 atomic_inc(&conf->nr_pending[idx]); in _wait_barrier()975 atomic_dec(&conf->nr_pending[idx]); in _wait_barrier()986 atomic_inc(&conf->nr_pending[idx]); in _wait_barrier()1002 atomic_inc(&conf->nr_pending[idx]); in wait_read_barrier()1009 atomic_dec(&conf->nr_pending[idx]); in wait_read_barrier()1019 atomic_inc(&conf->nr_pending[idx]); in wait_read_barrier()1033 atomic_dec(&conf->nr_pending[idx]); in _allow_barrier()[all …]
801 pending = atomic_read(&rdev->nr_pending); in read_balance()842 atomic_inc(&rdev->nr_pending); in read_balance()940 !atomic_read(&conf->nr_pending) && conf->barrier < RESYNC_DEPTH, in raise_barrier()973 (atomic_read(&conf->nr_pending) && in wait_barrier()989 atomic_inc(&conf->nr_pending); in wait_barrier()995 if ((atomic_dec_and_test(&conf->nr_pending)) || in allow_barrier()1019 atomic_read(&conf->nr_pending) == conf->nr_queued+extra, in freeze_array()1296 atomic_inc(&rdev->nr_pending); in wait_blocked_dev()1301 atomic_inc(&rrdev->nr_pending); in wait_blocked_dev()1326 atomic_inc(&rdev->nr_pending); in wait_blocked_dev()[all …]
101 atomic_t *nr_pending; member
81 atomic_t nr_pending; member
40 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()
108 atomic_t nr_pending; /* number of pending requests. member779 if (atomic_dec_and_test(&rdev->nr_pending) && faulty) { in rdev_dec_pending()
1123 atomic_inc(&rdev->nr_pending); in ops_run_io()1127 atomic_inc(&rrdev->nr_pending); in ops_run_io()1158 atomic_inc(&rdev->nr_pending); in ops_run_io()3566 atomic_inc(&rdev->nr_pending); in handle_failed_stripe()4672 atomic_inc(&rdev->nr_pending); in analyse_stripe()4710 atomic_inc(&rdev2->nr_pending); in analyse_stripe()4721 atomic_inc(&rdev2->nr_pending); in analyse_stripe()4730 atomic_inc(&rdev2->nr_pending); in analyse_stripe()5431 atomic_inc(&rdev->nr_pending); in raid5_read_one_chunk()7920 atomic_read(&rdev->nr_pending)) { in raid5_remove_disk()[all …]
1901 atomic_inc(&rdev->nr_pending); in r5l_recovery_replay_one_stripe()1911 atomic_inc(&rrdev->nr_pending); in r5l_recovery_replay_one_stripe()
556 atomic_inc(&rdev->nr_pending); in submit_flushes()557 atomic_inc(&rdev->nr_pending); in submit_flushes()963 atomic_inc(&rdev->nr_pending); in md_super_write()3664 atomic_set(&rdev->nr_pending, 0); in md_rdev_init()9091 atomic_read(&rdev->nr_pending)==0) { in remove_and_add_spares()9111 atomic_read(&rdev->nr_pending)==0)) { in remove_and_add_spares()
203 atomic_inc(&rdev->nr_pending); in next_active_rdev()
714 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()
186 return watch->nr_pending == 0; in frontend_will_handle()
63 unsigned int nr_pending; member
134 int nr_pending; member958 match->nr_pending++; in io_acct_cancel_pending_work()1011 if (match.nr_pending && !match.cancel_all) in io_wq_cancel_cb()1031 if (match.nr_pending) in io_wq_cancel_cb()
89 unsigned int nr_pending; /* # queued in the tree */ member663 --parent_sq->nr_pending; in throtl_rb_erase()708 tg->service_queue.parent_sq->nr_pending++; in throtl_enqueue_tg()762 if (!sq->nr_pending) in throtl_schedule_next_dispatch()1236 if (!parent_sq->nr_pending) in throtl_select_dispatch()
