Searched refs:nr_pending (Results 1 – 18 of 18) sorted by relevance
706 pending = atomic_read(&rdev->nr_pending); in read_balance()774 atomic_inc(&rdev->nr_pending); in read_balance()896 !atomic_read(&conf->nr_pending[idx]) && in raise_barrier()937 atomic_inc(&conf->nr_pending[idx]); in _wait_barrier()970 atomic_dec(&conf->nr_pending[idx]); in _wait_barrier()986 atomic_inc(&conf->nr_pending[idx]); in _wait_barrier()1006 atomic_inc(&conf->nr_pending[idx]); in wait_read_barrier()1013 atomic_dec(&conf->nr_pending[idx]); in wait_read_barrier()1029 atomic_inc(&conf->nr_pending[idx]); in wait_read_barrier()1046 atomic_dec(&conf->nr_pending[idx]); in _allow_barrier()[all …]
828 pending = atomic_read(&rdev->nr_pending); in read_balance()869 atomic_inc(&rdev->nr_pending); in read_balance()956 wait_event_barrier(conf, !atomic_read(&conf->nr_pending) && in raise_barrier()987 if (atomic_read(&conf->nr_pending) && bio_list && in stop_waiting_barrier()999 WARN_ON_ONCE(atomic_read(&conf->nr_pending) == 0); in stop_waiting_barrier()1013 atomic_inc(&conf->nr_pending); in wait_barrier_nolock()1017 if (atomic_dec_and_test(&conf->nr_pending)) in wait_barrier_nolock()1046 atomic_inc(&conf->nr_pending); in wait_barrier()1053 if ((atomic_dec_and_test(&conf->nr_pending)) || in allow_barrier()1076 wait_event_barrier_cmd(conf, atomic_read(&conf->nr_pending) == in freeze_array()[all …]
40 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()
100 atomic_t *nr_pending; member
80 atomic_t nr_pending; member
108 atomic_t nr_pending; /* number of pending requests. member837 if (atomic_dec_and_test(&rdev->nr_pending) && faulty) { in rdev_dec_pending()
1206 atomic_inc(&rdev->nr_pending); in ops_run_io()1210 atomic_inc(&rrdev->nr_pending); in ops_run_io()1241 atomic_inc(&rdev->nr_pending); in ops_run_io()2737 atomic_read(&rcu_access_pointer(rdev)->nr_pending)); in rdev_pend_deref()3649 atomic_inc(&rdev->nr_pending); in handle_failed_stripe()4741 atomic_inc(&rdev->nr_pending); in analyse_stripe()4779 atomic_inc(&rdev2->nr_pending); in analyse_stripe()4790 atomic_inc(&rdev2->nr_pending); in analyse_stripe()4799 atomic_inc(&rdev2->nr_pending); in analyse_stripe()5491 atomic_inc(&rdev->nr_pending); in raid5_read_one_chunk()[all …]
1893 atomic_inc(&rdev->nr_pending); in r5l_recovery_replay_one_stripe()1903 atomic_inc(&rrdev->nr_pending); in r5l_recovery_replay_one_stripe()
516 atomic_inc(&rdev->nr_pending); in submit_flushes()963 atomic_inc(&rdev->nr_pending); in md_super_write()3669 atomic_set(&rdev->nr_pending, 0); in md_rdev_init()9256 atomic_read(&rdev->nr_pending)==0) { in remove_and_add_spares()9276 atomic_read(&rdev->nr_pending)==0)) { in remove_and_add_spares()
193 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
560 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()
63 unsigned int nr_pending; member
135 int nr_pending; member1059 match->nr_pending++; in io_acct_cancel_pending_work()1115 if (match.nr_pending && !match.cancel_all) in io_wq_cancel_cb()1126 if (match.nr_pending) in io_wq_cancel_cb()
968 local_t nr_pending; member
2298 local_dec(&event->ctx->nr_pending); in event_sched_out() 3532 /* PMIs are disabled; ctx->nr_pending is stable. */ in perf_event_context_sched_out() 3533 if (local_read(&ctx->nr_pending) || in perf_event_context_sched_out() 3534 local_read(&next_ctx->nr_pending)) { in perf_event_context_sched_out() 5202 local_dec(&event->ctx->nr_pending); in perf_pending_task_sync() 6794 local_dec(&event->ctx->nr_pending); in __perf_pending_irq() 6872 local_dec(&event->ctx->nr_pending); in perf_pending_task() 9639 local_inc(&event->ctx->nr_pending); in __perf_event_overflow()