Searched refs:nr_pending (Results 1 – 16 of 16) sorted by relevance
777 atomic_inc(&rdev->nr_pending); in read_balance()942 atomic_inc(&conf->nr_pending[idx]); in _wait_barrier()1395 atomic_inc(&rdev->nr_pending); in raid1_write_request()1406 atomic_inc(&rdev->nr_pending); in raid1_write_request()2278 atomic_inc(&rdev->nr_pending); in fix_read_error()2310 atomic_inc(&rdev->nr_pending); in fix_read_error()2328 atomic_inc(&rdev->nr_pending); in fix_read_error()2793 atomic_inc(&rdev->nr_pending); in raid1_sync_request()2960 if (!conf->nr_pending) in setup_conf()3075 kfree(conf->nr_pending); in setup_conf()[all …]
842 atomic_inc(&rdev->nr_pending); in read_balance()989 atomic_inc(&conf->nr_pending); in wait_barrier()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()1467 atomic_inc(&rdev->nr_pending); in raid10_write_request()1471 atomic_inc(&rrdev->nr_pending); in raid10_write_request()1738 atomic_inc(&rdev->nr_pending); in raid10_handle_discard()2754 atomic_inc(&rdev->nr_pending); in fix_read_error()2790 atomic_inc(&rdev->nr_pending); in fix_read_error()[all …]
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()
101 atomic_t *nr_pending; member
81 atomic_t nr_pending; member
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()7917 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()962 atomic_inc(&rdev->nr_pending); in md_super_write()3670 atomic_set(&rdev->nr_pending, 0); in md_rdev_init()9105 atomic_read(&rdev->nr_pending)==0) { in remove_and_add_spares()9125 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()
50 unsigned int nr_pending; /* # queued in the tree */ member
516 --parent_sq->nr_pending; in throtl_rb_erase()561 tg->service_queue.parent_sq->nr_pending++; in throtl_enqueue_tg()615 if (!sq->nr_pending) in throtl_schedule_next_dispatch()1089 if (!parent_sq->nr_pending) in throtl_select_dispatch()
135 int nr_pending; member1029 match->nr_pending++; in io_acct_cancel_pending_work()1082 if (match.nr_pending && !match.cancel_all) in io_wq_cancel_cb()1102 if (match.nr_pending) in io_wq_cancel_cb()
63 unsigned int nr_pending; member
Completed in 68 milliseconds