Searched refs:rq_set (Results 1 – 5 of 5) sorted by relevance
164 struct ptlrpc_request_set *rq_set = req->rq_set; in ptlrpcd_wake() local166 LASSERT(rq_set != NULL); in ptlrpcd_wake()168 wake_up(&rq_set->set_waitq); in ptlrpcd_wake()213 req->rq_set = des; in ptlrpcd_steal_rqset()243 l_wait_event(req->rq_set_waitq, (req->rq_set == NULL), &lwi); in ptlrpcd_add_req()244 } else if (req->rq_set) { in ptlrpcd_add_req()251 atomic_inc(&req->rq_set->set_remaining); in ptlrpcd_add_req()253 wake_up(&req->rq_set->set_waitq); in ptlrpcd_add_req()331 req->rq_set = NULL; in ptlrpcd_check()
926 req->rq_set = NULL; in ptlrpc_set_destroy()950 req->rq_set = set; in ptlrpc_set_add_req()977 LASSERT(req->rq_set == NULL); in ptlrpc_set_add_new_req()982 req->rq_set = set; in ptlrpc_set_add_new_req()1839 req->rq_set = NULL; in ptlrpc_check_set()2354 if (request->rq_set != NULL) in ptlrpc_unregister_reply()2355 wq = &request->rq_set->set_waitq; in ptlrpc_unregister_reply()2614 LASSERT(req->rq_set == NULL); in ptlrpc_queue_wait()3002 req->rq_set = NULL; in work_interpreter()
222 DEBUG_REQ(D_HA, req, "waking (set %p):", req->rq_set); in ptlrpc_wake_delayed()
276 if (req->rq_set != NULL) in ptlrpc_unregister_bulk()277 wq = &req->rq_set->set_waitq; in ptlrpc_unregister_bulk()
1498 struct ptlrpc_request_set *rq_set; member2729 if (req->rq_set == NULL) in ptlrpc_client_wake_req()2732 wake_up(&req->rq_set->set_waitq); in ptlrpc_client_wake_req()