Searched refs:early_req (Results 1 – 3 of 3) sorted by relevance
1085 struct ptlrpc_request *early_req; in sptlrpc_cli_unwrap_early_reply() local1090 early_req = ptlrpc_request_cache_alloc(GFP_NOFS); in sptlrpc_cli_unwrap_early_reply()1091 if (early_req == NULL) in sptlrpc_cli_unwrap_early_reply()1142 spin_lock_init(&early_req->rq_lock); in sptlrpc_cli_unwrap_early_reply()1143 early_req->rq_cli_ctx = sptlrpc_cli_ctx_get(req->rq_cli_ctx); in sptlrpc_cli_unwrap_early_reply()1144 early_req->rq_flvr = req->rq_flvr; in sptlrpc_cli_unwrap_early_reply()1145 early_req->rq_repbuf = early_buf; in sptlrpc_cli_unwrap_early_reply()1146 early_req->rq_repbuf_len = early_bufsz; in sptlrpc_cli_unwrap_early_reply()1147 early_req->rq_repdata = (struct lustre_msg *) early_buf; in sptlrpc_cli_unwrap_early_reply()1148 early_req->rq_repdata_len = early_size; in sptlrpc_cli_unwrap_early_reply()[all …]
345 struct ptlrpc_request *early_req; in ptlrpc_at_recv_early_reply() local352 rc = sptlrpc_cli_unwrap_early_reply(req, &early_req); in ptlrpc_at_recv_early_reply()358 rc = unpack_reply(early_req); in ptlrpc_at_recv_early_reply()362 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()367 sptlrpc_cli_finish_early_reply(early_req); in ptlrpc_at_recv_early_reply()
1029 void sptlrpc_cli_finish_early_reply(struct ptlrpc_request *early_req);