Searched refs:early_req (Results 1 – 3 of 3) sorted by relevance
1043 struct ptlrpc_request *early_req; in sptlrpc_cli_unwrap_early_reply() local1048 early_req = ptlrpc_request_cache_alloc(GFP_NOFS); in sptlrpc_cli_unwrap_early_reply()1049 if (early_req == NULL) in sptlrpc_cli_unwrap_early_reply()1100 spin_lock_init(&early_req->rq_lock); in sptlrpc_cli_unwrap_early_reply()1101 early_req->rq_cli_ctx = sptlrpc_cli_ctx_get(req->rq_cli_ctx); in sptlrpc_cli_unwrap_early_reply()1102 early_req->rq_flvr = req->rq_flvr; in sptlrpc_cli_unwrap_early_reply()1103 early_req->rq_repbuf = early_buf; in sptlrpc_cli_unwrap_early_reply()1104 early_req->rq_repbuf_len = early_bufsz; in sptlrpc_cli_unwrap_early_reply()1105 early_req->rq_repdata = (struct lustre_msg *) early_buf; in sptlrpc_cli_unwrap_early_reply()1106 early_req->rq_repdata_len = early_size; in sptlrpc_cli_unwrap_early_reply()[all …]
357 struct ptlrpc_request *early_req; in ptlrpc_at_recv_early_reply() local364 rc = sptlrpc_cli_unwrap_early_reply(req, &early_req); in ptlrpc_at_recv_early_reply()370 rc = unpack_reply(early_req); in ptlrpc_at_recv_early_reply()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()379 sptlrpc_cli_finish_early_reply(early_req); in ptlrpc_at_recv_early_reply()
1004 void sptlrpc_cli_finish_early_reply(struct ptlrpc_request *early_req);