Lines Matching refs:nr_pending
722 * The rdev for the device selected will have nr_pending incremented.
834 pending = atomic_read(&rdev->nr_pending);
875 atomic_inc(&rdev->nr_pending);
934 * i.e. if nr_pending == 0.
962 wait_event_barrier(conf, !atomic_read(&conf->nr_pending) &&
990 * don't wait, as we need to empty that queue to get the nr_pending
993 if (atomic_read(&conf->nr_pending) && bio_list &&
1000 * move on if io is issued from raid10d(), nr_pending is not released
1005 WARN_ON_ONCE(atomic_read(&conf->nr_pending) == 0);
1019 atomic_inc(&conf->nr_pending);
1023 if (atomic_dec_and_test(&conf->nr_pending))
1050 /* Only increment nr_pending when we wait */
1052 atomic_inc(&conf->nr_pending);
1059 if ((atomic_dec_and_test(&conf->nr_pending)) ||
1069 * wait until nr_pending match nr_queued+extra
1072 * will be blocked by nr_pending, and we need to wait for
1075 * must match the number of pending IOs (nr_pending) before
1082 wait_event_barrier_cmd(conf, atomic_read(&conf->nr_pending) ==
1357 atomic_inc(&rdev->nr_pending);
1362 atomic_inc(&rrdev->nr_pending);
1387 atomic_inc(&rdev->nr_pending);
1531 atomic_inc(&rdev->nr_pending);
1535 atomic_inc(&rrdev->nr_pending);
1805 atomic_inc(&rdev->nr_pending);
1809 atomic_inc(&rrdev->nr_pending);
1849 * add rdev->nr_pending in the first loop.
2234 atomic_read(&rdev->nr_pending)) {
2252 if (atomic_read(&rdev->nr_pending)) {
2488 atomic_inc(&conf->mirrors[d].rdev->nr_pending);
2646 atomic_inc(&conf->mirrors[d].rdev->nr_pending);
2651 atomic_inc(&conf->mirrors[d].replacement->nr_pending);
2778 atomic_inc(&rdev->nr_pending);
2831 atomic_inc(&rdev->nr_pending);
2865 atomic_inc(&rdev->nr_pending);
3090 * nr_pending == nr_queued + extra to be true.
3503 atomic_inc(&mrdev->nr_pending);
3505 atomic_inc(&mreplace->nr_pending);
3577 atomic_inc(&rdev->nr_pending);
3769 atomic_inc(&rdev->nr_pending);
3786 atomic_inc(&rdev->nr_pending);
4121 atomic_set(&conf->nr_pending, 0);
5088 atomic_inc(&rdev->nr_pending);
5171 atomic_inc(&rdev->nr_pending);