Home
last modified time | relevance | path

Searched refs:rq_repmsg (Results 1 – 18 of 18) sorted by relevance

/linux-4.1.27/drivers/staging/lustre/lustre/ptlrpc/
Dniobuf.c327 lustre_msg_set_service_time(req->rq_repmsg, service_time); in ptlrpc_at_set_reply()
333 lustre_msg_set_timeout(req->rq_repmsg, 0); in ptlrpc_at_set_reply()
335 lustre_msg_set_timeout(req->rq_repmsg, in ptlrpc_at_set_reply()
344 lustre_msg_get_magic(req->rq_repmsg), req->rq_replen); in ptlrpc_at_set_reply()
370 LASSERT(req->rq_repmsg != NULL); in ptlrpc_send_reply()
371 LASSERT(req->rq_repmsg == rs->rs_msg); in ptlrpc_send_reply()
394 req->rq_replen = lustre_shrink_msg(req->rq_repmsg, 0, in ptlrpc_send_reply()
400 lustre_msg_set_type(req->rq_repmsg, req->rq_type); in ptlrpc_send_reply()
401 lustre_msg_set_status(req->rq_repmsg, in ptlrpc_send_reply()
403 lustre_msg_set_opc(req->rq_repmsg, in ptlrpc_send_reply()
[all …]
Dclient.c362 lustre_msg_get_timeout(early_req->rq_repmsg)); in ptlrpc_at_recv_early_reply()
364 lustre_msg_get_service_time(early_req->rq_repmsg)); in ptlrpc_at_recv_early_reply()
1138 err = lustre_msg_get_status(req->rq_repmsg); in ptlrpc_console_allow()
1154 err = lustre_msg_get_status(req->rq_repmsg); in ptlrpc_check_status()
1155 if (lustre_msg_get_type(req->rq_repmsg) == PTL_RPC_MSG_ERR) { in ptlrpc_check_status()
1184 struct lustre_msg *repmsg = req->rq_repmsg; in ptlrpc_save_versions()
1257 if (lustre_msg_get_status(req->rq_repmsg) == -EINPROGRESS && in after_reply()
1297 if (lustre_msg_get_type(req->rq_repmsg) != PTL_RPC_MSG_REPLY && in after_reply()
1298 lustre_msg_get_type(req->rq_repmsg) != PTL_RPC_MSG_ERR) { in after_reply()
1300 lustre_msg_get_type(req->rq_repmsg)); in after_reply()
[all …]
Dimport.c821 msg_flags = lustre_msg_get_op_flags(request->rq_repmsg); in ptlrpc_connect_interpret()
892 *lustre_msg_get_handle(request->rq_repmsg); in ptlrpc_connect_interpret()
913 if (!memcmp(&old_hdl, lustre_msg_get_handle(request->rq_repmsg), in ptlrpc_connect_interpret()
924 lustre_msg_get_handle(request->rq_repmsg), in ptlrpc_connect_interpret()
942 request->rq_repmsg)->cookie); in ptlrpc_connect_interpret()
950 request->rq_repmsg)->cookie); in ptlrpc_connect_interpret()
955 *lustre_msg_get_handle(request->rq_repmsg); in ptlrpc_connect_interpret()
989 *lustre_msg_get_handle(request->rq_repmsg); in ptlrpc_connect_interpret()
996 *lustre_msg_get_handle(request->rq_repmsg); in ptlrpc_connect_interpret()
1005 if (lustre_msg_get_last_committed(request->rq_repmsg) > 0 && in ptlrpc_connect_interpret()
[all …]
Dsec_null.c99 req->rq_repmsg = req->rq_repdata; in null_ctx_verify()
104 cksumc = lustre_msg_calc_cksum(req->rq_repmsg); in null_ctx_verify()
Dpack_generic.c351 req->rq_repmsg = rs->rs_msg; in lustre_pack_reply_v2()
606 rc = __lustre_unpack_msg(req->rq_repmsg, len); in ptlrpc_unpack_rep_msg()
619 struct lustre_msg_v2 *m = inout ? req->rq_reqmsg : req->rq_repmsg; in lustre_unpack_ptlrpc_body_v2()
656 switch (req->rq_repmsg->lm_magic) { in lustre_unpack_rep_ptlrpc_body()
661 req->rq_repmsg->lm_magic); in lustre_unpack_rep_ptlrpc_body()
2363 LASSERT(req->rq_repmsg); in rep_ptlrpc_body_swabbed()
2365 switch (req->rq_repmsg->lm_magic) { in rep_ptlrpc_body_swabbed()
2379 int rep_ok = req->rq_repmsg != NULL; in _debug_req()
2412 rep_ok ? lustre_msg_get_flags(req->rq_repmsg) : -1, in _debug_req()
2414 rep_ok ? lustre_msg_get_status(req->rq_repmsg) : -1); in _debug_req()
Dsec.c983 LASSERT(req->rq_repmsg == NULL); in do_cli_unwrap_reply()
1026 LASSERT(rc || req->rq_repmsg || req->rq_resend); in do_cli_unwrap_reply()
1046 LASSERT(req->rq_repmsg == NULL); in sptlrpc_cli_unwrap_reply()
1113 LASSERT(req->rq_repmsg == NULL); in sptlrpc_cli_unwrap_early_reply()
1159 LASSERT(early_req->rq_repmsg); in sptlrpc_cli_unwrap_early_reply()
1181 LASSERT(early_req->rq_repmsg); in sptlrpc_cli_finish_early_reply()
1697 req->rq_repmsg = NULL; in sptlrpc_cli_free_repbuf()
2027 LASSERT(req->rq_repmsg == NULL); in sptlrpc_svc_unwrap_request()
Dservice.c1991 (request->rq_repmsg ? in ptlrpc_server_handle_request()
1992 lustre_msg_get_transno(request->rq_repmsg) : in ptlrpc_server_handle_request()
1995 (request->rq_repmsg ? in ptlrpc_server_handle_request()
1996 lustre_msg_get_status(request->rq_repmsg) : -999)); in ptlrpc_server_handle_request()
Dlayout.c1747 return loc == RCL_CLIENT ? req->rq_reqmsg : req->rq_repmsg; in __req_msg()
2395 lustre_packed_msg_size(pill->rc_req->rq_repmsg) - len + newlen) in req_capsule_server_grow()
Dsec_plain.c282 req->rq_repmsg = lustre_msg_buf(msg, PLAIN_PACK_MSG_OFF, 0); in plain_ctx_verify()
/linux-4.1.27/drivers/staging/lustre/lustre/ldlm/
Dldlm_lib.c643 lustre_msg_set_slv(req->rq_repmsg, 0); in target_pack_pool_reply()
644 lustre_msg_set_limit(req->rq_repmsg, 0); in target_pack_pool_reply()
652 lustre_msg_set_slv(req->rq_repmsg, obd->obd_pool_slv); in target_pack_pool_reply()
653 lustre_msg_set_limit(req->rq_repmsg, obd->obd_pool_limit); in target_pack_pool_reply()
Dldlm_request.c1275 if (lustre_msg_get_slv(req->rq_repmsg) == 0 || in ldlm_cli_update_pool()
1276 lustre_msg_get_limit(req->rq_repmsg) == 0) { in ldlm_cli_update_pool()
1279 lustre_msg_get_slv(req->rq_repmsg), in ldlm_cli_update_pool()
1280 lustre_msg_get_limit(req->rq_repmsg)); in ldlm_cli_update_pool()
1284 new_limit = lustre_msg_get_limit(req->rq_repmsg); in ldlm_cli_update_pool()
1285 new_slv = lustre_msg_get_slv(req->rq_repmsg); in ldlm_cli_update_pool()
Dldlm_lockd.c341 if (req->rq_repmsg != NULL) { in ldlm_handle_gl_callback()
/linux-4.1.27/drivers/staging/lustre/lustre/include/
Dlustre_net.h1358 struct lustre_msg *rq_repmsg; member
2654 LASSERT(req->rq_repmsg); in lustre_shrink_reply()
2655 req->rq_replen = lustre_shrink_msg(req->rq_repmsg, segment, in lustre_shrink_reply()
2798 req->rq_repmsg = NULL; in ptlrpc_req_drop_rs()
Dobd.h711 if (req->rq_repmsg != NULL) in oti_init()
712 oti->oti_transno = lustre_msg_get_transno(req->rq_repmsg); in oti_init()
/linux-4.1.27/drivers/staging/lustre/lustre/osc/
Dosc_quota.c268 if (req->rq_repmsg) { in osc_quotactl()
Dosc_request.c527 oti->oti_transno = lustre_msg_get_transno(req->rq_repmsg); in osc_real_create()
537 lustre_msg_get_transno(req->rq_repmsg)); in osc_real_create()
1508 LASSERTF(req->rq_repmsg != NULL, "rc = %d\n", rc); in osc_brw_fini_request()
/linux-4.1.27/drivers/staging/lustre/lustre/mdc/
Dmdc_request.c143 lustre_msg_get_last_committed(req->rq_repmsg)); in send_getstatus()
936 if (req->rq_repmsg == NULL) { in mdc_close()
944 rc = lustre_msg_get_status(req->rq_repmsg); in mdc_close()
945 if (lustre_msg_get_type(req->rq_repmsg) == PTL_RPC_MSG_ERR) { in mdc_close()
1758 if (req->rq_repmsg) { in mdc_quotactl()
Dmdc_locks.c968 LASSERT(request->rq_repmsg != LP_POISON); in mdc_finish_intent_lock()