| /linux-4.4.14/drivers/staging/lustre/lustre/ptlrpc/ |
| D | niobuf.c | 325 lustre_msg_set_service_time(req->rq_repmsg, service_time); in ptlrpc_at_set_reply()
330 lustre_msg_set_timeout(req->rq_repmsg, 0); in ptlrpc_at_set_reply()
332 lustre_msg_set_timeout(req->rq_repmsg, in ptlrpc_at_set_reply()
340 lustre_msg_get_magic(req->rq_repmsg), req->rq_replen); in ptlrpc_at_set_reply()
366 LASSERT(req->rq_repmsg != NULL); in ptlrpc_send_reply()
367 LASSERT(req->rq_repmsg == rs->rs_msg); in ptlrpc_send_reply()
390 req->rq_replen = lustre_shrink_msg(req->rq_repmsg, 0, in ptlrpc_send_reply()
396 lustre_msg_set_type(req->rq_repmsg, req->rq_type); in ptlrpc_send_reply()
397 lustre_msg_set_status(req->rq_repmsg, in ptlrpc_send_reply()
399 lustre_msg_set_opc(req->rq_repmsg, in ptlrpc_send_reply()
[all …]
|
| D | client.c | 374 lustre_msg_get_timeout(early_req->rq_repmsg)); in ptlrpc_at_recv_early_reply()
376 lustre_msg_get_service_time(early_req->rq_repmsg)); in ptlrpc_at_recv_early_reply()
1096 err = lustre_msg_get_status(req->rq_repmsg); in ptlrpc_console_allow()
1112 err = lustre_msg_get_status(req->rq_repmsg); in ptlrpc_check_status()
1113 if (lustre_msg_get_type(req->rq_repmsg) == PTL_RPC_MSG_ERR) { in ptlrpc_check_status()
1142 struct lustre_msg *repmsg = req->rq_repmsg; in ptlrpc_save_versions()
1214 if (lustre_msg_get_status(req->rq_repmsg) == -EINPROGRESS && in after_reply()
1256 if (lustre_msg_get_type(req->rq_repmsg) != PTL_RPC_MSG_REPLY && in after_reply()
1257 lustre_msg_get_type(req->rq_repmsg) != PTL_RPC_MSG_ERR) { in after_reply()
1259 lustre_msg_get_type(req->rq_repmsg)); in after_reply()
[all …]
|
| D | import.c | 812 msg_flags = lustre_msg_get_op_flags(request->rq_repmsg); in ptlrpc_connect_interpret()
883 *lustre_msg_get_handle(request->rq_repmsg); in ptlrpc_connect_interpret()
904 if (!memcmp(&old_hdl, lustre_msg_get_handle(request->rq_repmsg), in ptlrpc_connect_interpret()
915 lustre_msg_get_handle(request->rq_repmsg), in ptlrpc_connect_interpret()
933 request->rq_repmsg)->cookie); in ptlrpc_connect_interpret()
941 request->rq_repmsg)->cookie); in ptlrpc_connect_interpret()
945 *lustre_msg_get_handle(request->rq_repmsg); in ptlrpc_connect_interpret()
979 *lustre_msg_get_handle(request->rq_repmsg); in ptlrpc_connect_interpret()
986 *lustre_msg_get_handle(request->rq_repmsg); in ptlrpc_connect_interpret()
995 if (lustre_msg_get_last_committed(request->rq_repmsg) > 0 && in ptlrpc_connect_interpret()
[all …]
|
| D | pack_generic.c | 334 req->rq_repmsg = rs->rs_msg; in lustre_pack_reply_v2()
592 rc = __lustre_unpack_msg(req->rq_repmsg, len); in ptlrpc_unpack_rep_msg()
605 struct lustre_msg_v2 *m = inout ? req->rq_reqmsg : req->rq_repmsg; in lustre_unpack_ptlrpc_body_v2()
642 switch (req->rq_repmsg->lm_magic) { in lustre_unpack_rep_ptlrpc_body()
647 req->rq_repmsg->lm_magic); in lustre_unpack_rep_ptlrpc_body()
2155 LASSERT(req->rq_repmsg); in rep_ptlrpc_body_swabbed()
2157 switch (req->rq_repmsg->lm_magic) { in rep_ptlrpc_body_swabbed()
2171 int rep_ok = req->rq_repmsg != NULL; in _debug_req()
2204 rep_ok ? lustre_msg_get_flags(req->rq_repmsg) : -1, in _debug_req()
2206 rep_ok ? lustre_msg_get_status(req->rq_repmsg) : -1); in _debug_req()
|
| D | sec_null.c | 101 req->rq_repmsg = req->rq_repdata; in null_ctx_verify()
106 cksumc = lustre_msg_calc_cksum(req->rq_repmsg); in null_ctx_verify()
|
| D | sec.c | 941 LASSERT(req->rq_repmsg == NULL); in do_cli_unwrap_reply()
984 LASSERT(rc || req->rq_repmsg || req->rq_resend); in do_cli_unwrap_reply()
1004 LASSERT(req->rq_repmsg == NULL); in sptlrpc_cli_unwrap_reply()
1071 LASSERT(req->rq_repmsg == NULL); in sptlrpc_cli_unwrap_early_reply()
1117 LASSERT(early_req->rq_repmsg); in sptlrpc_cli_unwrap_early_reply()
1139 LASSERT(early_req->rq_repmsg); in sptlrpc_cli_finish_early_reply()
1641 req->rq_repmsg = NULL; in sptlrpc_cli_free_repbuf()
1919 LASSERT(req->rq_repmsg == NULL); in sptlrpc_svc_unwrap_request()
|
| D | service.c | 1715 (request->rq_repmsg ? in ptlrpc_server_handle_request()
1716 lustre_msg_get_transno(request->rq_repmsg) : in ptlrpc_server_handle_request()
1719 (request->rq_repmsg ? in ptlrpc_server_handle_request()
1720 lustre_msg_get_status(request->rq_repmsg) : -999)); in ptlrpc_server_handle_request()
|
| D | sec_plain.c | 282 req->rq_repmsg = lustre_msg_buf(msg, PLAIN_PACK_MSG_OFF, 0); in plain_ctx_verify()
|
| D | layout.c | 1746 return loc == RCL_CLIENT ? req->rq_reqmsg : req->rq_repmsg; in __req_msg()
|
| /linux-4.4.14/drivers/staging/lustre/lustre/ldlm/ |
| D | ldlm_lib.c | 640 lustre_msg_set_slv(req->rq_repmsg, 0); in target_pack_pool_reply()
641 lustre_msg_set_limit(req->rq_repmsg, 0); in target_pack_pool_reply()
649 lustre_msg_set_slv(req->rq_repmsg, obd->obd_pool_slv); in target_pack_pool_reply()
650 lustre_msg_set_limit(req->rq_repmsg, obd->obd_pool_limit); in target_pack_pool_reply()
|
| D | ldlm_request.c | 975 if (lustre_msg_get_slv(req->rq_repmsg) == 0 || in ldlm_cli_update_pool()
976 lustre_msg_get_limit(req->rq_repmsg) == 0) { in ldlm_cli_update_pool()
979 lustre_msg_get_slv(req->rq_repmsg), in ldlm_cli_update_pool()
980 lustre_msg_get_limit(req->rq_repmsg)); in ldlm_cli_update_pool()
984 new_limit = lustre_msg_get_limit(req->rq_repmsg); in ldlm_cli_update_pool()
985 new_slv = lustre_msg_get_slv(req->rq_repmsg); in ldlm_cli_update_pool()
|
| D | ldlm_lockd.c | 318 if (req->rq_repmsg != NULL) { in ldlm_handle_gl_callback()
|
| /linux-4.4.14/drivers/staging/lustre/lustre/include/ |
| D | lustre_net.h | 1352 struct lustre_msg *rq_repmsg; member
2613 LASSERT(req->rq_repmsg); in lustre_shrink_reply()
2614 req->rq_replen = lustre_shrink_msg(req->rq_repmsg, segment, in lustre_shrink_reply()
2757 req->rq_repmsg = NULL; in ptlrpc_req_drop_rs()
|
| D | obd.h | 620 if (req->rq_repmsg != NULL) in oti_init()
621 oti->oti_transno = lustre_msg_get_transno(req->rq_repmsg); in oti_init()
|
| /linux-4.4.14/drivers/staging/lustre/lustre/osc/ |
| D | osc_quota.c | 269 if (req->rq_repmsg) { in osc_quotactl()
|
| D | osc_request.c | 503 oti->oti_transno = lustre_msg_get_transno(req->rq_repmsg); in osc_real_create()
513 lustre_msg_get_transno(req->rq_repmsg)); in osc_real_create()
1474 LASSERTF(req->rq_repmsg != NULL, "rc = %d\n", rc); in osc_brw_fini_request()
|
| /linux-4.4.14/drivers/staging/lustre/lustre/mdc/ |
| D | mdc_request.c | 107 lustre_msg_get_last_committed(req->rq_repmsg)); in mdc_getstatus()
851 if (req->rq_repmsg == NULL) { in mdc_close()
859 rc = lustre_msg_get_status(req->rq_repmsg); in mdc_close()
860 if (lustre_msg_get_type(req->rq_repmsg) == PTL_RPC_MSG_ERR) { in mdc_close()
1662 if (req->rq_repmsg) { in mdc_quotactl()
|
| D | mdc_locks.c | 935 LASSERT(request->rq_repmsg != LP_POISON); in mdc_finish_intent_lock()
|