Searched refs:set_remaining (Results 1 – 3 of 3) sorted by relevance
168 i = atomic_read(&set->set_remaining); in ptlrpcd_add_rqset()170 atomic_set(&set->set_remaining, 0); in ptlrpcd_add_rqset()204 atomic_add(rc, &des->set_remaining); in ptlrpcd_steal_rqset()237 atomic_inc(&req->rq_set->set_remaining); in ptlrpcd_add_req()277 &set->set_remaining); in ptlrpcd_check()306 if (atomic_read(&set->set_remaining)) in ptlrpcd_check()
866 atomic_set(&set->set_remaining, 0); in ptlrpc_prep_set()921 expected_phase = (atomic_read(&set->set_remaining) == 0) ? in ptlrpc_set_destroy()932 LASSERTF(atomic_read(&set->set_remaining) == 0 || in ptlrpc_set_destroy()933 atomic_read(&set->set_remaining) == n, "%d / %d\n", in ptlrpc_set_destroy()934 atomic_read(&set->set_remaining), n); in ptlrpc_set_destroy()946 atomic_dec(&set->set_remaining); in ptlrpc_set_destroy()957 LASSERT(atomic_read(&set->set_remaining) == 0); in ptlrpc_set_destroy()997 atomic_inc(&set->set_remaining); in ptlrpc_set_add_req()1485 remaining = atomic_read(&set->set_remaining); in ptlrpc_set_producer()1489 while (atomic_read(&set->set_remaining) < set->set_max_inflight) { in ptlrpc_set_producer()[all …]
337 atomic_t set_remaining; member