Home
last modified time | relevance | path

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

/linux-4.4.14/drivers/staging/lustre/lustre/ptlrpc/
Dsec_null.c175 req->rq_reqmsg = req->rq_reqbuf; in null_alloc_reqbuf()
184 LASSERTF(req->rq_reqmsg == req->rq_reqbuf, in null_free_reqbuf()
186 req, req->rq_reqmsg, req->rq_reqbuf); in null_free_reqbuf()
232 struct lustre_msg *oldbuf = req->rq_reqmsg; in null_enlarge_reqbuf()
236 LASSERT(req->rq_reqbuf == req->rq_reqmsg); in null_enlarge_reqbuf()
267 req->rq_reqbuf = req->rq_reqmsg = newbuf; in null_enlarge_reqbuf()
274 _sptlrpc_enlarge_msg_inplace(req->rq_reqmsg, segment, newsize); in null_enlarge_reqbuf()
298 req->rq_reqmsg = req->rq_reqbuf; in null_accept()
360 if (lustre_msghdr_get_flags(req->rq_reqmsg) & MSGHDR_AT_SUPPORT) in null_authorize()
Dniobuf.c309 (req->rq_reqmsg != NULL) && in ptlrpc_at_set_reply()
310 !(lustre_msg_get_flags(req->rq_reqmsg) & in ptlrpc_at_set_reply()
335 if (req->rq_reqmsg && in ptlrpc_at_set_reply()
336 !(lustre_msghdr_get_flags(req->rq_reqmsg) & MSGHDR_AT_SUPPORT)) { in ptlrpc_at_set_reply()
338 flags, lustre_msg_get_flags(req->rq_reqmsg), in ptlrpc_at_set_reply()
339 lustre_msg_get_magic(req->rq_reqmsg), in ptlrpc_at_set_reply()
400 req->rq_reqmsg ? lustre_msg_get_opc(req->rq_reqmsg) : 0); in ptlrpc_send_reply()
503 LASSERT(!((lustre_msg_get_flags(request->rq_reqmsg) & MSG_REPLAY) && in ptl_send_rpc()
519 lustre_msg_set_handle(request->rq_reqmsg, in ptl_send_rpc()
521 lustre_msg_set_type(request->rq_reqmsg, PTL_RPC_MSG_REQUEST); in ptl_send_rpc()
[all …]
Dclient.c257 lustre_msg_set_timeout(req->rq_reqmsg, req->rq_timeout); in ptlrpc_at_set_req_timeout()
309 CDEBUG((lustre_msg_get_flags(req->rq_reqmsg) & MSG_RESENT) ? in ptlrpc_at_adj_net_latency()
617 lustre_msg_add_version(request->rq_reqmsg, version); in __ptlrpc_request_bufs_pack()
650 lustre_msg_set_opc(request->rq_reqmsg, opcode); in __ptlrpc_request_bufs_pack()
954 if (req->rq_reqmsg != NULL) in ptlrpc_set_add_req()
955 lustre_msg_set_jobid(req->rq_reqmsg, NULL); in ptlrpc_set_add_req()
1028 DEBUG_REQ(lustre_msg_get_opc(req->rq_reqmsg) == OBD_PING ? in ptlrpc_import_delay_req()
1081 LASSERT(req->rq_reqmsg != NULL); in ptlrpc_console_allow()
1082 opc = lustre_msg_get_opc(req->rq_reqmsg); in ptlrpc_console_allow()
1115 __u32 opc = lustre_msg_get_opc(req->rq_reqmsg); in ptlrpc_check_status()
[all …]
Dsec_plain.c574 req->rq_reqmsg = lustre_msg_buf(req->rq_reqbuf, PLAIN_PACK_MSG_OFF, 0); in plain_alloc_reqbuf()
645 req->rq_reqmsg); in plain_enlarge_reqbuf()
648 oldsize = req->rq_reqmsg->lm_buflens[segment]; in plain_enlarge_reqbuf()
649 req->rq_reqmsg->lm_buflens[segment] = newsize; in plain_enlarge_reqbuf()
650 newmsg_size = lustre_msg_size_v2(req->rq_reqmsg->lm_bufcount, in plain_enlarge_reqbuf()
651 req->rq_reqmsg->lm_buflens); in plain_enlarge_reqbuf()
652 req->rq_reqmsg->lm_buflens[segment] = oldsize; in plain_enlarge_reqbuf()
685 req->rq_reqmsg = lustre_msg_buf(req->rq_reqbuf, in plain_enlarge_reqbuf()
694 _sptlrpc_enlarge_msg_inplace(req->rq_reqmsg, segment, newsize); in plain_enlarge_reqbuf()
771 req->rq_reqmsg = lustre_msg_buf(msg, PLAIN_PACK_MSG_OFF, 0); in plain_accept()
[all …]
Dservice.c864 if (unlikely(lustre_msg_get_conn_cnt(req->rq_reqmsg) < in ptlrpc_check_req()
868 lustre_msg_get_conn_cnt(req->rq_reqmsg), in ptlrpc_check_req()
880 } else if (lustre_msg_get_flags(req->rq_reqmsg) & in ptlrpc_check_req()
885 } else if (lustre_msg_get_transno(req->rq_reqmsg) != 0) { in ptlrpc_check_req()
888 lustre_msg_get_transno(req->rq_reqmsg)); in ptlrpc_check_req()
936 if ((lustre_msghdr_get_flags(req->rq_reqmsg) & MSGHDR_AT_SUPPORT) == 0) in ptlrpc_at_add_timed()
1024 if (!(lustre_msghdr_get_flags(req->rq_reqmsg) & MSGHDR_AT_SUPPORT)) { in ptlrpc_at_send_early_reply()
1063 reqcopy->rq_reqmsg = reqmsg; in ptlrpc_at_send_early_reply()
1064 memcpy(reqmsg, req->rq_reqmsg, req->rq_reqlen); in ptlrpc_at_send_early_reply()
1076 lustre_msg_get_handle(reqcopy->rq_reqmsg)); in ptlrpc_at_send_early_reply()
[all …]
Dpack_generic.c211 lustre_init_msg_v2(req->rq_reqmsg, count, lens, bufs); in lustre_pack_request_v2()
212 lustre_msg_add_version(req->rq_reqmsg, PTLRPC_MSG_VERSION); in lustre_pack_request_v2()
359 switch (req->rq_reqmsg->lm_magic) { in lustre_pack_reply_flags()
365 req->rq_reqmsg->lm_magic); in lustre_pack_reply_flags()
370 lustre_msg_size(req->rq_reqmsg->lm_magic, count, lens)); in lustre_pack_reply_flags()
579 rc = __lustre_unpack_msg(req->rq_reqmsg, len); in ptlrpc_unpack_req_msg()
605 struct lustre_msg_v2 *m = inout ? req->rq_reqmsg : req->rq_repmsg; in lustre_unpack_ptlrpc_body_v2()
630 switch (req->rq_reqmsg->lm_magic) { in lustre_unpack_req_ptlrpc_body()
635 req->rq_reqmsg->lm_magic); in lustre_unpack_req_ptlrpc_body()
1407 req->rq_replen = lustre_msg_size(req->rq_reqmsg->lm_magic, count, in ptlrpc_request_set_replen()
[all …]
Dsec.c414 LASSERT(req->rq_reqmsg); in sptlrpc_req_ctx_switch()
434 memcpy(reqmsg, req->rq_reqmsg, reqmsg_size); in sptlrpc_req_ctx_switch()
452 LASSERT(req->rq_reqmsg); in sptlrpc_req_ctx_switch()
453 memcpy(req->rq_reqmsg, reqmsg, reqmsg_size); in sptlrpc_req_ctx_switch()
541 lustre_msg_set_conn_cnt(req->rq_reqmsg, req->rq_import->imp_conn_cnt); in ctx_refresh_timeout()
670 unlikely(req->rq_reqmsg) && in sptlrpc_req_refresh_ctx()
671 lustre_msg_get_flags(req->rq_reqmsg) & MSG_RESENT) { in sptlrpc_req_refresh_ctx()
1008 (lustre_msghdr_get_flags(req->rq_reqmsg) & MSGHDR_AT_SUPPORT)) { in sptlrpc_cli_unwrap_reply()
1108 early_req->rq_reqmsg = req->rq_reqmsg; in sptlrpc_cli_unwrap_early_reply()
1487 LASSERT(req->rq_reqmsg == NULL); in sptlrpc_cli_alloc_reqbuf()
[all …]
Drecover.c157 lustre_msg_add_flags(req->rq_reqmsg, MSG_RESENT); in ptlrpc_replay_next()
238 lustre_msg_get_conn_cnt(failed_req->rq_reqmsg))) { in ptlrpc_request_handle_notconn()
Dimport.c704 lustre_msg_set_service_time(request->rq_reqmsg, in ptlrpc_connect_import()
713 lustre_msg_set_timeout(request->rq_reqmsg, request->rq_timeout); in ptlrpc_connect_import()
715 lustre_msg_add_op_flags(request->rq_reqmsg, MSG_CONNECT_NEXT_VER); in ptlrpc_connect_import()
736 lustre_msg_add_op_flags(request->rq_reqmsg, in ptlrpc_connect_import()
741 lustre_msg_add_op_flags(request->rq_reqmsg, in ptlrpc_connect_import()
1253 lustre_msg_add_flags(req->rq_reqmsg, in signal_completed_replay()
Devents.c128 ((lustre_msghdr_get_flags(req->rq_reqmsg) & MSGHDR_AT_SUPPORT))) { in reply_in_callback()
157 lustre_msg_get_flags(req->rq_reqmsg), in reply_in_callback()
Dptlrpcd.c233 if (req->rq_reqmsg) in ptlrpcd_add_req()
234 lustre_msg_set_jobid(req->rq_reqmsg, NULL); in ptlrpcd_add_req()
Dlproc_ptlrpc.c1128 __u32 op = lustre_msg_get_opc(req->rq_reqmsg); in ptlrpc_lprocfs_rpc_sent()
1149 idx = lustre_msg_get_opc(req->rq_reqmsg); in ptlrpc_lprocfs_brw()
Dnrs.c830 int opc = lustre_msg_get_opc(req->rq_reqmsg); in ptlrpc_nrs_hpreq_add_nolock()
Dlayout.c1746 return loc == RCL_CLIENT ? req->rq_reqmsg : req->rq_repmsg; in __req_msg()
/linux-4.4.14/drivers/staging/lustre/lustre/ldlm/
Dldlm_lockd.c547 if (lustre_msg_get_opc(req->rq_reqmsg) == SEC_CTX_FINI) in ldlm_callback_handler()
562 switch (lustre_msg_get_opc(req->rq_reqmsg)) { in ldlm_callback_handler()
588 lustre_msg_get_opc(req->rq_reqmsg)); in ldlm_callback_handler()
609 lustre_msg_get_opc(req->rq_reqmsg) == LDLM_BL_CALLBACK) { in ldlm_callback_handler()
626 lustre_msg_get_opc(req->rq_reqmsg) == LDLM_BL_CALLBACK) in ldlm_callback_handler()
633 if (lustre_msg_get_opc(req->rq_reqmsg) == LDLM_BL_CALLBACK) { in ldlm_callback_handler()
666 switch (lustre_msg_get_opc(req->rq_reqmsg)) { in ldlm_callback_handler()
Dldlm_lib.c715 rs->rs_opc = lustre_msg_get_opc(req->rq_reqmsg); in target_send_reply()
Dldlm_request.c1905 lustre_msg_set_flags(req->rq_reqmsg, MSG_REQ_REPLAY_DONE); in replay_one_lock()
/linux-4.4.14/drivers/staging/lustre/lustre/include/
Dobd.h611 if (req->rq_reqmsg != NULL && in oti_init()
612 lustre_msg_get_flags(req->rq_reqmsg) & MSG_REPLAY) { in oti_init()
613 __u64 *pre_version = lustre_msg_get_versions(req->rq_reqmsg); in oti_init()
616 oti->oti_transno = lustre_msg_get_transno(req->rq_reqmsg); in oti_init()
623 if (req->rq_reqmsg != NULL) in oti_init()
624 oti->oti_conn_cnt = lustre_msg_get_conn_cnt(req->rq_reqmsg); in oti_init()
Dlustre_net.h1350 struct lustre_msg *rq_reqmsg; member
2762 return lustre_msg_get_magic(req->rq_reqmsg); in lustre_request_magic()
2767 switch (req->rq_reqmsg->lm_magic) { in ptlrpc_req_get_repsize()
2769 return req->rq_reqmsg->lm_repsize; in ptlrpc_req_get_repsize()
2772 req->rq_reqmsg->lm_magic); in ptlrpc_req_get_repsize()
/linux-4.4.14/drivers/staging/lustre/lustre/osc/
Dosc_request.c1482 if (lustre_msg_get_opc(req->rq_reqmsg) == OST_WRITE && in osc_brw_fini_request()
1500 if (lustre_msg_get_opc(req->rq_reqmsg) == OST_WRITE) { in osc_brw_fini_request()
1619 rc = osc_brw_prep_request(lustre_msg_get_opc(request->rq_reqmsg) == in osc_brw_redo_request()
1801 if (lustre_msg_get_opc(req->rq_reqmsg) == OST_WRITE) in brw_interpret()
1946 lustre_msg_set_jobid(req->rq_reqmsg, crattr->cra_jobid); in osc_build_rpc()
Dosc_lock.c843 LASSERT(lustre_msg_get_opc(req->rq_reqmsg) == LDLM_GL_CALLBACK); in osc_ldlm_glimpse_ast()
/linux-4.4.14/drivers/staging/lustre/lustre/mdc/
Dmdc_request.c616 __u32 opc = lustre_msg_get_opc(close_req->rq_reqmsg); in mdc_replay_open()