Home
last modified time | relevance | path

Searched refs:rq_lock (Results 1 – 22 of 22) sorted by relevance

/drivers/staging/lustre/lustre/ptlrpc/
Dclient.c414 __must_hold(&req->rq_lock) in ptlrpc_at_recv_early_reply()
421 spin_unlock(&req->rq_lock); in ptlrpc_at_recv_early_reply()
425 spin_lock(&req->rq_lock); in ptlrpc_at_recv_early_reply()
432 spin_lock(&req->rq_lock); in ptlrpc_at_recv_early_reply()
452 spin_lock(&req->rq_lock); in ptlrpc_at_recv_early_reply()
1035 spin_lock(&req->rq_lock); in ptlrpc_set_destroy()
1038 spin_unlock(&req->rq_lock); in ptlrpc_set_destroy()
1323 spin_lock(&req->rq_lock); in after_reply()
1325 spin_unlock(&req->rq_lock); in after_reply()
1357 spin_lock(&req->rq_lock); in after_reply()
[all …]
Devents.c63 spin_lock(&req->rq_lock); in request_out_callback()
81 spin_unlock(&req->rq_lock); in request_out_callback()
104 spin_lock(&req->rq_lock); in reply_in_callback()
173 spin_unlock(&req->rq_lock); in reply_in_callback()
213 spin_lock(&req->rq_lock); in client_bulk_callback()
215 spin_unlock(&req->rq_lock); in client_bulk_callback()
Dniobuf.c497 spin_lock(&request->rq_lock); in ptl_send_rpc()
499 spin_unlock(&request->rq_lock); in ptl_send_rpc()
590 spin_lock(&request->rq_lock); in ptl_send_rpc()
592 spin_unlock(&request->rq_lock); in ptl_send_rpc()
612 spin_lock(&request->rq_lock); in ptl_send_rpc()
625 spin_unlock(&request->rq_lock); in ptl_send_rpc()
647 spin_lock(&request->rq_lock); in ptl_send_rpc()
650 spin_unlock(&request->rq_lock); in ptl_send_rpc()
Dsec.c581 spin_lock(&req->rq_lock); in ctx_refresh_interrupt()
583 spin_unlock(&req->rq_lock); in ctx_refresh_interrupt()
656 spin_lock(&req->rq_lock); in sptlrpc_req_refresh_ctx()
658 spin_unlock(&req->rq_lock); in sptlrpc_req_refresh_ctx()
703 spin_lock(&req->rq_lock); in sptlrpc_req_refresh_ctx()
705 spin_unlock(&req->rq_lock); in sptlrpc_req_refresh_ctx()
714 spin_lock(&req->rq_lock); in sptlrpc_req_refresh_ctx()
716 spin_unlock(&req->rq_lock); in sptlrpc_req_refresh_ctx()
738 spin_lock(&req->rq_lock); in sptlrpc_req_refresh_ctx()
743 spin_unlock(&req->rq_lock); in sptlrpc_req_refresh_ctx()
[all …]
Dptlrpcd.c230 spin_lock(&req->rq_lock); in ptlrpcd_add_req()
236 spin_unlock(&req->rq_lock); in ptlrpcd_add_req()
247 spin_unlock(&req->rq_lock); in ptlrpcd_add_req()
251 spin_unlock(&req->rq_lock); in ptlrpcd_add_req()
Drecover.c251 spin_lock(&failed_req->rq_lock); in ptlrpc_request_handle_notconn()
254 spin_unlock(&failed_req->rq_lock); in ptlrpc_request_handle_notconn()
Dptlrpc_internal.h310 spin_lock_init(&req->rq_lock); in ptlrpc_req_comm_init()
Dnrs.c811 spin_lock(&req->rq_lock); in ptlrpc_nrs_hpreq_add_nolock()
816 spin_unlock(&req->rq_lock); in ptlrpc_nrs_hpreq_add_nolock()
Dservice.c975 spin_lock(&req->rq_lock); in ptlrpc_at_add_timed()
977 spin_unlock(&req->rq_lock); in ptlrpc_at_add_timed()
1001 spin_lock(&req->rq_lock); in ptlrpc_at_remove_timed()
1003 spin_unlock(&req->rq_lock); in ptlrpc_at_remove_timed()
Dpack_generic.c310 spin_lock(&req->rq_lock); in lustre_pack_reply_v2()
312 spin_unlock(&req->rq_lock); in lustre_pack_reply_v2()
/drivers/infiniband/hw/nes/
Dnes_mgt.c59 spin_lock_irqsave(&nesmgt->rq_lock, flags); in nes_replenish_mgt_rq()
64 spin_unlock_irqrestore(&nesmgt->rq_lock, flags); in nes_replenish_mgt_rq()
68 spin_unlock_irqrestore(&nesmgt->rq_lock, flags); in nes_replenish_mgt_rq()
73 spin_unlock_irqrestore(&nesmgt->rq_lock, flags); in nes_replenish_mgt_rq()
103 spin_lock_irqsave(&nesmgt->rq_lock, flags); in nes_replenish_mgt_rq()
107 spin_unlock_irqrestore(&nesmgt->rq_lock, flags); in nes_replenish_mgt_rq()
111 spin_unlock_irqrestore(&nesmgt->rq_lock, flags); in nes_replenish_mgt_rq()
918 spin_lock_init(&mgtvnic->mgt.rq_lock); in nes_init_mgt_qp()
Dnes_mgt.h54 spinlock_t rq_lock; member
Dnes_hw.c1561 spin_lock_irqsave(&nesnic->rq_lock, flags); in nes_replenish_nic_rq()
1566 spin_unlock_irqrestore(&nesnic->rq_lock, flags); in nes_replenish_nic_rq()
1570 spin_unlock_irqrestore(&nesnic->rq_lock, flags); in nes_replenish_nic_rq()
1574 spin_unlock_irqrestore(&nesnic->rq_lock, flags); in nes_replenish_nic_rq()
1604 spin_lock_irqsave(&nesnic->rq_lock, flags); in nes_replenish_nic_rq()
1608 spin_unlock_irqrestore(&nesnic->rq_lock, flags); in nes_replenish_nic_rq()
1612 spin_unlock_irqrestore(&nesnic->rq_lock, flags); in nes_replenish_nic_rq()
1714 spin_lock_init(&nesvnic->nic.rq_lock); in nes_init_nic_qp()
Dnes_hw.h930 spinlock_t rq_lock; member
/drivers/staging/lustre/lustre/include/
Dlustre_net.h737 spinlock_t rq_lock; member
2200 spin_lock(&req->rq_lock); in ptlrpc_client_recv_or_unlink()
2202 spin_unlock(&req->rq_lock); in ptlrpc_client_recv_or_unlink()
2206 spin_unlock(&req->rq_lock); in ptlrpc_client_recv_or_unlink()
2211 spin_unlock(&req->rq_lock); in ptlrpc_client_recv_or_unlink()
2280 spin_lock(&req->rq_lock); in ptlrpc_no_resend()
2282 spin_unlock(&req->rq_lock); in ptlrpc_no_resend()
/drivers/staging/lustre/lustre/mdc/
Dmdc_reint.c398 spin_lock(&mod->mod_open_req->rq_lock); in mdc_rename()
400 spin_unlock(&mod->mod_open_req->rq_lock); in mdc_rename()
Dmdc_locks.c194 spin_lock(&req->rq_lock); in mdc_clear_replay_flag()
196 spin_unlock(&req->rq_lock); in mdc_clear_replay_flag()
296 spin_lock(&req->rq_lock); in mdc_intent_open_pack()
298 spin_unlock(&req->rq_lock); in mdc_intent_open_pack()
Dmdc_request.c586 spin_lock(&req->rq_lock); in mdc_commit_open()
588 spin_unlock(&req->rq_lock); in mdc_commit_open()
631 spin_lock(&open_req->rq_lock); in mdc_set_open_replay_data()
639 spin_unlock(&open_req->rq_lock); in mdc_set_open_replay_data()
746 spin_lock(&mod->mod_open_req->rq_lock); in mdc_close()
748 spin_unlock(&mod->mod_open_req->rq_lock); in mdc_close()
/drivers/staging/lustre/lustre/osc/
Dosc_page.c964 spin_lock(&req->rq_lock); in osc_inc_unstable_pages()
966 spin_unlock(&req->rq_lock); in osc_inc_unstable_pages()
971 spin_unlock(&req->rq_lock); in osc_inc_unstable_pages()
Dosc_request.c1629 spin_lock(&req->rq_lock); in brw_commit()
1632 spin_unlock(&req->rq_lock); in brw_commit()
1636 spin_unlock(&req->rq_lock); in brw_commit()
/drivers/infiniband/hw/bnxt_re/
Dib_verbs.h76 spinlock_t rq_lock; /* protect rq */ member
Dib_verbs.c1189 spin_lock_init(&qp->rq_lock); in bnxt_re_create_qp()
2274 spin_lock_irqsave(&qp->rq_lock, flags); in bnxt_re_post_recv()
2316 spin_unlock_irqrestore(&qp->rq_lock, flags); in bnxt_re_post_recv()