| /linux-4.4.14/drivers/staging/lustre/lustre/ptlrpc/ |
| D | client.c | 143 struct obd_import *imp = req->rq_import; in ptlrpc_prep_bulk_imp()
227 LASSERT(req->rq_import); in ptlrpc_at_set_req_timeout()
239 req->rq_timeout = req->rq_import->imp_server_timeout ? in ptlrpc_at_set_req_timeout()
242 at = &req->rq_import->imp_at; in ptlrpc_at_set_req_timeout()
243 idx = import_at_get_index(req->rq_import, in ptlrpc_at_set_req_timeout()
269 LASSERT(req->rq_import); in ptlrpc_at_adj_service()
270 at = &req->rq_import->imp_at; in ptlrpc_at_adj_service()
272 idx = import_at_get_index(req->rq_import, req->rq_request_portal); in ptlrpc_at_adj_service()
280 req->rq_import->imp_obd->obd_name, req->rq_request_portal, in ptlrpc_at_adj_service()
287 return AT_OFF ? 0 : at_get(&req->rq_import->imp_at.iat_net_latency); in ptlrpc_at_get_net_latency()
[all …]
|
| D | sec_null.c | 84 if (!req->rq_import->imp_dlm_fake) { in null_ctx_sign()
85 struct obd_device *obd = req->rq_import->imp_obd; in null_ctx_sign()
262 if (req->rq_import) in null_enlarge_reqbuf()
263 spin_lock(&req->rq_import->imp_lock); in null_enlarge_reqbuf()
270 if (req->rq_import) in null_enlarge_reqbuf()
271 spin_unlock(&req->rq_import->imp_lock); in null_enlarge_reqbuf()
|
| D | niobuf.c | 492 struct obd_device *obd = request->rq_import->imp_obd; in ptl_send_rpc()
504 (request->rq_import->imp_state == LUSTRE_IMP_FULL))); in ptl_send_rpc()
517 connection = request->rq_import->imp_connection; in ptl_send_rpc()
520 &request->rq_import->imp_remote_handle); in ptl_send_rpc()
523 request->rq_import->imp_conn_cnt); in ptl_send_rpc()
525 request->rq_import->imp_msghdr_flags); in ptl_send_rpc()
628 atomic_read(&request->rq_import->imp_inflight)); in ptl_send_rpc()
639 ptlrpc_pinger_sending_on_import(request->rq_import); in ptl_send_rpc()
|
| D | import.c | 784 struct obd_import *imp = request->rq_import; in ptlrpc_connect_interpret()
1210 atomic_dec(&req->rq_import->imp_replay_inflight); in completed_replay_interpret()
1212 !req->rq_import->imp_vbr_failed) { in completed_replay_interpret()
1213 ptlrpc_import_recovery_state_machine(req->rq_import); in completed_replay_interpret()
1215 if (req->rq_import->imp_vbr_failed) { in completed_replay_interpret()
1218 req->rq_import->imp_obd->obd_name); in completed_replay_interpret()
1221 req->rq_import->imp_obd->obd_name, in completed_replay_interpret()
1224 ptlrpc_connect_import(req->rq_import); in completed_replay_interpret()
|
| D | sec_plain.c | 677 if (req->rq_import) in plain_enlarge_reqbuf()
678 spin_lock(&req->rq_import->imp_lock); in plain_enlarge_reqbuf()
688 if (req->rq_import) in plain_enlarge_reqbuf()
689 spin_unlock(&req->rq_import->imp_lock); in plain_enlarge_reqbuf()
|
| D | sec.c | 354 struct obd_import *imp = req->rq_import; in sptlrpc_req_get_ctx()
541 lustre_msg_set_conn_cnt(req->rq_reqmsg, req->rq_import->imp_conn_cnt); in ctx_refresh_timeout()
606 rc = import_sec_validate_get(req->rq_import, &sec); in sptlrpc_req_refresh_ctx()
681 if (req->rq_import->imp_deactive) { in sptlrpc_req_refresh_ctx()
760 LASSERT(req->rq_import); in sptlrpc_req_set_flavor()
873 req->rq_import = imp; in sptlrpc_import_check_ctx()
|
| D | recover.c | 231 struct obd_import *imp = failed_req->rq_import; in ptlrpc_request_handle_notconn()
|
| D | lproc_ptlrpc.c | 1131 svc_stats = req->rq_import->imp_obd->obd_svc_stats; in ptlrpc_lprocfs_rpc_sent()
1144 if (!req->rq_import) in ptlrpc_lprocfs_brw()
1146 svc_stats = req->rq_import->imp_obd->obd_svc_stats; in ptlrpc_lprocfs_brw()
|
| D | pack_generic.c | 2180 if (req->rq_import && req->rq_import->imp_connection) in _debug_req()
2181 nid = req->rq_import->imp_connection->c_peer.nid; in _debug_req()
2191 req->rq_import ? in _debug_req()
2192 req->rq_import->imp_obd->obd_name : in _debug_req()
|
| D | events.c | 161 req->rq_import->imp_last_reply_time = ktime_get_real_seconds(); in reply_in_callback()
|
| D | layout.c | 2150 return lustre_msg_size(pill->rc_req->rq_import->imp_msg_magic, in req_capsule_msg_size()
|
| /linux-4.4.14/drivers/staging/lustre/lustre/osc/ |
| D | osc_request.c | 209 lustre_set_wire_obdo(&req->rq_import->imp_connect_data, &body->oa, in osc_pack_req_body()
225 lustre_get_wire_obdo(&req->rq_import->imp_connect_data, in osc_getattr_interpret()
303 lustre_get_wire_obdo(&req->rq_import->imp_connect_data, oinfo->oi_oa, in osc_getattr()
347 lustre_get_wire_obdo(&req->rq_import->imp_connect_data, oinfo->oi_oa, in osc_setattr()
370 lustre_get_wire_obdo(&req->rq_import->imp_connect_data, sa->sa_oa, in osc_setattr_interpret()
467 lustre_set_wire_obdo(&req->rq_import->imp_connect_data, &body->oa, oa); in osc_real_create()
490 lustre_get_wire_obdo(&req->rq_import->imp_connect_data, oa, &body->oa); in osc_real_create()
545 lustre_set_wire_obdo(&req->rq_import->imp_connect_data, &body->oa, in osc_punch_base()
609 lustre_set_wire_obdo(&req->rq_import->imp_connect_data, &body->oa, in osc_sync_base()
667 struct client_obd *cli = &req->rq_import->imp_obd->u.cli; in osc_destroy_interpret()
[all …]
|
| /linux-4.4.14/drivers/staging/lustre/lustre/ldlm/ |
| D | ldlm_request.c | 924 libcfs_nid2str(req->rq_import-> in ldlm_cli_cancel_req()
962 if (unlikely(!req->rq_import || !req->rq_import->imp_obd || in ldlm_cli_update_pool()
963 !imp_connect_lru_resize(req->rq_import))) { in ldlm_cli_update_pool()
986 obd = req->rq_import->imp_obd; in ldlm_cli_update_pool()
1794 atomic_dec(&req->rq_import->imp_replay_inflight); in replay_lock_interpret()
1829 ptlrpc_import_recovery_state_machine(req->rq_import); in replay_lock_interpret()
1833 ptlrpc_connect_import(req->rq_import); in replay_lock_interpret()
1909 atomic_inc(&req->rq_import->imp_replay_inflight); in replay_one_lock()
|
| /linux-4.4.14/drivers/staging/lustre/lustre/include/ |
| D | lustre_net.h | 1455 struct obd_import *rq_import; member
2660 if (req->rq_import) in ptlrpc_rqphase_move()
2661 atomic_inc(&req->rq_import->imp_unregistering); in ptlrpc_rqphase_move()
2665 if (req->rq_import) in ptlrpc_rqphase_move()
2666 atomic_dec(&req->rq_import->imp_unregistering); in ptlrpc_rqphase_move()
|
| /linux-4.4.14/drivers/staging/lustre/lustre/mdc/ |
| D | mdc_reint.c | 153 req->rq_import->imp_replayable) { in mdc_setattr()
|
| D | mdc_request.c | 60 struct client_obd *cli = &req->rq_import->imp_obd->u.cli; in mdc_queue_wait()
668 struct obd_import *imp = open_req->rq_import; in mdc_set_open_replay_data()
728 imp_connect_disp_stripe(mod->mod_open_req->rq_import)) in mdc_free_open()
|
| D | mdc_locks.c | 337 req->rq_replay = req->rq_import->imp_replayable; in mdc_intent_open_pack()
|
| /linux-4.4.14/drivers/staging/lustre/lustre/mgc/ |
| D | mgc_request.c | 1404 if (unlikely(req->rq_import->imp_need_mne_swab)) in mgc_process_recover_log()
|