Searched refs:nrq (Results 1 – 4 of 4) sorted by relevance
| /drivers/staging/lustre/lustre/ptlrpc/ |
| D | nrs_fifo.c | 132 struct ptlrpc_nrs_request *nrq, in nrs_fifo_res_get() argument
166 struct ptlrpc_nrs_request *nrq; in nrs_fifo_req_get() local
168 nrq = unlikely(list_empty(&head->fh_list)) ? NULL : in nrs_fifo_req_get()
172 if (likely(!peek && nrq != NULL)) { in nrs_fifo_req_get()
173 struct ptlrpc_request *req = container_of(nrq, in nrs_fifo_req_get()
177 list_del_init(&nrq->nr_u.fifo.fr_list); in nrs_fifo_req_get()
181 nrq->nr_u.fifo.fr_sequence); in nrs_fifo_req_get()
184 return nrq; in nrs_fifo_req_get()
197 struct ptlrpc_nrs_request *nrq) in nrs_fifo_req_add() argument
201 head = container_of(nrs_request_resource(nrq), struct nrs_fifo_head, in nrs_fifo_req_add()
[all …]
|
| D | nrs.c | 379 struct ptlrpc_nrs_request *nrq, in nrs_resource_get() argument
390 rc = policy->pol_desc->pd_ops->op_res_get(policy, nrq, res, in nrs_resource_get()
430 struct ptlrpc_nrs_request *nrq, in nrs_resource_get_safe() argument
456 resp[NRS_RES_FALLBACK] = nrs_resource_get(fallback, nrq, moving_req); in nrs_resource_get_safe()
460 resp[NRS_RES_PRIMARY] = nrs_resource_get(primary, nrq, in nrs_resource_get_safe()
533 struct ptlrpc_nrs_request *nrq; in nrs_request_get() local
537 nrq = policy->pol_desc->pd_ops->op_req_get(policy, peek, force); in nrs_request_get()
539 LASSERT(ergo(nrq != NULL, nrs_request_policy(nrq) == policy)); in nrs_request_get()
541 return nrq; in nrs_request_get()
554 static inline void nrs_request_enqueue(struct ptlrpc_nrs_request *nrq) in nrs_request_enqueue() argument
[all …]
|
| D | ptlrpc_internal.h | 194 nrs_request_resource(struct ptlrpc_nrs_request *nrq) in nrs_request_resource() argument
196 LASSERT(nrq->nr_initialized); in nrs_request_resource()
197 LASSERT(!nrq->nr_finalized); in nrs_request_resource()
199 return nrq->nr_res_ptrs[nrq->nr_res_idx]; in nrs_request_resource()
203 struct ptlrpc_nrs_policy *nrs_request_policy(struct ptlrpc_nrs_request *nrq) in nrs_request_policy() argument
205 return nrs_request_resource(nrq)->res_policy; in nrs_request_policy()
|
| /drivers/staging/lustre/lustre/include/ |
| D | lustre_net.h | 646 struct ptlrpc_nrs_request *nrq,
695 struct ptlrpc_nrs_request *nrq);
705 struct ptlrpc_nrs_request *nrq);
719 struct ptlrpc_nrs_request *nrq);
1538 struct ptlrpc_nrs_request *nrq = &req->rq_nrq; in ptlrpc_nrs_req_can_move() local
1546 return nrq->nr_enqueued && !nrq->nr_started && !req->rq_hp; in ptlrpc_nrs_req_can_move()
|