Home
last modified time | relevance | path

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

/linux-4.1.27/drivers/staging/lustre/lustre/ptlrpc/
Dniobuf.c311 (req->rq_reqmsg != NULL) && in ptlrpc_at_set_reply()
312 !(lustre_msg_get_flags(req->rq_reqmsg) & in ptlrpc_at_set_reply()
338 if (req->rq_reqmsg && in ptlrpc_at_set_reply()
339 !(lustre_msghdr_get_flags(req->rq_reqmsg) & MSGHDR_AT_SUPPORT)) { in ptlrpc_at_set_reply()
341 flags, lustre_msg_get_flags(req->rq_reqmsg), in ptlrpc_at_set_reply()
342 lustre_msg_is_v1(req->rq_reqmsg), in ptlrpc_at_set_reply()
343 lustre_msg_get_magic(req->rq_reqmsg), in ptlrpc_at_set_reply()
404 req->rq_reqmsg ? lustre_msg_get_opc(req->rq_reqmsg) : 0); in ptlrpc_send_reply()
507 LASSERT(!((lustre_msg_get_flags(request->rq_reqmsg) & MSG_REPLAY) && in ptl_send_rpc()
523 lustre_msg_set_handle(request->rq_reqmsg, in ptl_send_rpc()
[all …]
Dsec_null.c173 req->rq_reqmsg = req->rq_reqbuf; in null_alloc_reqbuf()
182 LASSERTF(req->rq_reqmsg == req->rq_reqbuf, in null_free_reqbuf()
184 req, req->rq_reqmsg, req->rq_reqbuf); in null_free_reqbuf()
230 struct lustre_msg *oldbuf = req->rq_reqmsg; in null_enlarge_reqbuf()
234 LASSERT(req->rq_reqbuf == req->rq_reqmsg); in null_enlarge_reqbuf()
265 req->rq_reqbuf = req->rq_reqmsg = newbuf; in null_enlarge_reqbuf()
272 _sptlrpc_enlarge_msg_inplace(req->rq_reqmsg, segment, newsize); in null_enlarge_reqbuf()
296 req->rq_reqmsg = req->rq_reqbuf; in null_accept()
358 if (lustre_msghdr_get_flags(req->rq_reqmsg) & MSGHDR_AT_SUPPORT) in null_authorize()
Dclient.c248 lustre_msg_set_timeout(req->rq_reqmsg, req->rq_timeout); in ptlrpc_at_set_req_timeout()
297 CDEBUG((lustre_msg_get_flags(req->rq_reqmsg) & MSG_RESENT) ? in ptlrpc_at_adj_net_latency()
603 lustre_msg_add_version(request->rq_reqmsg, version); in __ptlrpc_request_bufs_pack()
636 lustre_msg_set_opc(request->rq_reqmsg, opcode); in __ptlrpc_request_bufs_pack()
1000 if (req->rq_reqmsg != NULL) in ptlrpc_set_add_req()
1001 lustre_msg_set_jobid(req->rq_reqmsg, NULL); in ptlrpc_set_add_req()
1072 DEBUG_REQ(lustre_msg_get_opc(req->rq_reqmsg) == OBD_PING ? in ptlrpc_import_delay_req()
1125 LASSERT(req->rq_reqmsg != NULL); in ptlrpc_console_allow()
1126 opc = lustre_msg_get_opc(req->rq_reqmsg); in ptlrpc_console_allow()
1157 __u32 opc = lustre_msg_get_opc(req->rq_reqmsg); in ptlrpc_check_status()
[all …]
Dsec_plain.c575 req->rq_reqmsg = lustre_msg_buf(req->rq_reqbuf, PLAIN_PACK_MSG_OFF, 0); in plain_alloc_reqbuf()
646 req->rq_reqmsg); in plain_enlarge_reqbuf()
649 oldsize = req->rq_reqmsg->lm_buflens[segment]; in plain_enlarge_reqbuf()
650 req->rq_reqmsg->lm_buflens[segment] = newsize; in plain_enlarge_reqbuf()
651 newmsg_size = lustre_msg_size_v2(req->rq_reqmsg->lm_bufcount, in plain_enlarge_reqbuf()
652 req->rq_reqmsg->lm_buflens); in plain_enlarge_reqbuf()
653 req->rq_reqmsg->lm_buflens[segment] = oldsize; in plain_enlarge_reqbuf()
686 req->rq_reqmsg = lustre_msg_buf(req->rq_reqbuf, in plain_enlarge_reqbuf()
695 _sptlrpc_enlarge_msg_inplace(req->rq_reqmsg, segment, newsize); in plain_enlarge_reqbuf()
772 req->rq_reqmsg = lustre_msg_buf(msg, PLAIN_PACK_MSG_OFF, 0); in plain_accept()
[all …]
Dservice.c1106 if (unlikely(lustre_msg_get_conn_cnt(req->rq_reqmsg) < in ptlrpc_check_req()
1110 lustre_msg_get_conn_cnt(req->rq_reqmsg), in ptlrpc_check_req()
1122 } else if (lustre_msg_get_flags(req->rq_reqmsg) & in ptlrpc_check_req()
1129 } else if (lustre_msg_get_transno(req->rq_reqmsg) != 0 && in ptlrpc_check_req()
1132 lustre_msg_get_transno(req->rq_reqmsg)); in ptlrpc_check_req()
1180 if ((lustre_msghdr_get_flags(req->rq_reqmsg) & MSGHDR_AT_SUPPORT) == 0) in ptlrpc_at_add_timed()
1268 if (!(lustre_msghdr_get_flags(req->rq_reqmsg) & MSGHDR_AT_SUPPORT)) { in ptlrpc_at_send_early_reply()
1274 lustre_msg_get_flags(req->rq_reqmsg) & in ptlrpc_at_send_early_reply()
1321 reqcopy->rq_reqmsg = reqmsg; in ptlrpc_at_send_early_reply()
1322 memcpy(reqmsg, req->rq_reqmsg, req->rq_reqlen); in ptlrpc_at_send_early_reply()
[all …]
Dpack_generic.c228 lustre_init_msg_v2(req->rq_reqmsg, count, lens, bufs); in lustre_pack_request_v2()
229 lustre_msg_add_version(req->rq_reqmsg, PTLRPC_MSG_VERSION); in lustre_pack_request_v2()
376 switch (req->rq_reqmsg->lm_magic) { in lustre_pack_reply_flags()
382 req->rq_reqmsg->lm_magic); in lustre_pack_reply_flags()
387 lustre_msg_size(req->rq_reqmsg->lm_magic, count, lens)); in lustre_pack_reply_flags()
594 rc = __lustre_unpack_msg(req->rq_reqmsg, len); in ptlrpc_unpack_req_msg()
619 struct lustre_msg_v2 *m = inout ? req->rq_reqmsg : req->rq_repmsg; in lustre_unpack_ptlrpc_body_v2()
644 switch (req->rq_reqmsg->lm_magic) { in lustre_unpack_req_ptlrpc_body()
649 req->rq_reqmsg->lm_magic); in lustre_unpack_req_ptlrpc_body()
1553 req->rq_replen = lustre_msg_size(req->rq_reqmsg->lm_magic, count, in ptlrpc_request_set_replen()
[all …]
Dsec.c455 LASSERT(req->rq_reqmsg); in sptlrpc_req_ctx_switch()
475 memcpy(reqmsg, req->rq_reqmsg, reqmsg_size); in sptlrpc_req_ctx_switch()
493 LASSERT(req->rq_reqmsg); in sptlrpc_req_ctx_switch()
494 memcpy(req->rq_reqmsg, reqmsg, reqmsg_size); in sptlrpc_req_ctx_switch()
583 lustre_msg_set_conn_cnt(req->rq_reqmsg, req->rq_import->imp_conn_cnt); in ctx_refresh_timeout()
712 unlikely(req->rq_reqmsg) && in sptlrpc_req_refresh_ctx()
713 lustre_msg_get_flags(req->rq_reqmsg) & MSG_RESENT) { in sptlrpc_req_refresh_ctx()
1050 (lustre_msghdr_get_flags(req->rq_reqmsg) & MSGHDR_AT_SUPPORT)) { in sptlrpc_cli_unwrap_reply()
1150 early_req->rq_reqmsg = req->rq_reqmsg; in sptlrpc_cli_unwrap_early_reply()
1543 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.c712 lustre_msg_set_service_time(request->rq_reqmsg, in ptlrpc_connect_import()
721 lustre_msg_set_timeout(request->rq_reqmsg, request->rq_timeout); in ptlrpc_connect_import()
723 lustre_msg_add_op_flags(request->rq_reqmsg, MSG_CONNECT_NEXT_VER); in ptlrpc_connect_import()
744 lustre_msg_add_op_flags(request->rq_reqmsg, in ptlrpc_connect_import()
749 lustre_msg_add_op_flags(request->rq_reqmsg, in ptlrpc_connect_import()
1263 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.c219 if (req->rq_reqmsg) in ptlrpcd_add_req()
220 lustre_msg_set_jobid(req->rq_reqmsg, NULL); in ptlrpcd_add_req()
Dlproc_ptlrpc.c924 seq_printf(sf, "opc %d\n", lustre_msg_get_opc(req->rq_reqmsg)); in target_print_req()
1126 __u32 op = lustre_msg_get_opc(req->rq_reqmsg); in ptlrpc_lprocfs_rpc_sent()
1147 idx = lustre_msg_get_opc(req->rq_reqmsg); in ptlrpc_lprocfs_brw()
Dnrs.c831 int opc = lustre_msg_get_opc(req->rq_reqmsg); in ptlrpc_nrs_hpreq_add_nolock()
Dlayout.c1747 return loc == RCL_CLIENT ? req->rq_reqmsg : req->rq_repmsg; in __req_msg()
/linux-4.1.27/drivers/staging/lustre/lustre/ldlm/
Dldlm_lockd.c571 if (lustre_msg_get_opc(req->rq_reqmsg) == SEC_CTX_FINI) in ldlm_callback_handler()
586 switch (lustre_msg_get_opc(req->rq_reqmsg)) { in ldlm_callback_handler()
612 lustre_msg_get_opc(req->rq_reqmsg)); in ldlm_callback_handler()
633 lustre_msg_get_opc(req->rq_reqmsg) == LDLM_BL_CALLBACK) { in ldlm_callback_handler()
650 lustre_msg_get_opc(req->rq_reqmsg) == LDLM_BL_CALLBACK) in ldlm_callback_handler()
657 if (lustre_msg_get_opc(req->rq_reqmsg) == LDLM_BL_CALLBACK) { in ldlm_callback_handler()
690 switch (lustre_msg_get_opc(req->rq_reqmsg)) { in ldlm_callback_handler()
Dldlm_lib.c718 rs->rs_opc = lustre_msg_get_opc(req->rq_reqmsg); in target_send_reply()
Dldlm_request.c2217 lustre_msg_set_flags(req->rq_reqmsg, MSG_REQ_REPLAY_DONE); in replay_one_lock()
/linux-4.1.27/drivers/staging/lustre/lustre/include/
Dobd.h702 if (req->rq_reqmsg != NULL && in oti_init()
703 lustre_msg_get_flags(req->rq_reqmsg) & MSG_REPLAY) { in oti_init()
704 __u64 *pre_version = lustre_msg_get_versions(req->rq_reqmsg); in oti_init()
707 oti->oti_transno = lustre_msg_get_transno(req->rq_reqmsg); in oti_init()
714 if (req->rq_reqmsg != NULL) in oti_init()
715 oti->oti_conn_cnt = lustre_msg_get_conn_cnt(req->rq_reqmsg); in oti_init()
Dlustre_net.h1356 struct lustre_msg *rq_reqmsg; member
2803 return lustre_msg_get_magic(req->rq_reqmsg); in lustre_request_magic()
2808 switch (req->rq_reqmsg->lm_magic) { in ptlrpc_req_get_repsize()
2810 return req->rq_reqmsg->lm_repsize; in ptlrpc_req_get_repsize()
2813 req->rq_reqmsg->lm_magic); in ptlrpc_req_get_repsize()
/linux-4.1.27/drivers/staging/lustre/lustre/osc/
Dosc_request.c1516 if (lustre_msg_get_opc(req->rq_reqmsg) == OST_WRITE && in osc_brw_fini_request()
1534 if (lustre_msg_get_opc(req->rq_reqmsg) == OST_WRITE) { in osc_brw_fini_request()
1655 rc = osc_brw_prep_request(lustre_msg_get_opc(request->rq_reqmsg) == in osc_brw_redo_request()
1845 if (lustre_msg_get_opc(req->rq_reqmsg) == OST_WRITE) in brw_interpret()
1990 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.1.27/drivers/staging/lustre/lustre/mdc/
Dmdc_request.c118 lustre_msg_add_flags(req->rq_reqmsg, msg_flags); in send_getstatus()
698 __u32 opc = lustre_msg_get_opc(close_req->rq_reqmsg); in mdc_replay_open()