From: Arshad Hussain Date: Thu, 2 May 2024 10:57:31 +0000 (-0400) Subject: LU-16741 ptlrpc: rename ptlrpc_req_finished for component ptlrpc X-Git-Tag: 2.15.64~202 X-Git-Url: https://git.whamcloud.com/?a=commitdiff_plain;h=157efdc8abb03fd820bb511882b5c85a707df3d4;p=fs%2Flustre-release.git LU-16741 ptlrpc: rename ptlrpc_req_finished for component ptlrpc Patch renames ptlrpc_req_finished to ptlrpc_req_put for ptlrpc component Test-Parameters: trivial Signed-off-by: Arshad Hussain Change-Id: Ic41d76ace564132a369288676398bc881048f851 Reviewed-on: https://review.whamcloud.com/c/fs/lustre-release/+/54988 Tested-by: jenkins Tested-by: Maloo Reviewed-by: Andreas Dilger Reviewed-by: Patrick Farrell Reviewed-by: Oleg Drokin --- diff --git a/lustre/ptlrpc/batch.c b/lustre/ptlrpc/batch.c index ecaa860..9fbccae 100644 --- a/lustre/ptlrpc/batch.c +++ b/lustre/ptlrpc/batch.c @@ -214,7 +214,7 @@ static int batch_prep_update_req(struct batch_update_head *head, out_req: if (rc < 0) - ptlrpc_req_finished(req); + ptlrpc_req_put(req); RETURN(rc); } @@ -493,7 +493,7 @@ static int batch_send_update_req(const struct lu_env *env, } if (req != NULL) - ptlrpc_req_finished(req); + ptlrpc_req_put(req); lprocfs_oh_tally_log2(&obd->u.cli.cl_batch_rpc_hist, head->buh_update_count); diff --git a/lustre/ptlrpc/client.c b/lustre/ptlrpc/client.c index bca26f9..aae522b 100644 --- a/lustre/ptlrpc/client.c +++ b/lustre/ptlrpc/client.c @@ -1160,7 +1160,7 @@ void ptlrpc_set_destroy(struct ptlrpc_request_set *set) req->rq_invalid_rqset = 0; spin_unlock(&req->rq_lock); - ptlrpc_req_finished(req); + ptlrpc_req_put(req); } LASSERT(atomic_read(&set->set_remaining) == 0); @@ -2296,7 +2296,7 @@ interpret: /* record rq_status to compute the final status later */ if (req->rq_status != 0) set->set_rc = req->rq_status; - ptlrpc_req_finished(req); + ptlrpc_req_put(req); } else { list_move_tail(&req->rq_set_chain, &comp_reqs); } @@ -3730,7 +3730,7 @@ void ptlrpcd_destroy_work(void *handler) struct ptlrpc_request *req = handler; if (req) - ptlrpc_req_finished(req); + ptlrpc_req_put(req); } EXPORT_SYMBOL(ptlrpcd_destroy_work); diff --git a/lustre/ptlrpc/events.c b/lustre/ptlrpc/events.c index 789bc75..11762ba 100644 --- a/lustre/ptlrpc/events.c +++ b/lustre/ptlrpc/events.c @@ -83,7 +83,7 @@ void request_out_callback(struct lnet_event *ev) spin_unlock(&req->rq_lock); - ptlrpc_req_finished(req); + ptlrpc_req_put(req); EXIT; } diff --git a/lustre/ptlrpc/gss/gss_cli_upcall.c b/lustre/ptlrpc/gss/gss_cli_upcall.c index 073fa12..09bf063 100644 --- a/lustre/ptlrpc/gss/gss_cli_upcall.c +++ b/lustre/ptlrpc/gss/gss_cli_upcall.c @@ -383,7 +383,7 @@ out_copy: rc = 0; class_import_put(imp); - ptlrpc_req_finished(req); + ptlrpc_req_put(req); RETURN(rc); } @@ -446,7 +446,7 @@ int gss_do_ctx_fini_rpc(struct gss_cli_ctx *gctx) ctx->cc_vcred.vc_uid, sec2target_str(ctx->cc_sec), rc); out_ref: - ptlrpc_req_finished(req); + ptlrpc_req_put(req); out: RETURN(rc); } diff --git a/lustre/ptlrpc/import.c b/lustre/ptlrpc/import.c index e9340e9..496458c 100644 --- a/lustre/ptlrpc/import.c +++ b/lustre/ptlrpc/import.c @@ -1767,7 +1767,7 @@ int ptlrpc_disconnect_import(struct obd_import *imp, int noclose) spin_unlock(&imp->imp_lock); rc = ptlrpc_queue_wait(req); - ptlrpc_req_finished(req); + ptlrpc_req_put(req); set_state: spin_lock(&imp->imp_lock); diff --git a/lustre/ptlrpc/llog_client.c b/lustre/ptlrpc/llog_client.c index 42be66a..349bc57 100644 --- a/lustre/ptlrpc/llog_client.c +++ b/lustre/ptlrpc/llog_client.c @@ -143,7 +143,7 @@ static int llog_client_open(const struct lu_env *env, EXIT; out: llog_client_exit(ctxt, imp); - ptlrpc_req_finished(req); + ptlrpc_req_put(req); return rc; } @@ -217,7 +217,7 @@ static int llog_client_next_block(const struct lu_env *env, memcpy(buf, ptr, len); EXIT; out: - ptlrpc_req_finished(req); + ptlrpc_req_put(req); err_exit: llog_client_exit(loghandle->lgh_ctxt, imp); return rc; @@ -270,7 +270,7 @@ static int llog_client_prev_block(const struct lu_env *env, memcpy(buf, ptr, len); EXIT; out: - ptlrpc_req_finished(req); + ptlrpc_req_put(req); err_exit: llog_client_exit(loghandle->lgh_ctxt, imp); return rc; @@ -338,7 +338,7 @@ static int llog_client_read_header(const struct lu_env *env, } EXIT; out: - ptlrpc_req_finished(req); + ptlrpc_req_put(req); err_exit: llog_client_exit(handle->lgh_ctxt, imp); return rc; diff --git a/lustre/ptlrpc/lproc_ptlrpc.c b/lustre/ptlrpc/lproc_ptlrpc.c index ce27a97..ae29ac3 100644 --- a/lustre/ptlrpc/lproc_ptlrpc.c +++ b/lustre/ptlrpc/lproc_ptlrpc.c @@ -1350,7 +1350,7 @@ ssize_t ping_show(struct kobject *kobj, struct attribute *attr, req->rq_send_state = LUSTRE_IMP_FULL; rc = ptlrpc_queue_wait(req); - ptlrpc_req_finished(req); + ptlrpc_req_put(req); RETURN(rc); } diff --git a/lustre/ptlrpc/niobuf.c b/lustre/ptlrpc/niobuf.c index 0c72605..0d5687f 100644 --- a/lustre/ptlrpc/niobuf.c +++ b/lustre/ptlrpc/niobuf.c @@ -978,7 +978,7 @@ int ptl_send_rpc(struct ptlrpc_request *request, int noreply) skip_send: request->rq_req_unlinked = 1; - ptlrpc_req_finished(request); + ptlrpc_req_put(request); if (noreply) GOTO(out, rc); diff --git a/lustre/ptlrpc/pack_generic.c b/lustre/ptlrpc/pack_generic.c index babc190..c8f082d 100644 --- a/lustre/ptlrpc/pack_generic.c +++ b/lustre/ptlrpc/pack_generic.c @@ -1755,7 +1755,7 @@ int do_set_info_async(struct obd_import *imp, ptlrpc_check_set(NULL, set); } else { rc = ptlrpc_queue_wait(req); - ptlrpc_req_finished(req); + ptlrpc_req_put(req); } RETURN(rc); diff --git a/lustre/ptlrpc/pinger.c b/lustre/ptlrpc/pinger.c index 0abc772..431b9a1 100644 --- a/lustre/ptlrpc/pinger.c +++ b/lustre/ptlrpc/pinger.c @@ -86,7 +86,7 @@ int ptlrpc_obd_ping(struct obd_device *obd) } req->rq_send_state = LUSTRE_IMP_FULL; rc = ptlrpc_queue_wait(req); - ptlrpc_req_finished(req); + ptlrpc_req_put(req); } RETURN(rc); } diff --git a/lustre/ptlrpc/ptlrpcd.c b/lustre/ptlrpc/ptlrpcd.c index 3b90bce..2186372 100644 --- a/lustre/ptlrpc/ptlrpcd.c +++ b/lustre/ptlrpc/ptlrpcd.c @@ -373,7 +373,7 @@ static int ptlrpcd_check(struct lu_env *env, struct ptlrpcd_ctl *pc) list_del_init(&req->rq_set_chain); req->rq_set = NULL; - ptlrpc_req_finished(req); + ptlrpc_req_put(req); } if (rc == 0) {