Searched refs:rq_set (Results 1 – 5 of 5) sorted by relevance
92 struct ptlrpc_request_set *rq_set = req->rq_set; in ptlrpcd_wake() local94 LASSERT(rq_set != NULL); in ptlrpcd_wake()96 wake_up(&rq_set->set_waitq); in ptlrpcd_wake()162 req->rq_set = new; in ptlrpcd_add_rqset()199 req->rq_set = des; in ptlrpcd_steal_rqset()229 l_wait_event(req->rq_set_waitq, (req->rq_set == NULL), &lwi); in ptlrpcd_add_req()230 } else if (req->rq_set) { in ptlrpcd_add_req()237 atomic_inc(&req->rq_set->set_remaining); in ptlrpcd_add_req()239 wake_up(&req->rq_set->set_waitq); in ptlrpcd_add_req()317 req->rq_set = NULL; in ptlrpcd_check()
950 req->rq_set = NULL; in ptlrpc_set_destroy()996 req->rq_set = set; in ptlrpc_set_add_req()1021 LASSERT(req->rq_set == NULL); in ptlrpc_set_add_new_req()1028 req->rq_set = set; in ptlrpc_set_add_new_req()1872 req->rq_set = NULL; in ptlrpc_check_set()2402 if (request->rq_set != NULL) in ptlrpc_unregister_reply()2403 wq = &request->rq_set->set_waitq; in ptlrpc_unregister_reply()2674 LASSERT(req->rq_set == NULL); in ptlrpc_queue_wait()3056 req->rq_set = NULL; in work_interpreter()
222 DEBUG_REQ(D_HA, req, "waking (set %p):", req->rq_set); in ptlrpc_wake_delayed()
278 if (req->rq_set != NULL) in ptlrpc_unregister_bulk()279 wq = &req->rq_set->set_waitq; in ptlrpc_unregister_bulk()
1504 struct ptlrpc_request_set *rq_set; member2770 if (req->rq_set == NULL) in ptlrpc_client_wake_req()2773 wake_up(&req->rq_set->set_waitq); in ptlrpc_client_wake_req()