| /linux-4.1.27/drivers/staging/lustre/lustre/ptlrpc/ |
| D | client.c | 138 struct obd_import *imp = req->rq_import; in ptlrpc_prep_bulk_imp()
223 LASSERT(req->rq_import); in ptlrpc_at_set_req_timeout()
234 req->rq_timeout = req->rq_import->imp_server_timeout ? in ptlrpc_at_set_req_timeout()
237 at = &req->rq_import->imp_at; in ptlrpc_at_set_req_timeout()
238 idx = import_at_get_index(req->rq_import, in ptlrpc_at_set_req_timeout()
260 LASSERT(req->rq_import); in ptlrpc_at_adj_service()
261 at = &req->rq_import->imp_at; in ptlrpc_at_adj_service()
263 idx = import_at_get_index(req->rq_import, req->rq_request_portal); in ptlrpc_at_adj_service()
269 req->rq_import->imp_obd->obd_name, req->rq_request_portal, in ptlrpc_at_adj_service()
276 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 | 83 if (!req->rq_import->imp_dlm_fake) { in null_ctx_sign()
84 struct obd_device *obd = req->rq_import->imp_obd; in null_ctx_sign()
260 if (req->rq_import) in null_enlarge_reqbuf()
261 spin_lock(&req->rq_import->imp_lock); in null_enlarge_reqbuf()
268 if (req->rq_import) in null_enlarge_reqbuf()
269 spin_unlock(&req->rq_import->imp_lock); in null_enlarge_reqbuf()
|
| D | niobuf.c | 496 struct obd_device *obd = request->rq_import->imp_obd; in ptl_send_rpc()
508 (request->rq_import->imp_state == LUSTRE_IMP_FULL))); in ptl_send_rpc()
521 connection = request->rq_import->imp_connection; in ptl_send_rpc()
524 &request->rq_import->imp_remote_handle); in ptl_send_rpc()
527 request->rq_import->imp_conn_cnt); in ptl_send_rpc()
529 request->rq_import->imp_msghdr_flags); in ptl_send_rpc()
632 atomic_read(&request->rq_import->imp_inflight)); in ptl_send_rpc()
643 ptlrpc_pinger_sending_on_import(request->rq_import); in ptl_send_rpc()
|
| D | import.c | 793 struct obd_import *imp = request->rq_import; in ptlrpc_connect_interpret()
1220 atomic_dec(&req->rq_import->imp_replay_inflight); in completed_replay_interpret()
1222 !req->rq_import->imp_vbr_failed) { in completed_replay_interpret()
1223 ptlrpc_import_recovery_state_machine(req->rq_import); in completed_replay_interpret()
1225 if (req->rq_import->imp_vbr_failed) { in completed_replay_interpret()
1228 req->rq_import->imp_obd->obd_name); in completed_replay_interpret()
1231 req->rq_import->imp_obd->obd_name, in completed_replay_interpret()
1234 ptlrpc_connect_import(req->rq_import); in completed_replay_interpret()
|
| D | sec_plain.c | 678 if (req->rq_import) in plain_enlarge_reqbuf()
679 spin_lock(&req->rq_import->imp_lock); in plain_enlarge_reqbuf()
689 if (req->rq_import) in plain_enlarge_reqbuf()
690 spin_unlock(&req->rq_import->imp_lock); in plain_enlarge_reqbuf()
|
| D | sec.c | 395 struct obd_import *imp = req->rq_import; in sptlrpc_req_get_ctx()
583 lustre_msg_set_conn_cnt(req->rq_reqmsg, req->rq_import->imp_conn_cnt); in ctx_refresh_timeout()
648 rc = import_sec_validate_get(req->rq_import, &sec); in sptlrpc_req_refresh_ctx()
723 if (req->rq_import->imp_deactive) { in sptlrpc_req_refresh_ctx()
802 LASSERT(req->rq_import); in sptlrpc_req_set_flavor()
915 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 | 1129 svc_stats = req->rq_import->imp_obd->obd_svc_stats; in ptlrpc_lprocfs_rpc_sent()
1142 if (!req->rq_import) in ptlrpc_lprocfs_brw()
1144 svc_stats = req->rq_import->imp_obd->obd_svc_stats; in ptlrpc_lprocfs_brw()
|
| D | pack_generic.c | 2388 if (req->rq_import && req->rq_import->imp_connection) in _debug_req()
2389 nid = req->rq_import->imp_connection->c_peer.nid; in _debug_req()
2399 req->rq_import ? in _debug_req()
2400 req->rq_import->imp_obd->obd_name : in _debug_req()
|
| D | events.c | 161 req->rq_import->imp_last_reply_time = get_seconds(); in reply_in_callback()
|
| D | layout.c | 2215 return lustre_msg_size(pill->rc_req->rq_import->imp_msg_magic, in req_capsule_msg_size()
|
| /linux-4.1.27/drivers/staging/lustre/lustre/osc/ |
| D | osc_request.c | 217 lustre_set_wire_obdo(&req->rq_import->imp_connect_data, &body->oa, in osc_pack_req_body()
245 lustre_get_wire_obdo(&req->rq_import->imp_connect_data, in osc_getattr_interpret()
325 lustre_get_wire_obdo(&req->rq_import->imp_connect_data, oinfo->oi_oa, in osc_getattr()
370 lustre_get_wire_obdo(&req->rq_import->imp_connect_data, oinfo->oi_oa, in osc_setattr()
393 lustre_get_wire_obdo(&req->rq_import->imp_connect_data, sa->sa_oa, in osc_setattr_interpret()
491 lustre_set_wire_obdo(&req->rq_import->imp_connect_data, &body->oa, oa); in osc_real_create()
514 lustre_get_wire_obdo(&req->rq_import->imp_connect_data, oa, &body->oa); in osc_real_create()
570 lustre_set_wire_obdo(&req->rq_import->imp_connect_data, &body->oa, in osc_punch_base()
636 lustre_set_wire_obdo(&req->rq_import->imp_connect_data, &body->oa, in osc_sync_base()
695 struct client_obd *cli = &req->rq_import->imp_obd->u.cli; in osc_destroy_interpret()
[all …]
|
| /linux-4.1.27/drivers/staging/lustre/lustre/ldlm/ |
| D | ldlm_request.c | 1223 libcfs_nid2str(req->rq_import-> in ldlm_cli_cancel_req()
1262 if (unlikely(!req->rq_import || !req->rq_import->imp_obd || in ldlm_cli_update_pool()
1263 !imp_connect_lru_resize(req->rq_import))) { in ldlm_cli_update_pool()
1286 obd = req->rq_import->imp_obd; in ldlm_cli_update_pool()
2105 atomic_dec(&req->rq_import->imp_replay_inflight); in replay_lock_interpret()
2141 ptlrpc_import_recovery_state_machine(req->rq_import); in replay_lock_interpret()
2145 ptlrpc_connect_import(req->rq_import); in replay_lock_interpret()
2221 atomic_inc(&req->rq_import->imp_replay_inflight); in replay_one_lock()
|
| /linux-4.1.27/drivers/staging/lustre/lustre/include/ |
| D | lustre_net.h | 1461 struct obd_import *rq_import; member
2701 if (req->rq_import) in ptlrpc_rqphase_move()
2702 atomic_inc(&req->rq_import->imp_unregistering); in ptlrpc_rqphase_move()
2706 if (req->rq_import) in ptlrpc_rqphase_move()
2707 atomic_dec(&req->rq_import->imp_unregistering); in ptlrpc_rqphase_move()
|
| /linux-4.1.27/drivers/staging/lustre/lustre/mdc/ |
| D | mdc_reint.c | 155 req->rq_import->imp_replayable) { in mdc_setattr()
|
| D | mdc_request.c | 87 struct client_obd *cli = &req->rq_import->imp_obd->u.cli; in mdc_queue_wait()
750 struct obd_import *imp = open_req->rq_import; in mdc_set_open_replay_data()
810 imp_connect_disp_stripe(mod->mod_open_req->rq_import)) in mdc_free_open()
|
| D | mdc_locks.c | 343 req->rq_replay = req->rq_import->imp_replayable; in mdc_intent_open_pack()
|
| /linux-4.1.27/drivers/staging/lustre/lustre/mgc/ |
| D | mgc_request.c | 1432 if (unlikely(req->rq_import->imp_need_mne_swab)) in mgc_process_recover_log()
|