Searched refs:nr_pending (Results 1 – 9 of 9) sorted by relevance
582 atomic_inc(&info->rdev->nr_pending); in update_read_sectors()792 pending = atomic_read(&rdev->nr_pending); in choose_best_rdev()1000 !atomic_read(&conf->nr_pending[idx]) && in raise_barrier()1041 atomic_inc(&conf->nr_pending[idx]); in _wait_barrier()1074 atomic_dec(&conf->nr_pending[idx]); in _wait_barrier()1090 atomic_inc(&conf->nr_pending[idx]); in _wait_barrier()1110 atomic_inc(&conf->nr_pending[idx]); in wait_read_barrier()1117 atomic_dec(&conf->nr_pending[idx]); in wait_read_barrier()1133 atomic_inc(&conf->nr_pending[idx]); in wait_read_barrier()1150 atomic_dec(&conf->nr_pending[idx]); in _allow_barrier()[all …]
807 pending = atomic_read(&rdev->nr_pending); in read_balance()848 atomic_inc(&rdev->nr_pending); in read_balance()934 wait_event_barrier(conf, !atomic_read(&conf->nr_pending) && in raise_barrier()965 if (atomic_read(&conf->nr_pending) && bio_list && in stop_waiting_barrier()977 WARN_ON_ONCE(atomic_read(&conf->nr_pending) == 0); in stop_waiting_barrier()991 atomic_inc(&conf->nr_pending); in wait_barrier_nolock()995 if (atomic_dec_and_test(&conf->nr_pending)) in wait_barrier_nolock()1024 atomic_inc(&conf->nr_pending); in wait_barrier()1031 if ((atomic_dec_and_test(&conf->nr_pending)) || in allow_barrier()1054 wait_event_barrier_cmd(conf, atomic_read(&conf->nr_pending) == in freeze_array()[all …]
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()
16 size_t __percpu *nr_pending; member
100 this_cpu_dec(*c->btree_key_cache.nr_pending); in __bkey_cached_free()116 this_cpu_inc(*bc->nr_pending); in bkey_cached_free()780 free_percpu(bc->nr_pending); in bch2_fs_btree_key_cache_exit()792 bc->nr_pending = alloc_percpu(size_t); in bch2_fs_btree_key_cache_init()793 if (!bc->nr_pending) in bch2_fs_btree_key_cache_init()834 prt_printf(out, "pending:\t%zu\r\n", per_cpu_sum(bc->nr_pending)); in bch2_btree_key_cache_to_text()
50 unsigned int nr_pending; /* # queued in the tree */ member
63 unsigned int nr_pending; member
134 int nr_pending; member1070 match->nr_pending++; in io_acct_cancel_pending_work()1126 if (match.nr_pending && !match.cancel_all) in io_wq_cancel_cb()1137 if (match.nr_pending) in io_wq_cancel_cb()