Searched refs:nr_pending (Results 1 – 18 of 18) sorted by relevance
780 atomic_inc(&rdev->nr_pending); in read_balance()946 atomic_inc(&conf->nr_pending[idx]); in _wait_barrier()1415 atomic_inc(&rdev->nr_pending); in raid1_write_request()1426 atomic_inc(&rdev->nr_pending); in raid1_write_request()2305 atomic_inc(&rdev->nr_pending); in fix_read_error()2337 atomic_inc(&rdev->nr_pending); in fix_read_error()2354 atomic_inc(&rdev->nr_pending); in fix_read_error()2818 atomic_inc(&rdev->nr_pending); in raid1_sync_request()2985 if (!conf->nr_pending) in setup_conf()3099 kfree(conf->nr_pending); in setup_conf()[all …]
869 atomic_inc(&rdev->nr_pending); in read_balance()1014 atomic_inc(&conf->nr_pending); in wait_barrier_nolock()1047 atomic_inc(&conf->nr_pending); in wait_barrier()1350 atomic_inc(&rdev->nr_pending); in wait_blocked_dev()1355 atomic_inc(&rrdev->nr_pending); in wait_blocked_dev()1380 atomic_inc(&rdev->nr_pending); in wait_blocked_dev()1526 atomic_inc(&rdev->nr_pending); in raid10_write_request()1801 atomic_inc(&rdev->nr_pending); in raid10_handle_discard()2819 atomic_inc(&rdev->nr_pending); in fix_read_error()2853 atomic_inc(&rdev->nr_pending); in fix_read_error()[all …]
40 atomic_inc(&rdev->nr_pending); in multipath_map()254 atomic_read(&rdev->nr_pending)) { in multipath_remove_disk()262 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. member807 if (atomic_dec_and_test(&rdev->nr_pending) && faulty) { in rdev_dec_pending()
1201 atomic_inc(&rdev->nr_pending); in ops_run_io()1205 atomic_inc(&rrdev->nr_pending); in ops_run_io()1236 atomic_inc(&rdev->nr_pending); in ops_run_io()3668 atomic_inc(&rdev->nr_pending); in handle_failed_stripe()4775 atomic_inc(&rdev->nr_pending); in analyse_stripe()4813 atomic_inc(&rdev2->nr_pending); in analyse_stripe()4824 atomic_inc(&rdev2->nr_pending); in analyse_stripe()4833 atomic_inc(&rdev2->nr_pending); in analyse_stripe()5537 atomic_inc(&rdev->nr_pending); in raid5_read_one_chunk()8221 atomic_read(&rdev->nr_pending)) { in raid5_remove_disk()[all …]
1894 atomic_inc(&rdev->nr_pending); in r5l_recovery_replay_one_stripe()1904 atomic_inc(&rrdev->nr_pending); in r5l_recovery_replay_one_stripe()
553 atomic_inc(&rdev->nr_pending); in submit_flushes()554 atomic_inc(&rdev->nr_pending); in submit_flushes()958 atomic_inc(&rdev->nr_pending); in md_super_write()3618 atomic_set(&rdev->nr_pending, 0); in md_rdev_init()9142 atomic_read(&rdev->nr_pending)==0) { in remove_and_add_spares()9162 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
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()1123 if (!parent_sq->nr_pending) in throtl_select_dispatch()
63 unsigned int nr_pending; member
139 int nr_pending; member1045 match->nr_pending++; in io_acct_cancel_pending_work()1105 if (match.nr_pending && !match.cancel_all) in io_wq_cancel_cb()1117 if (match.nr_pending) in io_wq_cancel_cb()
951 local_t nr_pending; member
2260 local_dec(&event->ctx->nr_pending); in event_sched_out()3488 if (local_read(&ctx->nr_pending) || in perf_event_context_sched_out()3489 local_read(&next_ctx->nr_pending)) { in perf_event_context_sched_out()6674 local_dec(&event->ctx->nr_pending); in __perf_pending_irq()6747 local_dec(&event->ctx->nr_pending); in perf_pending_task()9523 local_inc(&event->ctx->nr_pending); in __perf_event_overflow()
Completed in 93 milliseconds