Searched refs:nr_pending (Results 1 – 15 of 15) sorted by relevance
583 atomic_inc(&info->rdev->nr_pending); in update_read_sectors()793 pending = atomic_read(&rdev->nr_pending); in choose_best_rdev()1001 !atomic_read(&conf->nr_pending[idx]) && in raise_barrier()1042 atomic_inc(&conf->nr_pending[idx]); in _wait_barrier()1075 atomic_dec(&conf->nr_pending[idx]); in _wait_barrier()1091 atomic_inc(&conf->nr_pending[idx]); in _wait_barrier()1111 atomic_inc(&conf->nr_pending[idx]); in wait_read_barrier()1118 atomic_dec(&conf->nr_pending[idx]); in wait_read_barrier()1134 atomic_inc(&conf->nr_pending[idx]); in wait_read_barrier()1151 atomic_dec(&conf->nr_pending[idx]); in _allow_barrier()[all …]
811 pending = atomic_read(&rdev->nr_pending); in read_balance()852 atomic_inc(&rdev->nr_pending); in read_balance()938 wait_event_barrier(conf, !atomic_read(&conf->nr_pending) && in raise_barrier()969 if (atomic_read(&conf->nr_pending) && bio_list && in stop_waiting_barrier()981 WARN_ON_ONCE(atomic_read(&conf->nr_pending) == 0); in stop_waiting_barrier()995 atomic_inc(&conf->nr_pending); in wait_barrier_nolock()999 if (atomic_dec_and_test(&conf->nr_pending)) in wait_barrier_nolock()1028 atomic_inc(&conf->nr_pending); in wait_barrier()1035 if ((atomic_dec_and_test(&conf->nr_pending)) || in allow_barrier()1058 wait_event_barrier_cmd(conf, atomic_read(&conf->nr_pending) == in freeze_array()[all …]
85 atomic_t *nr_pending; member
75 atomic_t nr_pending; member
196 atomic_t nr_pending; /* number of pending requests. member972 if (atomic_dec_and_test(&rdev->nr_pending) && faulty) { in rdev_dec_pending()
1205 atomic_inc(&rdev->nr_pending); in ops_run_io()1209 atomic_inc(&rrdev->nr_pending); in ops_run_io()1237 atomic_inc(&rdev->nr_pending); in ops_run_io()3599 atomic_inc(&rdev->nr_pending); in handle_failed_stripe()4694 atomic_inc(&rdev->nr_pending); in analyse_stripe()4744 atomic_inc(&rdev2->nr_pending); in analyse_stripe()4755 atomic_inc(&rdev2->nr_pending); in analyse_stripe()4764 atomic_inc(&rdev2->nr_pending); in analyse_stripe()5449 atomic_inc(&rdev->nr_pending); in raid5_read_one_chunk()8241 atomic_read(&rdev->nr_pending)) { in raid5_remove_disk()
1890 atomic_inc(&rdev->nr_pending); in r5l_recovery_replay_one_stripe()1898 atomic_inc(&rrdev->nr_pending); in r5l_recovery_replay_one_stripe()
396 atomic_inc(&rdev->nr_pending); in next_active_rdev()
1144 atomic_inc(&rdev->nr_pending); in md_write_metadata()3789 atomic_set(&rdev->nr_pending, 0); in md_rdev_init()9827 if (atomic_read(&rdev->nr_pending)) in rdev_removeable()
705 event->handle->nr_pending++; in xs_watch_msg()740 watch->nr_pending = 0; in register_xenbus_watch()791 if (watch->nr_pending) { in unregister_xenbus_watch()798 watch->nr_pending = 0; in unregister_xenbus_watch()863 event->handle->nr_pending--; in xenwatch_thread()
186 return watch->nr_pending == 0; in frontend_will_handle()
53 unsigned int nr_pending; /* # queued in the tree */ member
427 tg->service_queue.parent_sq->nr_pending++; in throtl_enqueue_tg()438 --parent_sq->nr_pending; in throtl_dequeue_tg()485 if (!sq->nr_pending) in throtl_schedule_next_dispatch()1079 if (!parent_sq->nr_pending) in throtl_select_dispatch()
143 int nr_pending; member1150 match->nr_pending++; in io_acct_cancel_pending_work()1217 if (match.nr_pending && !match.cancel_all) in io_wq_cancel_cb()1226 if (match.nr_pending) in io_wq_cancel_cb()
63 unsigned int nr_pending; member